[FLINK-23469] StateBackendContext does not close underlying MiniCluster

• Type: Bug
• Status: Closed
• Priority: Critical
• Resolution: Fixed
• Component/s: Benchmarks
• Labels: pull-request-available
• Assignee: Chesnay Schepler
• Reporter: Dawid Wysakowicz
• Created: 22/Jul/21 09:28
• Updated: 22/Jul/21 09:58
• Resolved: 22/Jul/21 09:58

Description

The StateBackendContext overrides the tearDown() method, but does not call the super.tearDown() which leaves the MiniCluster behind.

http://codespeed.dak8s.net:8080/job/flink-master-benchmarks/8123/consoleFull

10:00:29  Thread[flink-akka.actor.default-dispatcher-31,5,main]
10:00:29    at sun.misc.Unsafe.park(Native Method)
10:00:29    at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824)
10:00:29    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693)
10:00:29    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
10:00:29  
10:00:29  Thread[flink-metrics-6,1,main]
10:00:29    at sun.misc.Unsafe.park(Native Method)
10:00:29    at java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215)
10:00:29    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2078)
10:00:29    at java.util.concurrent.LinkedBlockingQueue.poll(LinkedBlockingQueue.java:467)
10:00:29    at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1073)
10:00:29    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
10:00:29    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
10:00:29    at java.lang.Thread.run(Thread.java:748)
10:00:29  
10:00:29  Thread[pool-4-thread-1,5,main]
10:00:29    at sun.misc.Unsafe.park(Native Method)
10:00:29    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
10:00:29    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:2039)
10:00:29    at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:442)
10:00:29    at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:1074)
10:00:29    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1134)
10:00:29    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
10:00:29    at java.lang.Thread.run(Thread.java:748)
10:00:29  
10:00:29  Thread[flink-akka.actor.default-dispatcher-33,5,main]
10:00:29    at sun.misc.Unsafe.park(Native Method)
10:00:29    at java.util.concurrent.ForkJoinPool.awaitWork(ForkJoinPool.java:1824)
10:00:29    at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1693)
10:00:29    at java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
10:00:29  
10:00:29  
10:00:29  <shutdown timeout of 30 seconds expired, forcing forked VM to exit>

Issue Links

• links to: GitHub Pull Request #26