Matthias Pohl created FLINK-31138: ------------------------------------- Summary: Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out Key: FLINK-31138 URL: https://issues.apache.org/jira/browse/FLINK-31138 Project: Flink Issue Type: Bug Components: Runtime / Checkpointing, Runtime / State Backends Affects Versions: 1.15.3 Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=46283&view=logs&j=4d4a0d10-fca2-5507-8eed-c07f0bdf4887&t=7b25afdf-cc6c-566f-5459-359dc2585798 This build timed out. The stacktraces revealed multiple tests that might have caused this: * {{StreamCheckpointingITCase}} through {{StreamFaultToleranceTestBase.runCheckpointedProgram}} {code} [...] 2023-02-18T07:37:47.6861582Z - locked <0x0000000083c85250> (a java.lang.Object) 2023-02-18T07:37:47.6862179Z at org.apache.flink.streaming.api.operators.StreamSourceContexts$SwitchingOnClose.collect(StreamSourceContexts.java:103) 2023-02-18T07:37:47.6862981Z at org.apache.flink.test.checkpointing.StreamCheckpointingITCase$StringGeneratingSourceFunction.run(StreamCheckpointingITCase.java:169) 2023-02-18T07:37:47.6863762Z - locked <0x0000000083c85250> (a java.lang.Object) [...] 2023-02-18T07:37:47.7904307Z "main" #1 prio=5 os_prio=0 tid=0x00007fca5000b800 nid=0x56636 waiting on condition [0x00007fca57c58000] 2023-02-18T07:37:47.7904803Z java.lang.Thread.State: WAITING (parking) 2023-02-18T07:37:47.7905160Z at sun.misc.Unsafe.park(Native Method) 2023-02-18T07:37:47.7905932Z - parking to wait for <0x0000000083c9df48> (a java.util.concurrent.CompletableFuture$Signaller) 2023-02-18T07:37:47.7906498Z at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) 2023-02-18T07:37:47.7907074Z at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) 2023-02-18T07:37:47.7907764Z at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) 2023-02-18T07:37:47.7908457Z at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) 2023-02-18T07:37:47.7909019Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) 2023-02-18T07:37:47.7909605Z at org.apache.flink.test.util.TestUtils.submitJobAndWaitForResult(TestUtils.java:93) 2023-02-18T07:37:47.7910413Z at org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase.runCheckpointedProgram(StreamFaultToleranceTestBase.java:134) [...] {code} or {{LocalRecoveryITCase}}/{{EventTimeWindowCheckpointingITCase}}: {code} [...] 2023-02-18T07:37:51.6744983Z "main" #1 prio=5 os_prio=0 tid=0x00007efc4000b800 nid=0x5645a waiting on condition [0x00007efc49b4e000] 2023-02-18T07:37:51.6745471Z java.lang.Thread.State: WAITING (parking) 2023-02-18T07:37:51.6745823Z at sun.misc.Unsafe.park(Native Method) 2023-02-18T07:37:51.6746482Z - parking to wait for <0x000000008718cce8> (a java.util.concurrent.CompletableFuture$Signaller) 2023-02-18T07:37:51.6747147Z at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175) 2023-02-18T07:37:51.6747725Z at java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707) 2023-02-18T07:37:51.6748313Z at java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3323) 2023-02-18T07:37:51.6748892Z at java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742) 2023-02-18T07:37:51.6749457Z at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) 2023-02-18T07:37:51.6750118Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1989) 2023-02-18T07:37:51.6750881Z at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1969) 2023-02-18T07:37:51.6751694Z at org.apache.flink.test.checkpointing.EventTimeWindowCheckpointingITCase.testSlidingTimeWindow(EventTimeWindowCheckpointingITCase.java:524) 2023-02-18T07:37:51.6752476Z at org.apache.flink.test.checkpointing.LocalRecoveryITCase.executeTest(LocalRecoveryITCase.java:84) 2023-02-18T07:37:51.6753157Z at org.apache.flink.test.checkpointing.LocalRecoveryITCase.executeTest(LocalRecoveryITCase.java:66) 2023-02-18T07:37:51.6753727Z at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) [...] {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)