[GitHub] shpark opened a new pull request #63: [NEMO-124] Support DoFn#output(tag, output)

shpark opened a new pull request #63: [NEMO-124] Support DoFn#output(tag, output) URL: https://github.com/apache/incubator-nemo/pull/63 JIRA: [NEMO-124: Support DoFn#output(tag, output)](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-124) **Major changes:** - Support

[GitHub] wynot12 opened a new pull request #65: [NEMO-106] Move /tests/compiler into /compiler/test

wynot12 opened a new pull request #65: [NEMO-106] Move /tests/compiler into /compiler/test URL: https://github.com/apache/incubator-nemo/pull/65 JIRA: [NEMO-106: Move /tests/compiler into /compiler/test](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-106) **Major

[GitHub] johnyangk opened a new pull request #66: 54 fetch fail

johnyangk opened a new pull request #66: 54 fetch fail URL: https://github.com/apache/incubator-nemo/pull/66 JIRA: [NEMO-##: TITLE](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-##) **Major changes:** - **Minor changes to note:** - **Tests for the

[GitHub] johnyangk opened a new pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal

johnyangk opened a new pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67 JIRA: [NEMO-54: Handle remote data fetch failures due to executor

[GitHub] seojangho opened a new pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

seojangho opened a new pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62 JIRA: [NEMO-71: Add LocationShareAssignmentPass and Example

[GitHub] seojangho commented on issue #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

seojangho commented on issue #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#issuecomment-401712182 Let #61 be merged before reviewing this PR.

[GitHub] johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output)

johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output) URL: https://github.com/apache/incubator-nemo/pull/63#discussion_r199431461 ## File path: common/src/main/java/edu/snu/nemo/common/ContextImpl.java ## @@ -25,14 +25,16 @@ */

[GitHub] johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output)

johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output) URL: https://github.com/apache/incubator-nemo/pull/63#discussion_r199433142 ## File path:

[GitHub] johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output)

johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output) URL: https://github.com/apache/incubator-nemo/pull/63#discussion_r199432811 ## File path:

[GitHub] johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output)

johnyangk commented on a change in pull request #63: [NEMO-124] Support DoFn#output(tag, output) URL: https://github.com/apache/incubator-nemo/pull/63#discussion_r199429645 ## File path: examples/beam/src/main/java/edu/snu/nemo/examples/beam/AdditionalOutputs.java ## @@

[GitHub] johnyangk opened a new pull request #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups

johnyangk opened a new pull request #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups URL: https://github.com/apache/incubator-nemo/pull/53 JIRA: [NEMO-123: Replace PendingTaskCollection with pointers to

[GitHub] seojangho opened a new pull request #54: [NEMO-126] Split ScheduleGroup by pull StageEdges by PhysicalPlanGenerator

seojangho opened a new pull request #54: [NEMO-126] Split ScheduleGroup by pull StageEdges by PhysicalPlanGenerator URL: https://github.com/apache/incubator-nemo/pull/54 JIRA: [NEMO-126: PhysicalPlanGenerator: Split ScheduleGroup by pull

[GitHub] johnyangk commented on issue #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups

johnyangk commented on issue #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups URL: https://github.com/apache/incubator-nemo/pull/53#issuecomment-400184882 @seojangho Thanks! I've addressed your comment.

[GitHub] seojangho opened a new pull request #55: [NEMO-127] Modify DefaultInterTaskDataStorePass not to overwrite property

seojangho opened a new pull request #55: [NEMO-127] Modify DefaultInterTaskDataStorePass not to overwrite property URL: https://github.com/apache/incubator-nemo/pull/55 JIRA: [NEMO-127: DefaultInterTaskDataStorePass: Do not overwrite

[GitHub] johnyangk closed pull request #55: [NEMO-127] Modify DefaultInterTaskDataStorePass not to overwrite property

johnyangk closed pull request #55: [NEMO-127] Modify DefaultInterTaskDataStorePass not to overwrite property URL: https://github.com/apache/incubator-nemo/pull/55 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] seojangho commented on a change in pull request #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups

seojangho commented on a change in pull request #53: [NEMO-123] Replace PendingTaskCollection with pointers to ScheduleGroups URL: https://github.com/apache/incubator-nemo/pull/53#discussion_r198017662 ## File path:

[GitHub] johnyangk closed pull request #54: [NEMO-126] Split ScheduleGroup by pull StageEdges by PhysicalPlanGenerator

