Skip to content

Commit

Permalink
Browse files Browse the repository at this point in the history
0003253: ProcessInfo which is used to gather information about processes
can be corrupted on push and pull because of threading in 3.8
  • Loading branch information
chenson42 committed Dec 13, 2017
1 parent efb556f commit 525905c
Showing 1 changed file with 4 additions and 1 deletion.
Expand Up @@ -1015,6 +1015,10 @@ protected IDataWriter chooseDataWriter(Batch batch) {
}
};
processor.process(ctx);

if (loadInfo.getCurrentBatchCount() == 0) {
loadInfo.setStatus(ProcessStatus.OK);
}
} catch (Exception e) {
isError = true;
throw e;
Expand Down Expand Up @@ -1120,7 +1124,6 @@ public boolean beforeBatchStarted(DataContext context) {
return true;
}
}
processInfo.setStatus(ProcessStatus.OK);
return false;
}

Expand Down

0 comments on commit 525905c

Please sign in to comment.