This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch IOTDB-5904 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit e7f61ac39b158ef6f7ad3eb538d26b96433391d8 Author: Steve Yurong Su <[email protected]> AuthorDate: Sun May 21 17:08:03 2023 +0800 adjust LoadManager's init order on CN --- .../org/apache/iotdb/confignode/manager/ConfigManager.java | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java index a23b6b44412..8c784c1fcc3 100644 --- a/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java +++ b/confignode/src/main/java/org/apache/iotdb/confignode/manager/ConfigManager.java @@ -291,12 +291,14 @@ public class ConfigManager implements IManager { this.modelManager = new ModelManager(this, modelInfo); this.pipeManager = new PipeManager(this, pipeInfo); + // 1. keep PipeManager initialization before LoadManager initialization, because + // LoadManager will register PipeManager as a listener. + // 2. keep RetryFailedTasksThread initialization after LoadManager initialization, + // because RetryFailedTasksThread will keep a reference of LoadManager. + this.loadManager = new LoadManager(this); + this.retryFailedTasksThread = new RetryFailedTasksThread(this); this.clusterQuotaManager = new ClusterQuotaManager(this, quotaInfo); - - // Please keep loadManager initializing at last because it may require other managers to - // register the eventBus - this.loadManager = new LoadManager(this); } public void initConsensusManager() throws IOException {