johnyangk closed pull request #54: [NEMO-126] Split ScheduleGroup by pull StageEdges by PhysicalPlanGenerator URL: https://github.com/apache/incubator-nemo/pull/54 This is a PR merged from a forked repository. As GitHub hides the original diff on merge, it is displayed below for the sake

[GitHub] johnyangk opened a new pull request #52: [NEMO-122] Manage Task/Stage/Job states in one place

johnyangk opened a new pull request #52: [NEMO-122] Manage Task/Stage/Job states in one place URL: https://github.com/apache/incubator-nemo/pull/52 JIRA: [NEMO-122: Manage Task/Stage/Job states in one place](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-122) **Major

[GitHub] johnyangk commented on issue #52: [NEMO-122] Manage Task/Stage/Job states in one place

johnyangk commented on issue #52: [NEMO-122] Manage Task/Stage/Job states in one place URL: https://github.com/apache/incubator-nemo/pull/52#issuecomment-399820227 @seojangho I've resolved the conflicts.  This is an

[GitHub] johnyangk commented on issue #51: [NEMO-102] Stage Partitioning by PhysicalPlanGenerator

johnyangk commented on issue #51: [NEMO-102] Stage Partitioning by PhysicalPlanGenerator URL: https://github.com/apache/incubator-nemo/pull/51#issuecomment-399810051 @seojangho Overall, looks good to me. I just have one request: can you group the CreateViewTransform vertices with

[GitHub] seojangho closed pull request #52: [NEMO-122] Manage Task/Stage/Job states in one place

seojangho closed pull request #52: [NEMO-122] Manage Task/Stage/Job states in one place URL: https://github.com/apache/incubator-nemo/pull/52 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

[GitHub] seojangho commented on a change in pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal

seojangho commented on a change in pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67#discussion_r199696813 ## File path:

[GitHub] johnyangk commented on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal

johnyangk commented on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67#issuecomment-402029995 Thanks @seojangho. I've addressed your comment.

[GitHub] sanha opened a new pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy

sanha opened a new pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy URL: https://github.com/apache/incubator-nemo/pull/68 JIRA: [NEMO-125: Fix data loss bug caused by SailfishSchedulingPolicy](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-125)

[GitHub] johnyangk commented on a change in pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy

johnyangk commented on a change in pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy URL: https://github.com/apache/incubator-nemo/pull/68#discussion_r199701691 ## File path:

[GitHub] johnyangk commented on a change in pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy

johnyangk commented on a change in pull request #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy URL: https://github.com/apache/incubator-nemo/pull/68#discussion_r199701710 ## File path:

[GitHub] sanha commented on issue #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy

sanha commented on issue #68: [NEMO-125] Fix data loss bug caused by SailfishSchedulingPolicy URL: https://github.com/apache/incubator-nemo/pull/68#issuecomment-402037728 @johnyangk I addressed your comments. Thanks for catching out!

[GitHub] sanha commented on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal

sanha commented on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67#issuecomment-402041357 LGTM. I'm merge this. This is an automated

[GitHub] jeongyooneo closed pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric

jeongyooneo closed pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric URL: https://github.com/apache/incubator-nemo/pull/61 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

[GitHub] bgchun commented on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test

bgchun commented on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test URL: https://github.com/apache/incubator-nemo/pull/65#issuecomment-402058547 Why do we make a new module just for compiler tests? This is

[GitHub] sanha closed pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal

sanha closed pull request #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67 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

[GitHub] sanha edited a comment on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal

sanha edited a comment on issue #67: [NEMO-54] Handle remote data fetch failures due to executor removal URL: https://github.com/apache/incubator-nemo/pull/67#issuecomment-402041357 LGTM. I'm merging this. This is an

[GitHub] jeongyooneo commented on a change in pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric

jeongyooneo commented on a change in pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric URL: https://github.com/apache/incubator-nemo/pull/61#discussion_r199704536 ## File path: runtime/common/src/main/java/edu/snu/nemo/runtime/common/metric/TaskMetric.java

[GitHub] skystar-p commented on a change in pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric

skystar-p commented on a change in pull request #61: [NEMO-20] RESTful APIs to Access Job State and Metric URL: https://github.com/apache/incubator-nemo/pull/61#discussion_r199716044 ## File path: runtime/common/src/main/java/edu/snu/nemo/runtime/common/metric/TaskMetric.java

[GitHub] wynot12 edited a comment on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test

