-
Notifications
You must be signed in to change notification settings - Fork 0
The connector raises an UnknownHostException when lost the connection #2
Description
2023-07-18 00:35:33,160 ERROR [kafka-connector-source-redis|task-0] [redis-replicator] socket error. redis-server[redis-cluster-leader-2.redis-cluster-leader-headless.redis-operator.svc:6379] (com.moilioncircle.redis.replicator.RedisSocketReplicator) [pool-9-thread-4]
java.net.UnknownHostException: redis-cluster-leader-2.redis-cluster-leader-headless.redis-operator.svc
at java.base/sun.nio.ch.NioSocketImpl.connect(NioSocketImpl.java:567)
at java.base/java.net.SocksSocketImpl.connect(SocksSocketImpl.java:327)
at java.base/java.net.Socket.connect(Socket.java:633)
at com.moilioncircle.redis.replicator.net.RedisSocketFactory.createSocket(RedisSocketFactory.java:82)
at com.moilioncircle.redis.replicator.RedisSocketReplicator.connect(RedisSocketReplicator.java:355)
at com.moilioncircle.redis.replicator.RedisSocketReplicator.establishConnection(RedisSocketReplicator.java:191)
at com.moilioncircle.redis.replicator.RedisSocketReplicator$RedisSocketReplicatorRetrier.connect(RedisSocketReplicator.java:413)
at com.moilioncircle.redis.replicator.AbstractReplicatorRetrier.retry(AbstractReplicatorRetrier.java:46)
at com.moilioncircle.redis.replicator.RedisSocketReplicator.open(RedisSocketReplicator.java:123)
at com.moilioncircle.redis.replicator.RedisReplicator.open(RedisReplicator.java:274)
at net.galgus.kafka.connect.redis.source.RedisPartialSyncWorker.run(RedisPartialSyncWorker.java:87)
at java.base/java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539)
at java.base/java.util.concurrent.FutureTask.run(FutureTask.java:264)
at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136)
at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635)
at java.base/java.lang.Thread.run(Thread.java:833)