Kezhu Wang created FLINK-21821: ---------------------------------- Summary: StreamTask.cancelables was closed concurrent between task canceler and task thread Key: FLINK-21821 URL: https://issues.apache.org/jira/browse/FLINK-21821 Project: Flink Issue Type: Improvement Components: Runtime / Task Affects Versions: 1.13.0 Reporter: Kezhu Wang
I think {{AbstractInvokable.cancel}} should only do flag things but not closing staff. Otherwise task canceler and task thread will contend on these closing tasks. It is same for {{BatchTask.cancel}} which might be confirmed as one potential cause for FLINK-21728. cc [~dwysakowicz] [~roman_khachatryan] [~pnowojski] [~AHeise] -- This message was sent by Atlassian Jira (v8.3.4#803005)