[
https://issues.apache.org/jira/browse/FLINK-30846?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17682858#comment-17682858
]
Lijie Wang edited comment on FLINK-30846 at 2/1/23 6:14 AM:
------------------------------------------------------------
In FLINK-30683, we removed the logic of manually configuring the adaptive
batch scheduler, which led to this test running with default scheduler (we
expected this test must run with adaptive batch scheduler).
was (Author: wanglijie95):
In FLINK-30683, we removed the logic of manually configuring the adaptive
batch scheduler, which led to this test running with default scheduler, but
this test must run with adaptive batch scheduler.
> SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource fails
> ----------------------------------------------------------------------------
>
> Key: FLINK-30846
> URL: https://issues.apache.org/jira/browse/FLINK-30846
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.17.0
> Reporter: Matthias Pohl
> Assignee: Junrui Li
> Priority: Blocker
> Labels: test-stability
>
> {{SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource}} is
> timing out
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=45440&view=logs&j=8fd9202e-fd17-5b26-353c-ac1ff76c8f28&t=ea7cf968-e585-52cb-e0fc-f48de023a7ca&l=8599
> {code}
> Jan 31 02:02:28 "ForkJoinPool-1-worker-25" #27 daemon prio=5 os_prio=0
> tid=0x00007fcf74f2b800 nid=0x5476 waiting on condition [0x00007fce2b078000]
> Jan 31 02:02:28 java.lang.Thread.State: WAITING (parking)
> Jan 31 02:02:28 at sun.misc.Unsafe.park(Native Method)
> Jan 31 02:02:28 - parking to wait for <0x00000000a22933e0> (a
> java.util.concurrent.CompletableFuture$Signaller)
> Jan 31 02:02:28 at
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> Jan 31 02:02:28 at
> java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> Jan 31 02:02:28 at
> java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3313)
> Jan 31 02:02:28 at
> java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> Jan 31 02:02:28 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> Jan 31 02:02:28 at
> org.apache.flink.test.scheduling.SpeculativeSchedulerITCase.executeJob(SpeculativeSchedulerITCase.java:216)
> Jan 31 02:02:28 at
> org.apache.flink.test.scheduling.SpeculativeSchedulerITCase.testSpeculativeExecutionOfInputFormatSource(SpeculativeSchedulerITCase.java:162)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
