autumnust commented on a change in pull request #3250:
URL: https://github.com/apache/gobblin/pull/3250#discussion_r598024598
##########
File path:
gobblin-runtime/src/main/java/org/apache/gobblin/runtime/GobblinMultiTaskAttempt.java
##########
@@ -157,6 +161,11 @@ public void run()
Pair<List<Task>, Boolean> executionResult = runWorkUnits(countDownLatch);
this.tasks = executionResult.getFirst();
+ if (this.tasks.isEmpty() && this.stopped.get()) {
Review comment:
Let me know if this understanding is correct: whenever these two
conditions hold at the same time, it indicates that the cancel happens before
the task is materialized and executed in the executor. ( since the regular
cancel will result in tasks being non empty). Can you add a comment if this is
the case, just to distinguish between the regular cancel.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
