I want to cancel a simple streaming job on a CentOS server, but the job kept being 'canceling', maybe there is some deadlock, but the same program works fine and can be canceled directly in my another ubuntu server, so I don't think it's caused by the program, what should I do to solve this?
2021-06-18 10:05:53,203 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source -> Sink: Unnamed (1/1)#0' did not react to cancelling signal for 30 seconds, but is stuck in method:
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.util.concurrent.CompletableFuture$Signaller.block(CompletableFuture.java:1707)
java.util.concurrent.ForkJoinPool.managedBlock(ForkJoinPool.java:3334)
java.util.concurrent.CompletableFuture.waitingGet(CompletableFuture.java:1742)
java.util.concurrent.CompletableFuture.join(CompletableFuture.java:1947)
org.apache.flink.streaming.runtime.tasks.StreamTask.cleanUpInvoke(StreamTask.java:618)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:552)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:722)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:547)
java.lang.Thread.run(Thread.java:748)