nemo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeongy...@apache.org
Subject [incubator-nemo] 33/40: relax
Date Fri, 06 Apr 2018 02:36:13 GMT
This is an automated email from the ASF dual-hosted git repository.

jeongyoon pushed a commit to branch skew_exp
in repository https://gitbox.apache.org/repos/asf/incubator-nemo.git

commit f0554c52050dd261f555694e3ab355cce46b85d3
Author: sanha <sanhaleehana@naver.com>
AuthorDate: Thu Mar 22 12:56:55 2018 +0900

    relax
---
 .../runtime/master/scheduler/SourceLocationAwareSchedulingPolicy.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/SourceLocationAwareSchedulingPolicy.java
b/runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/SourceLocationAwareSchedulingPolicy.java
index 06f7532..7e812e8 100644
--- a/runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/SourceLocationAwareSchedulingPolicy.java
+++ b/runtime/master/src/main/java/edu/snu/nemo/runtime/master/scheduler/SourceLocationAwareSchedulingPolicy.java
@@ -102,7 +102,7 @@ public final class SourceLocationAwareSchedulingPolicy implements SchedulingPoli
               final String location = locationHandler.getLocationFuture().get();
               final boolean scheduled =
                   scheduleToLocalExecutor(scheduledTaskGroup, jobStateManager, location);
-              if (!scheduled && System.currentTimeMillis() % 100 == 0) {
+              if (!scheduled && System.currentTimeMillis() % 1000 == 0) {
                 return roundRobinSchedulingPolicy.scheduleTaskGroup(scheduledTaskGroup, jobStateManager);
// delay
               } else {
                 return scheduled;

-- 
To stop receiving notification emails like this one, please contact
jeongyoon@apache.org.

Mime
View raw message