Skip to content
Permalink
Browse files
GIRAPH-1201
closes #84
  • Loading branch information
dlogothetis committed Sep 21, 2018
1 parent 6128d66 commit 7f6a33d94efdfa9f1db4bd71da6ddff10aace45e
Showing 1 changed file with 7 additions and 1 deletion.
@@ -1379,9 +1379,15 @@ private boolean barrierOnWorkerList(String finishedWorkerPath,

// Wait for a signal or timeout
boolean eventTriggered = event.waitMsecs(eventLoopTimeout);

// If the event was triggered, we reset it. In the next loop run, we will
// read ZK to get the new hosts.
if (eventTriggered) {
event.reset();
}

long elapsedTimeSinceRegularRunMsec = System.currentTimeMillis() -
lastRegularRunTimeMsec;
event.reset();
getContext().progress();

if (eventTriggered ||

0 comments on commit 7f6a33d

Please sign in to comment.