nemo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
Subject [incubator-nemo] branch master updated: [NEMO-165] Bug when a task reads from multiple parent tasks
Date Thu, 19 Jul 2018 09:31:23 GMT
This is an automated email from the ASF dual-hosted git repository.

jeongyoon pushed a commit to branch master
in repository

The following commit(s) were added to refs/heads/master by this push:
     new 1a39efa  [NEMO-165] Bug when a task reads from multiple parent tasks
1a39efa is described below

commit 1a39efabb248fc9d195fb55e1a79e645d1df3714
Author: John Yang <>
AuthorDate: Thu Jul 19 18:31:21 2018 +0900

    [NEMO-165] Bug when a task reads from multiple parent tasks
    JIRA: NEMO-165: Bug when a task reads from multiple parent tasks
    Major changes:
    * In TaskExecutor#handleDataFetchers, initialize "int finishedFetcherIndex" in each looping,
and not outside the loop.
    Minor changes to note:
    Tests for the changes:
    Other comments:
    resolves NEMO-165
 .../src/main/java/edu/snu/nemo/runtime/executor/task/ | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/
index bfcd040..7520730 100644
--- a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/
+++ b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/
@@ -350,8 +350,9 @@ public final class TaskExecutor {
   private boolean handleDataFetchers(final List<DataFetcher> fetchers) {
     final List<DataFetcher> availableFetchers = new ArrayList<>(fetchers);
-    int finishedFetcherIndex = NONE_FINISHED;
     while (!availableFetchers.isEmpty()) { // empty means we've consumed all task-external
input data
+      // For this looping of available fetchers.
+      int finishedFetcherIndex = NONE_FINISHED;
       for (int i = 0; i < availableFetchers.size(); i++) {
         final DataFetcher dataFetcher = fetchers.get(i);
         final Object element;

View raw message