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.---
