Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-34426

HybridShuffleITCase.testHybridSelectiveExchangesRestart times out

    XMLWordPrintableJSON

Details

    Description

      https://github.com/apache/flink/actions/runs/7851900779/job/21429781783#step:10:9052

      "ForkJoinPool-1-worker-3" #16 daemon prio=5 os_prio=0 cpu=3397.79ms elapsed=11462.88s tid=0x00007f48966b3800 nid=0x7a303 waiting on condition  [0x00007f486e97a000]
         java.lang.Thread.State: WAITING (parking)
      	at jdk.internal.misc.Unsafe.park(java.base@11.0.19/Native Method)
      	- parking to wait for  <0x00000000a2faa230> (a java.util.concurrent.CompletableFuture$Signaller)
      	at java.util.concurrent.locks.LockSupport.park(java.base@11.0.19/LockSupport.java:194)
      	at java.util.concurrent.CompletableFuture$Signaller.block(java.base@11.0.19/CompletableFuture.java:1796)
      	at java.util.concurrent.ForkJoinPool.managedBlock(java.base@11.0.19/ForkJoinPool.java:3118)
      	at java.util.concurrent.CompletableFuture.waitingGet(java.base@11.0.19/CompletableFuture.java:1823)
      	at java.util.concurrent.CompletableFuture.get(java.base@11.0.19/CompletableFuture.java:1998)
      	at org.apache.flink.util.AutoCloseableAsync.close(AutoCloseableAsync.java:36)
      	at org.apache.flink.test.runtime.JobGraphRunningUtil.execute(JobGraphRunningUtil.java:61)
      	at org.apache.flink.test.runtime.BatchShuffleITCaseBase.executeJob(BatchShuffleITCaseBase.java:117)
      	at org.apache.flink.test.runtime.HybridShuffleITCase.testHybridSelectiveExchangesRestart(HybridShuffleITCase.java:79)
      	at jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(java.base@11.0.19/Native Method)
      [...]
      

      Attachments

        Activity

          People

            Unassigned Unassigned
            mapohl Matthias Pohl
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: