[
https://issues.apache.org/jira/browse/FLINK-29419?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17619341#comment-17619341
]
Xingbo Huang commented on FLINK-29419:
--------------------------------------
[https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=42115&view=logs&j=2c3cbe13-dee0-5837-cf47-3053da9a8a78&t=b78d9d30-509a-5cea-1fef-db7abaa325ae]
HybridShuffleITCase.testHybridSelectiveExchanges hangs too
{code:java}
3:03:31.9738556Z Oct 18 03:03:31 "ForkJoinPool-1-worker-51" #28 daemon prio=5
os_prio=0 cpu=5134.15ms elapsed=3370.05s tid=0x00007f03f4dad000 nid=0x4f71
waiting on condition [0x00007f03c8c12000]
2022-10-18T03:03:31.9739287Z Oct 18 03:03:31 java.lang.Thread.State: WAITING
(parking)
2022-10-18T03:03:31.9739815Z Oct 18 03:03:31 at
jdk.internal.misc.Unsafe.park([email protected]/Native Method)
2022-10-18T03:03:31.9740662Z Oct 18 03:03:31 - parking to wait for
<0x00000000a2748288> (a java.util.concurrent.CompletableFuture$Signaller)
2022-10-18T03:03:31.9741425Z Oct 18 03:03:31 at
java.util.concurrent.locks.LockSupport.park([email protected]/LockSupport.java:194)
2022-10-18T03:03:31.9742584Z Oct 18 03:03:31 at
java.util.concurrent.CompletableFuture$Signaller.block([email protected]/CompletableFuture.java:1796)
2022-10-18T03:03:31.9743340Z Oct 18 03:03:31 at
java.util.concurrent.ForkJoinPool.managedBlock([email protected]/ForkJoinPool.java:3118)
2022-10-18T03:03:31.9744059Z Oct 18 03:03:31 at
java.util.concurrent.CompletableFuture.waitingGet([email protected]/CompletableFuture.java:1823)
2022-10-18T03:03:31.9744783Z Oct 18 03:03:31 at
java.util.concurrent.CompletableFuture.get([email protected]/CompletableFuture.java:1998)
2022-10-18T03:03:31.9745501Z Oct 18 03:03:31 at
org.apache.flink.test.runtime.JobGraphRunningUtil.execute(JobGraphRunningUtil.java:57)
2022-10-18T03:03:31.9746297Z Oct 18 03:03:31 at
org.apache.flink.test.runtime.BatchShuffleITCaseBase.executeJob(BatchShuffleITCaseBase.java:115)
2022-10-18T03:03:31.9747132Z Oct 18 03:03:31 at
org.apache.flink.test.runtime.HybridShuffleITCase.testHybridSelectiveExchanges(HybridShuffleITCase.java:51)
{code}
> HybridShuffle.testHybridFullExchangesRestart hangs
> --------------------------------------------------
>
> Key: FLINK-29419
> URL: https://issues.apache.org/jira/browse/FLINK-29419
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Network
> Affects Versions: 1.16.0, 1.17.0
> Reporter: Huang Xingbo
> Assignee: Weijie Guo
> Priority: Critical
> Labels: pull-request-available, test-stability
>
> {code:java}
> 2022-09-26T10:56:44.0766792Z Sep 26 10:56:44 "ForkJoinPool-1-worker-25" #27
> daemon prio=5 os_prio=0 tid=0x00007f41a4efa000 nid=0x6d76 waiting on
> condition [0x00007f40ac135000]
> 2022-09-26T10:56:44.0767432Z Sep 26 10:56:44 java.lang.Thread.State:
> WAITING (parking)
> 2022-09-26T10:56:44.0767892Z Sep 26 10:56:44 at sun.misc.Unsafe.park(Native
> Method)
> 2022-09-26T10:56:44.0768644Z Sep 26 10:56:44 - parking to wait for
> <0x00000000a0704e18> (a java.util.concurrent.CompletableFuture$Signaller)
> 2022-09-26T10:56:44.0769287Z Sep 26 10:56:44 at
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> 2022-09-26T10:56:44.0769949Z Sep 26 10:56:44 at
> java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> 2022-09-26T10:56:44.0770623Z Sep 26 10:56:44 at
> java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3313)
> 2022-09-26T10:56:44.0771349Z Sep 26 10:56:44 at
> java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> 2022-09-26T10:56:44.0772092Z Sep 26 10:56:44 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2022-09-26T10:56:44.0772777Z Sep 26 10:56:44 at
> org.apache.flink.test.runtime.JobGraphRunningUtil.execute(JobGraphRunningUtil.java:57)
> 2022-09-26T10:56:44.0773534Z Sep 26 10:56:44 at
> org.apache.flink.test.runtime.BatchShuffleITCaseBase.executeJob(BatchShuffleITCaseBase.java:115)
> 2022-09-26T10:56:44.0774333Z Sep 26 10:56:44 at
> org.apache.flink.test.runtime.HybridShuffleITCase.testHybridFullExchangesRestart(HybridShuffleITCase.java:59)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=41343&view=logs&j=a57e0635-3fad-5b08-57c7-a4142d7d6fa9&t=2ef0effc-1da1-50e5-c2bd-aab434b1c5b7
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
