nemo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeongy...@apache.org
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 https://gitbox.apache.org/repos/asf/incubator-nemo.git


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 <johnyangk@gmail.com>
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:
    N/A
    
    Tests for the changes:
    N/A
    
    Other comments:
    N/A
    
    resolves NEMO-165
---
 .../src/main/java/edu/snu/nemo/runtime/executor/task/TaskExecutor.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/TaskExecutor.java
b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/TaskExecutor.java
index bfcd040..7520730 100644
--- a/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/TaskExecutor.java
+++ b/runtime/executor/src/main/java/edu/snu/nemo/runtime/executor/task/TaskExecutor.java
@@ -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;


Mime
View raw message