nemo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jeongy...@apache.org
Subject [incubator-nemo] 27/40: probability
Date Fri, 06 Apr 2018 02:36:07 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 977ffdb25e77a3caf23757c11fdcc581689a0c89
Author: sanha <sanhaleehana@naver.com>
AuthorDate: Wed Mar 21 14:05:04 2018 +0900

    probability
---
 conf/src/main/java/edu/snu/nemo/conf/JobConf.java                   | 2 +-
 .../master/scheduler/SourceLocationAwareSchedulingPolicy.java       | 6 +++++-
 2 files changed, 6 insertions(+), 2 deletions(-)

diff --git a/conf/src/main/java/edu/snu/nemo/conf/JobConf.java b/conf/src/main/java/edu/snu/nemo/conf/JobConf.java
index 52362eb..d89bf8a 100644
--- a/conf/src/main/java/edu/snu/nemo/conf/JobConf.java
+++ b/conf/src/main/java/edu/snu/nemo/conf/JobConf.java
@@ -144,7 +144,7 @@ public final class JobConf extends ConfigurationModuleBuilder {
   /**
    * Scheduler timeout in ms.
    */
-  @NamedParameter(doc = "Scheduler timeout in ms", short_name = "scheduler_timeout_ms", default_value
= "30")
+  @NamedParameter(doc = "Scheduler timeout in ms", short_name = "scheduler_timeout_ms", default_value
= "10")
   public final class SchedulerTimeoutMs implements Name<Integer> {
   }
 
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 252f80a..acb56c7 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
@@ -126,7 +126,11 @@ public final class SourceLocationAwareSchedulingPolicy implements SchedulingPoli
                     throw new SchedulingException(e);
                   }
                 }
-                return roundRobinSchedulingPolicy.scheduleTaskGroup(scheduledTaskGroup, jobStateManager);
// delay
+                if (System.currentTimeMillis() % 10 == 0) {
+                  return roundRobinSchedulingPolicy.scheduleTaskGroup(scheduledTaskGroup,
jobStateManager); // delay
+                } else {
+                  return false;
+                }
               } catch (final InterruptedException | ExecutionException e) {
                 LOG.error("Error during getting intermediate data location!", e);
               }

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

Mime
View raw message