Github user zhijiangW commented on the issue: https://github.com/apache/flink/pull/6238 Thanks for fixing this bug. :) I think there is another potential bug in polling segments from queue during task canceling process, and I pointed out it in the above codes.
---