Github user zhijiangW commented on the issue:
https://github.com/apache/flink/pull/6238
ð
---
Github user NicoK commented on the issue:
https://github.com/apache/flink/pull/6238
actually, it was quite easy to reproduce and the fix was also just as you
proposed - please see the new commits (the old one was only renamed since I
created a separate issue for that now)
---
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.
---
