This is an automated email from the ASF dual-hosted git repository. mblow pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/asterixdb.git
commit b0f3ef4e1cec4b945607b7be2182fcb70b2bc58f Author: Michael Blow <[email protected]> AuthorDate: Thu Aug 8 16:38:21 2024 -0400 [NO ISSUE][HYR] Configure bootstrap executors Configure bootstrap executors on Cluster & Node controller services in the event they are accessed during bootstrap. Ext-ref: MB-63076 Change-Id: I36ecba707201b12cb79c92ed765b76321b6daf8b Reviewed-on: https://asterix-gerrit.ics.uci.edu/c/asterixdb/+/18634 Reviewed-by: Michael Blow <[email protected]> Reviewed-by: Ali Alsuliman <[email protected]> Tested-by: Michael Blow <[email protected]> --- .../java/org/apache/hyracks/control/cc/ClusterControllerService.java | 4 +++- .../java/org/apache/hyracks/control/nc/NodeControllerService.java | 4 +++- 2 files changed, 6 insertions(+), 2 deletions(-) diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/ClusterControllerService.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/ClusterControllerService.java index f11e7ffb99..c9ac4efac9 100644 --- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/ClusterControllerService.java +++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-cc/src/main/java/org/apache/hyracks/control/cc/ClusterControllerService.java @@ -34,6 +34,7 @@ import java.util.Timer; import java.util.TimerTask; import java.util.TreeMap; import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; import org.apache.hyracks.api.application.ICCApplication; import org.apache.hyracks.api.client.ClusterControllerInfo; @@ -78,6 +79,7 @@ import org.apache.hyracks.control.common.deployment.DeploymentRun; import org.apache.hyracks.control.common.ipc.CCNCFunctions; import org.apache.hyracks.control.common.logs.LogFile; import org.apache.hyracks.control.common.shutdown.ShutdownRun; +import org.apache.hyracks.control.common.utils.HyracksThreadFactory; import org.apache.hyracks.control.common.work.WorkQueue; import org.apache.hyracks.ipc.api.IIPCI; import org.apache.hyracks.ipc.impl.IPCSystem; @@ -118,7 +120,7 @@ public class ClusterControllerService implements IControllerService { private final WorkQueue workQueue; - private ExecutorService executor; + private ExecutorService executor = Executors.newCachedThreadPool(new HyracksThreadFactory("<bootstrap>")); private final Timer timer; diff --git a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/NodeControllerService.java b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/NodeControllerService.java index f69d106f1d..cc84aebdc3 100644 --- a/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/NodeControllerService.java +++ b/hyracks-fullstack/hyracks/hyracks-control/hyracks-control-nc/src/main/java/org/apache/hyracks/control/nc/NodeControllerService.java @@ -35,6 +35,7 @@ import java.util.Timer; import java.util.TimerTask; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ExecutorService; +import java.util.concurrent.Executors; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicLong; @@ -72,6 +73,7 @@ import org.apache.hyracks.control.common.heartbeat.HeartbeatSchema; import org.apache.hyracks.control.common.ipc.CCNCFunctions; import org.apache.hyracks.control.common.ipc.ClusterControllerRemoteProxy; import org.apache.hyracks.control.common.job.profiling.om.JobProfile; +import org.apache.hyracks.control.common.utils.HyracksThreadFactory; import org.apache.hyracks.control.common.work.FutureValue; import org.apache.hyracks.control.common.work.WorkQueue; import org.apache.hyracks.control.nc.application.NCServiceContext; @@ -145,7 +147,7 @@ public class NodeControllerService implements IControllerService { private final Map<JobId, JobParameterByteStore> jobParameterByteStoreMap = new HashMap<>(); - private ExecutorService executor; + private ExecutorService executor = Executors.newCachedThreadPool(new HyracksThreadFactory("<bootstrap>")); private Map<CcId, HeartbeatManager> heartbeatManagers = new ConcurrentHashMap<>();
