Changed executor service in JobManager to support larger clusters

VonRosenchild · Aug 7, 2012 · 807fbc1 · 807fbc1
1 parent 1fa6eae
commit 807fbc1
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/nephele/nephele-server/src/main/java/eu/stratosphere/nephele/jobmanager/JobManager.java b/nephele/nephele-server/src/main/java/eu/stratosphere/nephele/jobmanager/JobManager.java
@@ -159,7 +159,7 @@ public class JobManager implements DeploymentManager, ExtendedManagementProtocol
 
  private final int recommendedClientPollingInterval;
 
- private final ExecutorService executorService = Executors.newSingleThreadExecutor();
+ private final ExecutorService executorService = Executors.newCachedThreadPool();
 
  private final static int SLEEPINTERVAL = 1000;
 

diff --git a/nephele/nephele-server/src/main/java/eu/stratosphere/nephele/taskmanager/TaskManager.java b/nephele/nephele-server/src/main/java/eu/stratosphere/nephele/taskmanager/TaskManager.java
@@ -125,7 +125,7 @@ public class TaskManager implements TaskOperationProtocol, PluginCommunicationPr
 
  private final static int FAILURERETURNCODE = -1;
 
- private final static int DEFAULTPERIODICTASKSINTERVAL = 1000;
+ private final static int DEFAULTPERIODICTASKSINTERVAL = 2000;
 
  /**
  * The instance of the {@link ByteBufferedChannelManager} which is responsible for