Loading...

Type: Bug
Resolution: Done
Priority: Major
Fix Version/s: 2.6.0.Beta1
Affects Version/s: 2.6.0.Alpha2
Component/s: debezium-server
Labels:
- flaky-test

Blocked:
False
Blocked Reason:

Hide

None

Show
None
Ready:
False
Git Pull Request:
https://github.com/debezium/debezium-server/pull/79
Intelligence Requested:
Market:

SFDC Cases Counter:
SFDC Cases Open:
SFDC Cases Links:

Redis sink tests fail randomly, but very often, with JedisConnectionException: Unexpected end of stream.
Either when the tests connects to the Redis to initialize offset store:

2024-02-28 09:07:24,059 ERROR [io.deb.ser.ConnectorLifecycle] (pool-6-thread-1) Connector completed: success = 'false', message = 'Unable to configure and start the 'io.debezium.server.redis.RedisOffsetBackingStore' offset backing store', error = 'io.debezium.storage.redis.RedisClientConnectionException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.': io.debezium.storage.redis.RedisClientConnectionException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
        at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:103)
        at io.debezium.storage.redis.offset.RedisOffsetBackingStore.connect(RedisOffsetBackingStore.java:52)
        at io.debezium.storage.redis.offset.RedisOffsetBackingStore.start(RedisOffsetBackingStore.java:71)
        at io.debezium.embedded.EmbeddedEngine.initializeOffsetStore(EmbeddedEngine.java:552)
        at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:425)
        at io.debezium.embedded.ConvertingEngineBuilder$1.run(ConvertingEngineBuilder.java:163)
        at io.debezium.server.DebeziumServer.lambda$start$1(DebeziumServer.java:173)
        at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1144)
        at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:642)
        at java.base/java.lang.Thread.run(Thread.java:1583)
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
        at redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:201)
        at redis.clients.jedis.util.RedisInputStream.readByte(RedisInputStream.java:42)
        at redis.clients.jedis.Protocol.process(Protocol.java:126)
        at redis.clients.jedis.Protocol.read(Protocol.java:192)
        at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:316)
        at redis.clients.jedis.Connection.getStatusCodeReply(Connection.java:243)
        at redis.clients.jedis.Jedis.ping(Jedis.java:354)
        at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:92)
        ... 9 more

or during initialization of the test resource:

2024-02-26 15:28:23,238 ERROR [io.qua.run.Application] (main) Failed to start application (with profile [prod]): java.lang.RuntimeException: Failed to start quarkus
        at io.quarkus.runner.ApplicationImpl.doStart(Unknown Source)
        at io.quarkus.runtime.Application.start(Application.java:101)
        at io.quarkus.runtime.ApplicationLifecycleManager.run(ApplicationLifecycleManager.java:111)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:71)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:44)
        at io.quarkus.runtime.Quarkus.run(Quarkus.java:124)
        at io.debezium.server.Main.main(Main.java:15)
        at java.base/jdk.internal.reflect.DirectMethodHandleAccessor.invoke(DirectMethodHandleAccessor.java:103)
        at java.base/java.lang.reflect.Method.invoke(Method.java:580)
        at io.quarkus.bootstrap.runner.QuarkusEntryPoint.doRun(QuarkusEntryPoint.java:61)
        at io.quarkus.bootstrap.runner.QuarkusEntryPoint.main(QuarkusEntryPoint.java:32)
Caused by: io.debezium.storage.redis.RedisClientConnectionException: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
        at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:103)
        at io.debezium.server.redis.RedisStreamChangeConsumer.connect(RedisStreamChangeConsumer.java:101)
        at io.debezium.server.redis.RedisStreamChangeConsumer_Bean.doCreate(Unknown Source)
        at io.debezium.server.redis.RedisStreamChangeConsumer_Bean.create(Unknown Source)
        at io.debezium.server.redis.RedisStreamChangeConsumer_Bean.create(Unknown Source)
        at io.debezium.server.DebeziumServer.start(DebeziumServer.java:131)
        at io.debezium.server.DebeziumServer_Bean.doCreate(Unknown Source)
        at io.debezium.server.DebeziumServer_Bean.create(Unknown Source)
        at io.debezium.server.DebeziumServer_Bean.create(Unknown Source)
        at io.quarkus.arc.impl.AbstractSharedContext.createInstanceHandle(AbstractSharedContext.java:113)
        at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:37)
        at io.quarkus.arc.impl.AbstractSharedContext$1.get(AbstractSharedContext.java:34)
        at io.quarkus.arc.impl.LazyValue.get(LazyValue.java:26)
        at io.quarkus.arc.impl.ComputingCache.computeIfAbsent(ComputingCache.java:69)
        at io.quarkus.arc.impl.AbstractSharedContext.get(AbstractSharedContext.java:34)
        at io.quarkus.arc.impl.ClientProxies.getApplicationScopedDelegate(ClientProxies.java:21)
        at io.debezium.server.DebeziumServer_ClientProxy.arc$delegate(Unknown Source)
        at io.debezium.server.DebeziumServer_ClientProxy.arc_contextualInstance(Unknown Source)
        at io.debezium.server.DebeziumServer_Observer_Synthetic_f28a48f6bdce4326db44aec92fdb5c84d535b5d9.notify(Unknown Source)
        at io.quarkus.arc.impl.EventImpl$Notifier.notifyObservers(EventImpl.java:346)
        at io.quarkus.arc.impl.EventImpl$Notifier.notify(EventImpl.java:328)
        at io.quarkus.arc.impl.EventImpl.fire(EventImpl.java:82)
        at io.quarkus.arc.runtime.ArcRecorder.fireLifecycleEvent(ArcRecorder.java:155)
        at io.quarkus.arc.runtime.ArcRecorder.handleLifecycleEvents(ArcRecorder.java:106)
        at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent1144526294.deploy_0(Unknown Source)
        at io.quarkus.deployment.steps.LifecycleEventsBuildStep$startupEvent1144526294.deploy(Unknown Source)
        ... 11 more
Caused by: redis.clients.jedis.exceptions.JedisConnectionException: Unexpected end of stream.
        at redis.clients.jedis.util.RedisInputStream.ensureFill(RedisInputStream.java:201)
        at redis.clients.jedis.util.RedisInputStream.readByte(RedisInputStream.java:42)
        at redis.clients.jedis.Protocol.process(Protocol.java:126)
        at redis.clients.jedis.Protocol.read(Protocol.java:192)
        at redis.clients.jedis.Connection.readProtocolWithCheckingBroken(Connection.java:316)
        at redis.clients.jedis.Connection.getStatusCodeReply(Connection.java:243)
        at redis.clients.jedis.Jedis.ping(Jedis.java:354)
        at io.debezium.storage.redis.RedisConnection.getRedisClient(RedisConnection.java:92)
        ... 36 more

Details

Description

Attachments

Easy Agile Planning Poker

Activity

People

Dates