[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229599612 ## File path: runtime/executor/src/test/java/org/apache/nemo/runtime/executor/task/TaskExecutorTest.java

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229596058 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/task/TaskExecutor.java

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229590607 ## File path:

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229596747 ## File path:

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229589941 ## File path:

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229598008 ## File path: runtime/executor/src/test/java/org/apache/nemo/runtime/executor/task/TaskExecutorTest.java

[GitHub] johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk commented on a change in pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#discussion_r229596994 ## File path: