You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nemo.apache.org by je...@apache.org on 2018/04/06 02:36:07 UTC
[incubator-nemo] 27/40: probability
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 <sa...@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.