[
https://issues.apache.org/jira/browse/FLINK-33416?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17832097#comment-17832097
]
Ryan Skraba commented on FLINK-33416:
-------------------------------------
1.19, jdk8
[https://github.com/apache/flink/actions/runs/8467681781/job/23199435037#step:10:8909]
This looks suspiciously simular in the mvn-2.log:
{code:java}
--------------------------------------------------------------------------------Test
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest.testSlotAllocationAccordingToStrategyResult[testSlotAllocationAccordingToStrategyResult()]
successfully
run.================================================================================13:18:55,524
[ pool-487-thread-1] ERROR org.apache.flink.util.FatalExitExceptionHandler
[] - FATAL: Thread 'pool-487-thread-1' produced an uncaught
exception. Stopping the process...java.util.concurrent.CompletionException:
java.util.concurrent.RejectedExecutionException: Task
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@45bd78c2
rejected from
java.util.concurrent.ScheduledThreadPoolExecutor@479ccf95[Shutting down, pool
size = 1, active threads = 1, queued tasks = 1, completed tasks = 194] at
java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:838)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:811)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:851)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture.handleAsync(CompletableFuture.java:2178)
~[?:1.8.0_392] at
org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer.allocateSlot(DefaultSlotStatusSyncer.java:138)
~[classes/:?] at
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.allocateSlotsAccordingTo(FineGrainedSlotManager.java:722)
~[classes/:?] at
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.checkResourceRequirements(FineGrainedSlotManager.java:645)
~[classes/:?] at
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.lambda$null$12(FineGrainedSlotManager.java:603)
~[classes/:?] at
java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
[?:1.8.0_392] at java.util.concurrent.FutureTask.run(FutureTask.java:266)
[?:1.8.0_392] at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
[?:1.8.0_392] at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
[?:1.8.0_392] at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_392] at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_392] at java.lang.Thread.run(Thread.java:750) [?:1.8.0_392]Caused
by: java.util.concurrent.RejectedExecutionException: Task
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@45bd78c2
rejected from
java.util.concurrent.ScheduledThreadPoolExecutor@479ccf95[Shutting down, pool
size = 1, active threads = 1, queued tasks = 1, completed tasks = 194] at
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)
~[?:1.8.0_392] at
java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)
~[?:1.8.0_392] at
java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:326)
~[?:1.8.0_392] at
java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:533)
~[?:1.8.0_392] at
java.util.concurrent.ScheduledThreadPoolExecutor.execute(ScheduledThreadPoolExecutor.java:622)
~[?:1.8.0_392] at
java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:668)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture$UniCompletion.claim(CompletableFuture.java:543)
~[?:1.8.0_392] at
java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:826)
~[?:1.8.0_392] ... 14 more {code}
> FineGrainedSlotManagerTest failed with fatal error
> --------------------------------------------------
>
> Key: FLINK-33416
> URL: https://issues.apache.org/jira/browse/FLINK-33416
> Project: Flink
> Issue Type: Sub-task
> Components: Runtime / Coordination
> Reporter: Matthias Pohl
> Priority: Major
> Labels: github-actions, test-stability
>
> In FLINK-33245, we reported an error of the
> {{ZooKeeperLeaderElectionConnectionHandlingTest}} failure due to a fatal
> error. The corresponding build is [this
> one|https://github.com/XComp/flink/actions/runs/6472726326/job/17575765131].
> But the stacktrace indicates that it's actually
> {{FineGrainedSlotManagerTest}} which ran before the ZK-related test:
> {code}
> Test
> org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManagerTest.testSlotAllocationAccordingToStrategyResult[testSlotAllocationAccordingToStrategyResult()]
> successfully run.
> ================================================================================
> 19:30:11,463 [ pool-752-thread-1] ERROR
> org.apache.flink.util.FatalExitExceptionHandler [] - FATAL:
> Thread 'pool-752-thread-1' produced an uncaught exception. Stopping the
> process...
> java.util.concurrent.CompletionException:
> java.util.concurrent.RejectedExecutionException: Task
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@1201ef67[Not
> completed, task =
> java.util.concurrent.Executors$RunnableAdapter@1ea6ccfa[Wrapped task =
> java.util.concurrent.CompletableFuture$UniHandle@36f84d94]] rejected from
> java.util.concurrent.ScheduledThreadPoolExecutor@4642c78d[Shutting down, pool
> size = 1, active threads = 1, queued tasks = 1, completed tasks = 194]
> at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:314)
> ~[?:?]
> at
> java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:951)
> ~[?:?]
> at
> java.util.concurrent.CompletableFuture.handleAsync(CompletableFuture.java:2276)
> ~[?:?]
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.DefaultSlotStatusSyncer.allocateSlot(DefaultSlotStatusSyncer.java:138)
> ~[classes/:?]
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.allocateSlotsAccordingTo(FineGrainedSlotManager.java:722)
> ~[classes/:?]
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.checkResourceRequirements(FineGrainedSlotManager.java:645)
> ~[classes/:?]
> at
> org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager.lambda$checkResourceRequirementsWithDelay$12(FineGrainedSlotManager.java:603)
> ~[classes/:?]
> at
> java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:515) [?:?]
> at java.util.concurrent.FutureTask.run(FutureTask.java:264) [?:?]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:304)
> [?:?]
> at
> java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128)
> [?:?]
> at
> java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628)
> [?:?]
> at java.lang.Thread.run(Thread.java:829) [?:?]
> Caused by: java.util.concurrent.RejectedExecutionException: Task
> java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask@1201ef67[Not
> completed, task =
> java.util.concurrent.Executors$RunnableAdapter@1ea6ccfa[Wrapped task =
> java.util.concurrent.CompletableFuture$UniHandle@36f84d94]] rejected from
> java.util.concurrent.ScheduledThreadPoolExecutor@4642c78d[Shutting down, pool
> size = 1, active threads = 1, queued tasks = 1, completed tasks = 194]
> at
> java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2055)
> ~[?:?]
> at
> java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:825)
> ~[?:?]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor.delayedExecute(ScheduledThreadPoolExecutor.java:340)
> ~[?:?]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor.schedule(ScheduledThreadPoolExecutor.java:562)
> ~[?:?]
> at
> java.util.concurrent.ScheduledThreadPoolExecutor.execute(ScheduledThreadPoolExecutor.java:705)
> ~[?:?]
> at
> java.util.concurrent.Executors$DelegatedExecutorService.execute(Executors.java:687)
> ~[?:?]
> at
> java.util.concurrent.CompletableFuture.uniHandleStage(CompletableFuture.java:949)
> ~[?:?]
> ... 11 more
> [...]
> {code}
> I leave this issue open for documentation purposes for now. ...in case the
> issue pops up again.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