wynot12 edited a comment on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test URL: https://github.com/apache/incubator-nemo/pull/65#issuecomment-402070976 The concern is the dependency between compiler test codes. Actually most of compiler tests can be decomposed and

[GitHub] wynot12 commented on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test

wynot12 commented on issue #65: [NEMO-106] Move /tests/compiler into /compiler/test URL: https://github.com/apache/incubator-nemo/pull/65#issuecomment-402361359 @bgchun @wonook Is this PR okay to go? This is an automated

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199787585 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199800699 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199800181 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199790236 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199789378 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199794727 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199795584 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199793952 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199788962 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199798685 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199794546 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199796747 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199798491 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199796961 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199787487 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199796665 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199795278 ## File path:

[GitHub] johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application

johnyangk commented on a change in pull request #62: [NEMO-71] Add LocationShareAssignmentPass and Example Application URL: https://github.com/apache/incubator-nemo/pull/62#discussion_r199791201 ## File path:

[GitHub] johnyangk opened a new pull request #83: [NEMO-167] Rename Passes and Execution Properties

johnyangk opened a new pull request #83: [NEMO-167] Rename Passes and Execution Properties URL: https://github.com/apache/incubator-nemo/pull/83 JIRA: [NEMO-167: Rename Passes and Execution Properties](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-167) **Major changes:**

[GitHub] jeongyooneo closed pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

jeongyooneo closed pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84 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:

[GitHub] johnyangk opened a new pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

johnyangk opened a new pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84 JIRA: [NEMO-171: Fix confusing ITCase input/output file names](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-171)

[GitHub] jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84#discussion_r207773921 ## File path: examples/spark/src/test/java/edu/snu/nemo/examples/spark/MRJava.java ##

[GitHub] jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84#discussion_r207773584 ## File path: deploy/README.md ## @@ -29,7 +29,7 @@ * git clone Nemo on v-m and

[GitHub] jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84#discussion_r207773921 ## File path: examples/spark/src/test/java/edu/snu/nemo/examples/spark/MRJava.java ##

[GitHub] jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names

jeongyooneo commented on a change in pull request #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84#discussion_r207774259 ## File path: examples/spark/src/test/java/edu/snu/nemo/examples/spark/MRJava.java ##

[GitHub] johnyangk commented on issue #84: [NEMO-171] Fix confusing ITCase input/output file names

johnyangk commented on issue #84: [NEMO-171] Fix confusing ITCase input/output file names URL: https://github.com/apache/incubator-nemo/pull/84#issuecomment-410590810 Thanks @jeongyooneo! I've just removed the commented-out code in `/examples/spark/MRJava.java` as maintaining unused

[GitHub] sanha opened a new pull request #96: [NEMO-177] Fix BytesDecoder to handle empty stream properly

sanha opened a new pull request #96: [NEMO-177] Fix BytesDecoder to handle empty stream properly URL: https://github.com/apache/incubator-nemo/pull/96 JIRA: [NEMO-177: Fix BytesDecoder to handle empty stream properly](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-177)

[GitHub] sanha closed pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program

sanha closed pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program URL: https://github.com/apache/incubator-nemo/pull/94 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

[GitHub] sanha opened a new pull request #98: [NEMO-118] Implement Skipping (De)Serialization by ExecutionProperty

sanha opened a new pull request #98: [NEMO-118] Implement Skipping (De)Serialization by ExecutionProperty URL: https://github.com/apache/incubator-nemo/pull/98 JIRA: [NEMO-118: Implement Skipping (De)Serialization by

[GitHub] seojangho closed pull request #98: [NEMO-118] Implement Skipping (De)Serialization by ExecutionProperty

seojangho closed pull request #98: [NEMO-118] Implement Skipping (De)Serialization by ExecutionProperty URL: https://github.com/apache/incubator-nemo/pull/98 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

[GitHub] jeongyooneo opened a new pull request #99: [NEMo-64] Fix map stage hang under DataSkewPolicy

jeongyooneo opened a new pull request #99: [NEMo-64] Fix map stage hang under DataSkewPolicy URL: https://github.com/apache/incubator-nemo/pull/99 JIRA: [NEMO-64: Fix map stage hang under DataSkewPolicy](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-64) **Major

[GitHub] seojangho closed pull request #93: [NEMO-160] Handle Beam VoidCoder properly

seojangho closed pull request #93: [NEMO-160] Handle Beam VoidCoder properly URL: https://github.com/apache/incubator-nemo/pull/93 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

