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
##
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
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
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
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
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
##
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
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.
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
##
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
##
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
##
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
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
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
##
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.
---
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
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
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
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
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
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
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
##
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
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
##
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
##
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
##
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
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
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
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
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
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
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:**
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
34 matches
Mail list logo