gaborgsomogyi commented on PR #204: URL: https://github.com/apache/flink-connector-kafka/pull/204#issuecomment-3638785563
Seem like one test hangs infinitely. If somebody has any idea why and how to solve then plz share ``` 2025-12-10T19:41:02.7473262Z "main" #1 prio=5 os_prio=0 cpu=4081.65ms elapsed=2751.39s tid=0x00007fe15402a0e0 nid=0x48f3 waiting on condition [0x00007fe159df9000] 2025-12-10T19:41:02.7473813Z java.lang.Thread.State: WAITING (parking) 2025-12-10T19:41:02.7474384Z at jdk.internal.misc.Unsafe.park([email protected]/Native Method) 2025-12-10T19:41:02.7475137Z - parking to wait for <0x0000000086400038> (a java.util.concurrent.CompletableFuture$Signaller) 2025-12-10T19:41:02.7475918Z at java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:211) 2025-12-10T19:41:02.7476762Z at java.util.concurrent.CompletableFuture$Signaller.block([email protected]/CompletableFuture.java:1864) 2025-12-10T19:41:02.7477642Z at java.util.concurrent.ForkJoinPool.unmanagedBlock([email protected]/ForkJoinPool.java:3465) 2025-12-10T19:41:02.7478529Z at java.util.concurrent.ForkJoinPool.managedBlock([email protected]/ForkJoinPool.java:3436) 2025-12-10T19:41:02.7479592Z at java.util.concurrent.CompletableFuture.waitingGet([email protected]/CompletableFuture.java:1898) 2025-12-10T19:41:02.7480465Z at java.util.concurrent.CompletableFuture.get([email protected]/CompletableFuture.java:2072) 2025-12-10T19:41:02.7481451Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1878) 2025-12-10T19:41:02.7482585Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1846) 2025-12-10T19:41:02.7483846Z at org.apache.flink.streaming.util.TestStreamEnvironment.execute(TestStreamEnvironment.java:238) 2025-12-10T19:41:02.7484859Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1824) 2025-12-10T19:41:02.7485908Z at org.apache.flink.connector.kafka.sink.KafkaSinkITCase.testRecoveryWithAssertion(KafkaSinkITCase.java:656) 2025-12-10T19:41:02.7486991Z at org.apache.flink.connector.kafka.sink.KafkaSinkITCase.testRecoveryWithExactlyOnceGuarantee(KafkaSinkITCase.java:285) ``` -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
