You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@slider.apache.org by st...@apache.org on 2014/10/06 04:57:05 UTC
[08/24] git commit: SLIDER-476 make AM queue executor non-reentrant
SLIDER-476 make AM queue executor non-reentrant
Project: http://git-wip-us.apache.org/repos/asf/incubator-slider/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-slider/commit/483ab958
Tree: http://git-wip-us.apache.org/repos/asf/incubator-slider/tree/483ab958
Diff: http://git-wip-us.apache.org/repos/asf/incubator-slider/diff/483ab958
Branch: refs/heads/feature/SLIDER-149_Support_a_YARN_service_registry
Commit: 483ab958956f52177205ea928730e4bf71935b34
Parents: 755bb7c
Author: Steve Loughran <st...@apache.org>
Authored: Thu Oct 2 14:25:36 2014 -0700
Committer: Steve Loughran <st...@apache.org>
Committed: Thu Oct 2 14:25:36 2014 -0700
----------------------------------------------------------------------
.../java/org/apache/slider/server/appmaster/SliderAppMaster.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-slider/blob/483ab958/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
----------------------------------------------------------------------
diff --git a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
index cc4f6fe..74a6f34 100644
--- a/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
+++ b/slider-core/src/main/java/org/apache/slider/server/appmaster/SliderAppMaster.java
@@ -409,7 +409,7 @@ public class SliderAppMaster extends AbstractSliderLaunchedService
SliderUtils.validateSliderServerEnvironment(log);
executorService = new WorkflowExecutorService<ExecutorService>("AmExecutor",
- Executors.newCachedThreadPool(
+ Executors.newFixedThreadPool(2,
new ServiceThreadFactory("AmExecutor", true)));
addService(executorService);