[GitHub] wonook commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program

wonook commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program URL: https://github.com/apache/incubator-nemo/pull/94#discussion_r208802547 ## File path:

[GitHub] seojangho commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program

seojangho commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program URL: https://github.com/apache/incubator-nemo/pull/94#discussion_r208795793 ## File path:

[GitHub] seojangho closed pull request #96: [NEMO-177] Fix BytesDecoder to handle empty stream properly

seojangho closed pull request #96: [NEMO-177] Fix BytesDecoder to handle empty stream properly URL: https://github.com/apache/incubator-nemo/pull/96 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:

[GitHub] seojangho closed pull request #97: [NEMO-136] Rename SchedulerRunner to TaskDispatcher

seojangho closed pull request #97: [NEMO-136] Rename SchedulerRunner to TaskDispatcher URL: https://github.com/apache/incubator-nemo/pull/97 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

[GitHub] wonook commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program

wonook commented on a change in pull request #94: [NEMO-152] Support Multiple DAGs Execution in a Single User Program URL: https://github.com/apache/incubator-nemo/pull/94#discussion_r208802597 ## File path:

[GitHub] johnyangk opened a new pull request #97: [NEMO-136] Rename SchedulerRunner to TaskDispatcher

johnyangk opened a new pull request #97: [NEMO-136] Rename SchedulerRunner to TaskDispatcher URL: https://github.com/apache/incubator-nemo/pull/97 JIRA: [NEMO-136: Rename SchedulerRunner to TaskDispatcher](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-136) **Major

[GitHub] skystar-p opened a new pull request #95: [NEMO-25] Improve WebUI to use RESTful APIs by Nemo

skystar-p opened a new pull request #95: [NEMO-25] Improve WebUI to use RESTful APIs by Nemo URL: https://github.com/apache/incubator-nemo/pull/95 JIRA: [NEMO-25: Improve WebUI to use RESTful APIs by Nemo](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-25) **Major

[GitHub] johnyangk commented on a change in pull request #86: [NEMO-51] Intermediate data location aware scheduling

johnyangk commented on a change in pull request #86: [NEMO-51] Intermediate data location aware scheduling URL: https://github.com/apache/incubator-nemo/pull/86#discussion_r208068738 ## File path:

[GitHub] wonook opened a new pull request #88: [NEMO-138] Rule-based policy

wonook opened a new pull request #88: [NEMO-138] Rule-based policy URL: https://github.com/apache/incubator-nemo/pull/88 JIRA: [NEMO-138: Rule-based policy](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-138) **Major changes:** - Adds `ConditionalPass` and

[GitHub] johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner

johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner URL: https://github.com/apache/incubator-nemo/pull/85#discussion_r208070628 ## File path:

[GitHub] johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner

johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner URL: https://github.com/apache/incubator-nemo/pull/85#discussion_r208070887 ## File path:

[GitHub] johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner

johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner URL: https://github.com/apache/incubator-nemo/pull/85#discussion_r208069498 ## File path:

[GitHub] johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner

johnyangk commented on a change in pull request #85: [NEMO-172] Implement one partition per one element partitioner URL: https://github.com/apache/incubator-nemo/pull/85#discussion_r208069918 ## File path:

[GitHub] shpark opened a new pull request #87: [NEMO-151] Add OutputWriters for addtional tagged outputs

shpark opened a new pull request #87: [NEMO-151] Add OutputWriters for addtional tagged outputs URL: https://github.com/apache/incubator-nemo/pull/87 JIRA: [NEMO-151: Add OutputWriters for addtional tagged outputs](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-151)

[GitHub] shpark closed pull request #81: [NEMO-151] Add OutputWriters for additional tagged outputs

shpark closed pull request #81: [NEMO-151] Add OutputWriters for additional tagged outputs URL: https://github.com/apache/incubator-nemo/pull/81 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

[GitHub] seojangho closed pull request #87: [NEMO-151] Add OutputWriters for addtional tagged outputs

seojangho closed pull request #87: [NEMO-151] Add OutputWriters for addtional tagged outputs URL: https://github.com/apache/incubator-nemo/pull/87 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:

[GitHub] shpark opened a new pull request #90: [NEMO-81] Support the Beam 'Partition' transform

shpark opened a new pull request #90: [NEMO-81] Support the Beam 'Partition' transform URL: https://github.com/apache/incubator-nemo/pull/90 JIRA: [NEMO-81: TITLE](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-81) **Major changes:** - Supports Beam partition transform

