Matthias Pohl created FLINK-37259:
-------------------------------------
Summary: StreamCheckpointingITCase times out
Key: FLINK-37259
URL: https://issues.apache.org/jira/browse/FLINK-37259
Project: Flink
Issue Type: Bug
Components: Runtime / Checkpointing
Affects Versions: 2.0.0, 2.1.0
Reporter: Matthias Pohl
https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=65800&view=logs&j=5c8e7682-d68f-54d1-16a2-a09310218a49&t=86f654fa-ab48-5c1a-25f4-7e7f6afb9bba&l=10103
{code}
"main" #1 prio=5 os_prio=0 cpu=3360.33ms elapsed=12292.07s
tid=0x00007fc4cd89c000 nid=0x7a6d waiting on condition [0x00007fc4cdeb3000]
java.lang.Thread.State: WAITING (parking)
at jdk.internal.misc.Unsafe.park(java.base@17.0.7/Native Method)
- parking to wait for <0x00000000a160fa30> (a
java.util.concurrent.CompletableFuture$Signaller)
at
java.util.concurrent.locks.LockSupport.park(java.base@17.0.7/LockSupport.java:211)
at
java.util.concurrent.CompletableFuture$Signaller.block(java.base@17.0.7/CompletableFuture.java:1864)
at
java.util.concurrent.ForkJoinPool.unmanagedBlock(java.base@17.0.7/ForkJoinPool.java:3463)
at
java.util.concurrent.ForkJoinPool.managedBlock(java.base@17.0.7/ForkJoinPool.java:3434)
at
java.util.concurrent.CompletableFuture.waitingGet(java.base@17.0.7/CompletableFuture.java:1898)
at
java.util.concurrent.CompletableFuture.get(java.base@17.0.7/CompletableFuture.java:2072)
at
org.apache.flink.test.util.TestUtils.submitJobAndWaitForResult(TestUtils.java:102)
at
org.apache.flink.test.checkpointing.StreamFaultToleranceTestBase.runCheckpointedProgram(StreamFaultToleranceTestBase.java:136)
[...]
{code}
Parsing the Maven output reveals that {{StreamCheckpointingITCase}} is the test
run that times out:
{code}
cat 165.txt | grep "Running \|Tests run: " | grep -o '[^ ]*$' | sort | uniq -c
| grep -v " 2"
[...]
1 org.apache.flink.test.checkpointing.StreamCheckpointingITCase
{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
