[FLINK-31138] Either StreamCheckpointingITCase/StreamFaultToleranceTestBase or EventTimeWindowCheckpointingITCase are timinng out

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Won't Do
• Affects Version/s: 1.15.3
• Component/s: Runtime / Checkpointing, Runtime / State Backends
• Labels: test-stability
• Assignee: Unassigned
• Reporter: Matthias Pohl
• Created: 20/Feb/23 10:57
• Updated: 06/Mar/23 12:48
• Resolved: 06/Mar/23 12:48

Description

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

  [...]
  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)
  [...]
  

  or LocalRecoveryITCase/EventTimeWindowCheckpointingITCase:

  [...]
  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)
  [...]
  

Issue Links

• is related to: FLINK-31036 StateCheckpointedITCase timed out
• relates to: FLINK-28076 StreamFaultToleranceTestBase runs into timeout