[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_r229598327 ## 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_r229591007 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWaterma

[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: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWaterma

[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_r229591138 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWaterma

[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: runtime/executor/src/test/java/org/apache/nemo/runtime/executor/datatransfer/InputWatermarkMan

[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: runtime/executor/src/test/java/org/apache/nemo/runtime/executor/datatransfer/InputWatermarkMan

[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_r229593679 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/NextOperatorInfo.

[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_r229598953 ## 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_r229599734 ## 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_r229589818 ## File path: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWaterma

[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: runtime/executor/src/main/java/org/apache/nemo/runtime/executor/datatransfer/MultiInputWaterma

[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 issue #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark

2018-10-31 Thread GitBox
johnyangk commented on issue #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark URL: https://github.com/apache/incubator-nemo/pull/138#issuecomment-434618145 @taegeonum @seojangho I've updated the branch. ---

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

[GitHub] taegeonum commented on issue #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
taegeonum commented on issue #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137#issuecomment-434890444 @johnyangk Thanks for the review! I've addressed your comments This is

[GitHub] taegeonum closed pull request #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark

2018-10-31 Thread GitBox
taegeonum closed pull request #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark URL: https://github.com/apache/incubator-nemo/pull/138 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[GitHub] taegeonum commented on issue #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark

2018-10-31 Thread GitBox
taegeonum commented on issue #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark URL: https://github.com/apache/incubator-nemo/pull/138#issuecomment-434892425 LGTM. I will merge it This is an

[GitHub] taegeonum closed pull request #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark

2018-10-31 Thread GitBox
taegeonum closed pull request #138: [NEMO-237] Refactor ParentTaskDataFetcher to emit streaming data and watermark URL: https://github.com/apache/incubator-nemo/pull/138 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the

[GitHub] johnyangk closed pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk closed pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a fo

[GitHub] johnyangk closed pull request #137: [NEMO-232] Implement InputWatermarkManager

2018-10-31 Thread GitBox
johnyangk closed pull request #137: [NEMO-232] Implement InputWatermarkManager URL: https://github.com/apache/incubator-nemo/pull/137 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake of provenance: As this is a fo

[GitHub] jooykim opened a new pull request #140: [NEMO-254] Modify POM to publish maven artifacts

2018-10-31 Thread GitBox
jooykim opened a new pull request #140: [NEMO-254] Modify POM to publish maven artifacts URL: https://github.com/apache/incubator-nemo/pull/140 JIRA: [NEMO-254: Modify POM to publish maven artifacts](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-254) **Major changes:**

[GitHub] taegeonum opened a new pull request #141: [NEMO-252] Fix CreatViewTransform to emit windowed materialized data

2018-10-31 Thread GitBox
taegeonum opened a new pull request #141: [NEMO-252] Fix CreatViewTransform to emit windowed materialized data URL: https://github.com/apache/incubator-nemo/pull/141 JIRA: [NEMO-252: Fix CreatViewTransform to emit windowed materialized data](https://issues.apache.org/jira/projects/NEMO