rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355573202
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTas
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355570314
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355570314
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355490815
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTas
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355479323
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/mailbox/M
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r355482653
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStr
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r354549691
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStr
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r354420898
##
File path:
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/tasks/SourceStr
rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task]
Fix SourceStreamTask cancellation
URL: https://github.com/apache/flink/pull/10446#discussion_r354422240
##
File path:
flink-streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/SourceStr