[FLINK-3266] LocalFlinkMiniCluster leaks resources when multiple jobs are submitted

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.0.0
• Fix Version/s: 1.0.0
• Component/s: Runtime / Task
• Assignee: Stephan Ewen
• Reporter: Gábor Gévay
• Created: 20/Jan/16 15:22
• Updated: 08/Feb/16 23:10
• Resolved: 08/Feb/16 23:09

Description

After a job submitted to a LocalEnvironment finishes, some threads are not stopped, and are stuck in waiting forever.

You can observe this, if you enclose the body of the main function of the WordCount example with a loop that executes 100 times, and monitor the thread count (with VisualVM for example).

(The problem only happens if I use a mini cluster. If I use start-local.sh and submit jobs to it, then there is no leak.)

Sub-Tasks

• JobManager does not shut down dedicated executor properly: Closed
• BlobLibraryCacheManager does not shutdown Timer thread: Closed