[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-09 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-05 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-05 Thread GitBox
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

[GitHub] [flink] rkhachatryan commented on a change in pull request #10446: [FLINK-15076][task] Fix SourceStreamTask cancellation

2019-12-05 Thread GitBox
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