Hi, You are not shutting down the ScheduledExecutorService [1], which means that after job cancelation the thread will continue running getLiveInfo(). The user code class loader, and your classes won't be garbage collected. You should use the RichFunction#close callback to shutdown your thread pool [2].
Best, Gary [1] https://stackoverflow.com/questions/10504172/how-to-shutdown-an-executorservice [2] https://ci.apache.org/projects/flink/flink-docs-release-1.4/dev/api_concepts.html#rich-functions On Thu, Mar 8, 2018 at 3:11 AM, sundy <543950...@qq.com> wrote: > > Hi: > > I faced a problem, the taskmanagers in 3 nodes are still running, I make > sure that all job are cancelled, but I could see that stdout logs are > still printing all the way. The job's parallelism is 6. > > I wrote a scheduled pool like this > > static { > Executors.newScheduledThreadPool(1).scheduleAtFixedRate(new Runnable() { > @Override > public void run() { > try { > getLiveInfo(); > } catch (Exception e) { > e.printStackTrace(); > } > } > }, 0, 60, TimeUnit.SECONDS); > } > > Is that the static methods will still be running in the taskmanagers even > if the job is cancelled? That’s weird. >
