Chesnay Schepler created FLINK-8789: ---------------------------------------
Summary: StoppableFunctions sometimes not detected Key: FLINK-8789 URL: https://issues.apache.org/jira/browse/FLINK-8789 Project: Flink Issue Type: Bug Components: Streaming Affects Versions: 1.5.0 Reporter: Chesnay Schepler While porting the {{TimestampITCase}} i got a strange exception in the logs when running {{testWatermarkPropagationNoFinalWatermarkOnStop}}: {code:java} Caused by: java.lang.UnsupportedOperationException: Stopping not supported by task Source: Custom Source (1/1) (87f44b422280be896bdf44766ebeb53e). at org.apache.flink.runtime.taskmanager.Task.stopExecution(Task.java:965) at org.apache.flink.runtime.taskexecutor.TaskExecutor.stopTask(TaskExecutor.java:549) ... 18 more{code} This source however implements the {{StoppableFunction}} interface. This happens also against a legacy cluster. -- This message was sent by Atlassian JIRA (v7.6.3#76005)