[GitHub] shpark commented on a change in pull request #91: [NEMO-3] Bump up the Beam version to 2.5.0

shpark commented on a change in pull request #91: [NEMO-3] Bump up the Beam version to 2.5.0 URL: https://github.com/apache/incubator-nemo/pull/91#discussion_r208424286 ## File path: runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/datatransfer/OutputCollectorImpl.java

[GitHub] seojangho commented on issue #89: [NEMO-175] Remove 'taskInfo', add Scheduler#completeHeldTask

seojangho commented on issue #89: [NEMO-175] Remove 'taskInfo', add Scheduler#completeHeldTask URL: https://github.com/apache/incubator-nemo/pull/89#issuecomment-411264772 @johnyangk Please check the updates. Thanks. This is

[GitHub] johnyangk closed pull request #85: [NEMO-172] Implement one partition per one element partitioner

johnyangk closed pull request #85: [NEMO-172] Implement one partition per one element partitioner URL: https://github.com/apache/incubator-nemo/pull/85 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

[GitHub] johnyangk closed pull request #88: [NEMO-138] Rule-based policy

johnyangk closed pull request #88: [NEMO-138] Rule-based policy URL: https://github.com/apache/incubator-nemo/pull/88 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 foreign pull

[GitHub] sanha opened a new pull request #92: [NEMO-176] Improve sequential read from disk

sanha opened a new pull request #92: [NEMO-176] Improve sequential read from disk URL: https://github.com/apache/incubator-nemo/pull/92 JIRA: [NEMO-176: Improve sequential read from disk](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-176) **Major changes:** - Read

[GitHub] johnyangk closed pull request #92: [NEMO-176] Improve sequential read from disk

johnyangk closed pull request #92: [NEMO-176] Improve sequential read from disk URL: https://github.com/apache/incubator-nemo/pull/92 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

[GitHub] johnyangk closed pull request #89: [NEMO-175] Remove 'taskInfo', add Scheduler#completeHeldTask

johnyangk closed pull request #89: [NEMO-175] Remove 'taskInfo', add Scheduler#completeHeldTask URL: https://github.com/apache/incubator-nemo/pull/89 This is an automated message from the Apache Git Service. To respond to

[GitHub] wonook opened a new pull request #94: [NEMO-152] Multiple physical plans execution

wonook opened a new pull request #94: [NEMO-152] Multiple physical plans execution URL: https://github.com/apache/incubator-nemo/pull/94 JIRA: [NEMO-152: Multiple physical plans execution](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-152) **Major changes:** - Divides

[GitHub] arunlakshman opened a new pull request #103: [NEMO-11] Generalize Equality of Int Predicates for Loops

arunlakshman opened a new pull request #103: [NEMO-11] Generalize Equality of Int Predicates for Loops URL: https://github.com/apache/incubator-nemo/pull/103 JIRA: [NEMO-11: Generalize Equality of Int Predicates for Loops](https://issues.apache.org/jira/projects/NEMO/issues/NEMO-11)

[GitHub] johnyangk commented on issue #103: [NEMO-11] Generalize Equality of Int Predicates for Loops

johnyangk commented on issue #103: [NEMO-11] Generalize Equality of Int Predicates for Loops URL: https://github.com/apache/incubator-nemo/pull/103#issuecomment-413234136 Hi Arun! A warm welcome to the community. The PR looks good to me. Moving the code to the util package also

[GitHub] seojangho opened a new pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG

seojangho opened a new pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG URL: https://github.com/apache/incubator-nemo/pull/104 JIRA: [NEMO-183: DAG-centric translation from Beam pipeline to IR

[GitHub] johnyangk commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG

johnyangk commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG URL: https://github.com/apache/incubator-nemo/pull/104#discussion_r210493130 ## File path:

[GitHub] johnyangk commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG

johnyangk commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG URL: https://github.com/apache/incubator-nemo/pull/104#discussion_r210491619 ## File path:

[GitHub] seojangho commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG

seojangho commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG URL: https://github.com/apache/incubator-nemo/pull/104#discussion_r210524686 ## File path:

[GitHub] seojangho commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG

seojangho commented on a change in pull request #104: [NEMO-183] DAG-centric translation from Beam pipeline to IR DAG URL: https://github.com/apache/incubator-nemo/pull/104#discussion_r210507204 ## File path:

<    1   2   3   4   5   6   7   8   9   10   >