[ https://issues.apache.org/jira/browse/FLINK-8789?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek updated FLINK-8789: ------------------------------------ Fix Version/s: 1.5.0 > 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 > Priority: Blocker > Fix For: 1.5.0 > > > 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)