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() {
    public void run() {
      try {
      } catch (Exception e) {
  }, 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.

Reply via email to