[
https://issues.apache.org/jira/browse/FLINK-36299?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17883858#comment-17883858
]
Matthias Pohl commented on FLINK-36299:
---------------------------------------
I cannot reproduce the issue. But I found a bug in the
{{AdaptiveSchedulerTest}} implementation: I missed using the right
{{ComponentMainThreadExecutor}} for the {{DefaultDeclarativeSlotPool}}. Instead
of passing in the main thread executor that's used within the test, the test's
main thread was still used which might cause concurrency issues resulting in
the desired resources not being available soon enough.
> AdaptiveSchedulerTest.testStatusMetrics times out
> -------------------------------------------------
>
> Key: FLINK-36299
> URL: https://issues.apache.org/jira/browse/FLINK-36299
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Affects Versions: 2.0-preview
> Reporter: Matthias Pohl
> Assignee: Matthias Pohl
> Priority: Critical
> Labels: test-stability
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=62146&view=logs&j=d89de3df-4600-5585-dadc-9bbc9a5e661c&t=be5a4b15-4b23-56b1-7582-795f58a645a2&l=9849
> {code}
> Sep 15 02:28:22 "ForkJoinPool-495-worker-25" #9352 daemon prio=5 os_prio=0
> tid=0x00007fcdde409000 nid=0x77f4 waiting on condition [0x00007fcd5c52c000]
> Sep 15 02:28:22 java.lang.Thread.State: WAITING (parking)
> Sep 15 02:28:22 at sun.misc.Unsafe.park(Native Method)
> Sep 15 02:28:22 - parking to wait for <0x00000000f8d7d0b8> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> Sep 15 02:28:22 at
> java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
> Sep 15 02:28:22 at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
> Sep 15 02:28:22 at
> java.util.concurrent.ArrayBlockingQueue.take(ArrayBlockingQueue.java:403)
> Sep 15 02:28:22 at
> org.apache.flink.runtime.scheduler.adaptive.AdaptiveSchedulerTest$SubmissionBufferingTaskManagerGateway.waitForSubmissions(AdaptiveSchedulerTest.java:2593)
> Sep 15 02:28:22 at
> org.apache.flink.runtime.scheduler.adaptive.AdaptiveSchedulerTest.testStatusMetrics(AdaptiveSchedulerTest.java:732)
> {code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
