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 <[email protected]> Authored: Thu Oct 2 14:25:36 2014 -0700 Committer: Steve Loughran <[email protected]> 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);
