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)
