[
https://issues.apache.org/jira/browse/FLINK-34070?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17806821#comment-17806821
]
Matthias Pohl commented on FLINK-34070:
---------------------------------------
I provided a PR for this issue that made the test more explicit and covers all
three supported scenarios. Could you have a look?
> MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot fails for the
> AdaptiveScheduler
> ------------------------------------------------------------------------------------------
>
> Key: FLINK-34070
> URL: https://issues.apache.org/jira/browse/FLINK-34070
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Coordination
> Affects Versions: 1.19.0
> Reporter: Matthias Pohl
> Assignee: Matthias Pohl
> Priority: Major
> Labels: pull-request-available, test-stability
>
> We experience test failures of
> {{MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot}} with the
> {{AdaptiveScheduler}} being enabled after FLINK-33414 was fixed:
> {code:java}
> Jan 09 02:01:16 at
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> Jan 09 02:01:16 at
> java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
> Jan 09 02:01:16 at
> java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3313)
> Jan 09 02:01:16 at
> java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
> Jan 09 02:01:16 at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> Jan 09 02:01:16 at
> org.apache.flink.runtime.minicluster.MiniCluster.executeJobBlocking(MiniCluster.java:1050)
> Jan 09 02:01:16 at
> org.apache.flink.runtime.minicluster.MiniClusterITCase.runHandleJobsWhenNotEnoughSlots(MiniClusterITCase.java:152)
> Jan 09 02:01:16 at
> org.apache.flink.runtime.minicluster.MiniClusterITCase.lambda$testHandleStreamingJobsWhenNotEnoughSlot$0(MiniClusterITCase.java:119)
> Jan 09 02:01:16 at
> org.apache.flink.runtime.minicluster.MiniClusterITCase$$Lambda$1927/1144737794.call(Unknown
> Source)
> Jan 09 02:01:16 at
> org.assertj.core.api.ThrowableAssert.catchThrowable(ThrowableAssert.java:63)
> Jan 09 02:01:16 at
> org.assertj.core.api.AssertionsForClassTypes.catchThrowable(AssertionsForClassTypes.java:892)
> Jan 09 02:01:16 at
> org.assertj.core.api.Assertions.catchThrowable(Assertions.java:1366)
> Jan 09 02:01:16 at
> org.assertj.core.api.Assertions.assertThatThrownBy(Assertions.java:1210)
> Jan 09 02:01:16 at
> org.apache.flink.runtime.minicluster.MiniClusterITCase.testHandleStreamingJobsWhenNotEnoughSlot(MiniClusterITCase.java:119)
> Jan 09 02:01:16 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native
> Method)
> Jan 09 02:01:16 at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> Jan 09 02:01:16 at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> {code}
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56124&view=logs&j=0e7be18f-84f2-53f0-a32d-4a5e4a174679&t=7c1d86e3-35bd-5fd5-3b7c-30c126a78702&l=9813]
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56166&view=logs&j=0e7be18f-84f2-53f0-a32d-4a5e4a174679&t=7c1d86e3-35bd-5fd5-3b7c-30c126a78702&l=10782]
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56226&view=logs&j=0e7be18f-84f2-53f0-a32d-4a5e4a174679&t=7c1d86e3-35bd-5fd5-3b7c-30c126a78702&l=10773]
> [https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=56285&view=logs&j=0e7be18f-84f2-53f0-a32d-4a5e4a174679&t=7c1d86e3-35bd-5fd5-3b7c-30c126a78702&l=10800]
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
