[ https://issues.apache.org/jira/browse/FLINK-8751?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Elias Levy updated FLINK-8751: ------------------------------ Description: Canceling a job results in the following exception reported by the TM: {code:java} ERROR org.apache.flink.streaming.runtime.tasks.StreamTask - Could not shut down timer service java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(Unknown Source) at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.shutdownAndAwaitPending(SystemProcessingTimeService.java:197) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:317) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718) at java.lang.Thread.run(Unknown Source){code} was: Canceling a job results in the following exception reported by the JM: {code:java} ERROR org.apache.flink.streaming.runtime.tasks.StreamTask - Could not shut down timer service java.lang.InterruptedException at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(Unknown Source) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(Unknown Source) at org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.shutdownAndAwaitPending(SystemProcessingTimeService.java:197) at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:317) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718) at java.lang.Thread.run(Unknown Source){code} Component/s: (was: JobManager) TaskManager Summary: Canceling a job results in a InterruptedException in the TM (was: Canceling a job results in a InterruptedException in the JM) > Canceling a job results in a InterruptedException in the TM > ----------------------------------------------------------- > > Key: FLINK-8751 > URL: https://issues.apache.org/jira/browse/FLINK-8751 > Project: Flink > Issue Type: Bug > Components: TaskManager > Affects Versions: 1.4.1 > Reporter: Elias Levy > Priority: Major > > Canceling a job results in the following exception reported by the TM: > {code:java} > ERROR org.apache.flink.streaming.runtime.tasks.StreamTask - Could > not shut down timer service java.lang.InterruptedException > at > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(Unknown > Source) at java.util.concurrent.ThreadPoolExecutor.awaitTermination(Unknown > Source) > at > org.apache.flink.streaming.runtime.tasks.SystemProcessingTimeService.shutdownAndAwaitPending(SystemProcessingTimeService.java:197) > > at > org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:317) > at org.apache.flink.runtime.taskmanager.Task.run(Task.java:718) > at java.lang.Thread.run(Unknown Source){code} > -- This message was sent by Atlassian JIRA (v7.6.3#76005)