This is an automated email from the ASF dual-hosted git repository.
CRZbulabula pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/master by this push:
new cb0269d9fde Standardize ConfigRegionStateMachine log messages (#18811)
cb0269d9fde is described below
commit cb0269d9fde8c6adc3ee67b695b902145f1d0636
Author: d-wang-commit <[email protected]>
AuthorDate: Sat Oct 10 10:13:11 2026 +0800
Standardize ConfigRegionStateMachine log messages (#18811)
Add a common [ConfigRegion Update] prefix to English and Chinese logs.
Clarify leadership transitions and replace concatenated messages with
complete templates.
---
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 62 ++++++++++-----------
.../iotdb/confignode/i18n/ConfigNodeMessages.java | 65 +++++++++++-----------
.../statemachine/ConfigRegionStateMachine.java | 16 +++---
3 files changed, 71 insertions(+), 72 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
b/iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
index 6fae63f6536..0e834e0603f 100644
---
a/iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
+++
b/iotdb-core/confignode/src/main/i18n/en/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
@@ -21,6 +21,15 @@ package org.apache.iotdb.confignode.i18n;
public final class ConfigNodeMessages {
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_A_CONFIGREGION_FOLLOWER_NEW_LEADER_NODEID_ARG_STOPPING_LEADER_SERVICES_A1962CD2
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}] is
a ConfigRegion follower; new leader nodeId: {}. Stopping leader services.";
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_NO_LONGER_THE_CONFIGREGION_LEADER_STOPPING_LEADER_SERVICES_5DB0DA66
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}] is
no longer the ConfigRegion leader; stopping leader services.";
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_COMPLETED_STOPPING_LEADER_SERVICES_62381EE1
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
completed stopping leader services.";
+ public static final String
LOG_CONFIGREGION_UPDATE_FAILED_TO_CLOSE_THE_CONFIGNODE_SIMPLECONSENSUS_LOG_FILEPATH_ARG_RETRY_ARG_188A702E
=
+ "[ConfigRegion Update] Failed to close the ConfigNode SimpleConsensus
log, filePath: {}, retry: {}.";
+
public static final String ACQUIRE_TRIGGERTABLELOCK = "acquire
TriggerTableLock";
public static final String ACQUIRE_UDFTABLELOCK = "acquire UDFTableLock";
public static final String ACTIVATING = "Activating {}...";
@@ -38,19 +47,17 @@ public final class ConfigNodeMessages {
"Cannot find RegionGroup for region {} when removeRegionOldLocation in
{}";
public static final String CAN_ONLY_ALTER_DATATYPE_OF_FIELD_COLUMNS =
"Can only alter datatype of FIELD columns";
- public static final String
CAN_T_CLOSE_STANDALONELOG_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "Can't close StandAloneLog for ConfigNode SimpleConsensus mode, ";
public static final String CAN_T_CONNECT_TO_DATA_NODE = "Can't connect to
Data node: {}";
public static final String CAN_T_CONSTRUCT_CLUSTERSCHEMAINFO =
"Can't construct ClusterSchemaInfo";
public static final String CAN_T_DELETE_TEMPORARY_SNAPSHOT_FILE_RETRYING =
"Can't delete temporary snapshot file: {}, retrying...";
public static final String
CAN_T_FORCE_LOGWRITER_FOR_CONFIGNODE_FLUSHWALFORSIMPLECONSENSUS =
- "Can't force logWriter for ConfigNode flushWALForSimpleConsensus";
+ "[ConfigRegion Update] Can't force logWriter for ConfigNode
flushWALForSimpleConsensus";
public static final String
CAN_T_FORCE_LOGWRITER_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "Can't force logWriter for ConfigNode SimpleConsensus mode";
+ "[ConfigRegion Update] Can't force logWriter for ConfigNode
SimpleConsensus mode";
public static final String
CAN_T_SERIALIZE_CURRENT_CONFIGPHYSICALPLAN_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "Can't serialize current ConfigPhysicalPlan for ConfigNode
SimpleConsensus mode";
+ "[ConfigRegion Update] Can't serialize current ConfigPhysicalPlan for
ConfigNode SimpleConsensus mode";
public static final String CAN_T_START_CONFIGNODE_CONSENSUS_GROUP =
"Can't start ConfigNode consensus group!";
public static final String CHANGE_REGIONS_LEADER_ERROR_ON_DATE_NODE =
@@ -96,11 +103,11 @@ public final class ConfigNodeMessages {
public static final String
CONFIGNODE_RPC_SERVICE_START_TO_REMOVE_DATANODE_REQ =
"ConfigNode RPC Service start to remove DataNode, req: {}";
public static final String
CONFIGNODE_SIMPLECONSENSUSFILE_HAS_EXISTED_FILEPATH =
- "ConfigNode SimpleConsensusFile has existed，filePath:{}";
+ "[ConfigRegion Update] ConfigNode SimpleConsensusFile has
existed，filePath:{}";
public static final String
CONFIG_REGION_LISTENING_QUEUE_LISTEN_TO_SNAPSHOT_FAILED_THE_HISTORICAL =
- "Config Region Listening Queue Listen to snapshot failed, the historical
data may not be transferred.";
+ "[ConfigRegion Update] Config Region Listening Queue Listen to snapshot
failed, the historical data may not be transferred.";
public static final String
CONFIG_REGION_LISTENING_QUEUE_LISTEN_TO_SNAPSHOT_FAILED_WHEN_STARTUP =
- "Config Region Listening Queue Listen to snapshot failed when startup,
snapshot will be tried again when starting schema transferring pipes";
+ "[ConfigRegion Update] Config Region Listening Queue Listen to snapshot
failed when startup, snapshot will be tried again when starting schema
transferring pipes";
public static final String
CONTINUOUS_QUERY_MIN_EVERY_INTERVAL_IN_MS_SHOULD_BE_GREATER =
"continuous_query_min_every_interval_in_ms should be greater than 0, but
current value is {}, ignore that and use the default value {}";
public static final String
CONTINUOUS_QUERY_SUBMIT_THREAD_SHOULD_BE_GREATER_THAN_0 =
@@ -112,18 +119,15 @@ public final class ConfigNodeMessages {
public static final String
CREATEREGIONGROUPS_DATABASE_HAS_BEEN_DELETED_CORRESPONDING_REGIONGROUPS =
"[CreateRegionGroups] Database {} has been deleted, corresponding
RegionGroups will not be created.";
public static final String CREATE_CONFIGNODE_SIMPLECONSENSUSFILE =
- "Create ConfigNode SimpleConsensusFile: {}";
+ "[ConfigRegion Update] Create ConfigNode SimpleConsensusFile: {}";
public static final String
CREATE_CONFIGNODE_SIMPLECONSENSUSFILE_FAILED_FILEPATH =
- "Create ConfigNode SimpleConsensusFile failed, filePath: {}";
+ "[ConfigRegion Update] Create ConfigNode SimpleConsensusFile failed,
filePath: {}";
public static final String
CURRENT_NODE_NODEID_IP_PORT_AS_CONFIG_REGION_LEADER_IS =
- "Current node [nodeId: {}, ip:port: {}] as config region leader is ready
to work";
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
completed leader service startup.";
public static final String
CURRENT_NODE_NODEID_IP_PORT_BECOMES_CONFIG_REGION_LEADER =
- "Current node [nodeId: {}, ip:port: {}] becomes config region leader";
- public static final String
CURRENT_NODE_NODEID_IP_PORT_IS_NO_LONGER_THE_LEADER =
- "Current node [nodeId:{}, ip:port: {}] is no longer the leader, ";
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
became the ConfigRegion leader; starting leader services.";
public static final String
MESSAGE_CURRENT_NODE_NODEID_ARG_IP_PORT_ARG_IS_NO_LONGER_THE_LEADER_SKIP_STARTING_LEADER_SERVICES_BECAUSE_THE_LEADER_EPOCH_IS_STALE_CCF39435
=
- "Current node [nodeId:{}, ip:port: {}] is no longer the leader, skip
starting leader "
- + "services because the leader epoch is stale";
+ "[ConfigRegion Update] Skipping leader service startup for ConfigNode
[nodeId: {}, consensusEndpoint: {}] because the leadership epoch is stale.";
public static final String
DATABASE_INCONSISTENCY_DETECTED_WHEN_ADJUSTING_MAX_REGION_GROUP_COUNT_MESSAGE =
"Database inconsistency detected when adjusting max region group count,
message: {}, will be corrected by the following adjusting plans";
public static final String DATABASE_NOT_EXIST = "Database not exist";
@@ -136,7 +140,7 @@ public final class ConfigNodeMessages {
public static final String DELETE_USELESS_PROCEDURE_WAL_DIR_FAIL =
"Delete useless procedure wal dir fail.";
public static final String
DESERIALIZATION_ERROR_FOR_WRITE_PLAN_REQUEST_BYTEBUFFER =
- "Deserialization error for write plan, request: {}, bytebuffer: {}";
+ "[ConfigRegion Update] Deserialization error for write plan, request:
{}, bytebuffer: {}";
public static final String DOES_NOT_EXIST = "%s does not exist";
public static final String DROPPING_TAG_OR_TIME_COLUMN_IS_NOT_SUPPORTED =
"Dropping tag or time column is not supported.";
@@ -162,8 +166,8 @@ public final class ConfigNodeMessages {
"Execute getClusterId with result {}";
public static final String EXECUTE_GETSYSTEMCONFIGURATION_WITH_RESULT =
"Execute GetSystemConfiguration with result {}";
- public static final String EXECUTE_NON_QUERY_PLAN_FAILED = "Execute
non-query plan failed";
- public static final String EXECUTE_QUERY_PLAN_FAILED = "Execute query plan
failed";
+ public static final String EXECUTE_NON_QUERY_PLAN_FAILED = "[ConfigRegion
Update] Execute non-query plan failed";
+ public static final String EXECUTE_QUERY_PLAN_FAILED = "[ConfigRegion
Update] Execute query plan failed";
public static final String EXECUTE_REGISTERAINODEREQUEST_WITH_RESULT =
"Execute RegisterAINodeRequest {} with result {}";
public static final String EXECUTE_REGISTERCONFIGNODEREQUEST_WITH_RESULT =
@@ -309,7 +313,7 @@ public final class ConfigNodeMessages {
"{} has successfully started and joined the cluster: {}.";
public static final String ID_TOOK_SNAPSHOT_FAIL = "{} id {} took snapshot
fail";
public static final String
INITSTANDALONECONFIGNODE_MEETS_ERROR_CAN_T_FIND_STANDALONE_LOG_FILES_FILEPATH =
- "InitStandAloneConfigNode meets error, can't find standalone log files,
filePath: {}";
+ "[ConfigRegion Update] InitStandAloneConfigNode meets error, can't find
standalone log files, filePath: {}";
public static final String INVALID_AUTHOR_TYPE_ORDINAL = "Invalid Author
Type ordinal";
public static final String IOTDB_STARTED = "IoTDB started";
public static final String IS_DEACTIVATED = "{} is deactivated.";
@@ -470,15 +474,15 @@ public final class ConfigNodeMessages {
"The time_partition_interval should be positive";
public static final String THE_TIME_PARTITION_ORIGIN_SHOULD_BE_NON_NEGATIVE =
"The time_partition_origin should be non-negative";
- public static final String TRY_LISTEN_TO_PLAN_FAILED = "Try listen to plan
failed";
+ public static final String TRY_LISTEN_TO_PLAN_FAILED = "[ConfigRegion
Update] Try listen to plan failed";
public static final String UNDEFINED_TEMPLATE = "Undefined template {}";
public static final String
UNEXPECTED_INTERRUPTION_DURING_THE_CLOSE_METHOD_OF_LOGWRITER =
- "Unexpected interruption during the close method of logWriter";
+ "[ConfigRegion Update] Unexpected interruption during the close method
of logWriter";
public static final String
UNEXPECTED_INTERRUPTION_DURING_WAITING_FOR_LEADER_ELECTION =
"Unexpected interruption during waiting for leader election.";
- public static final String UNEXPECTED_READ_PLAN = "Unexpected read plan :
{}";
+ public static final String UNEXPECTED_READ_PLAN = "[ConfigRegion Update]
Unexpected read plan : {}";
public static final String UNEXPECTED_WRITE_PLAN_REQUEST_BYTEBUFFER =
- "Unexpected write plan, request: {}, bytebuffer: {}";
+ "[ConfigRegion Update] Unexpected write plan, request: {}, bytebuffer:
{}";
public static final String UNKNOWN_FAILURE_DETECTOR = "Unknown
failure_detector: %s, please set to \"fixed\" or \"phi_accrual\"";
public static final String UNKNOWN_HOST_WHEN_CHECKING_SEED_CONFIGNODE_IP =
"Unknown host when checking seed configNode IP {}";
@@ -621,10 +625,6 @@ public final class ConfigNodeMessages {
public static final String
LOG_NO_NEED_REMOVE_IT_NODE_ARG_REGION_ARG_D14062CE = "no need to remove it,
node: {}, region: {}";
public static final String
LOG_PID_ARG_FAILED_WRITE_UPDATE_API_EXECUTING_CONSENSUS_LAYER_824FB30E =
"pid={} Failed in the write update API executing the consensus layer due to: ";
public static final String
LOG_PID_ARG_FAILED_WRITE_DELETE_API_EXECUTING_CONSENSUS_LAYER_0E758BF5 =
"pid={} Failed in the write delete API executing the consensus layer due to: ";
- public static final String LOG_NEW_LEADER_NODEID_ARG_0A63760B = "the new
leader is [nodeId:{}]";
- public static final String LOG_START_CLEANING_UP_RELATED_SERVICES_A409E261 =
"start cleaning up related services";
- public static final String
LOG_ALL_SERVICES_OLD_LEADER_UNAVAILABLE_NOW_8A22E60F = "all services on old
leader are unavailable now.";
- public static final String LOG_FILEPATH_ARG_RETRY_ARG_16284354 = "filePath:
{}, retry: {}";
public static final String EXCEPTION_COLON_5D70AD09 = ":";
public static final String MESSAGE_COLON_CEFF3F4D = ": ";
public static final String EMPTY_MESSAGE = "";
@@ -633,16 +633,16 @@ public final class ConfigNodeMessages {
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FAILED_TO_START_LEADER_SERVICE_ARG_THE_1754011A
=
"Current ConfigNode(nodeId: {}, ip: {}) failed to start leader service
[{}], the";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FAILED_TO_START_LEADER_SERVICE_ARG_THE_NODE_WILL_STILL_FINISH_WARMING_UP_THIS_SERVICE_STAYS_UNAVAILABLE_UNTIL_THE_NEXT_LEADERSHIP_TRANSITION_E89A98E7
=
- "Current ConfigNode(nodeId: {}, ip: {}) failed to start leader service
[{}], the node will "
+ "[ConfigRegion Update] Current ConfigNode(nodeId: {}, ip: {}) failed to
start leader service [{}], the node will "
+ "still finish warming up; this service stays unavailable until the
next leadership "
+ "transition.";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FINISHED_STARTING_LEADER_SERVICES_WHILE_LOAD_0C57A408
=
"Current ConfigNode(nodeId: {}, ip: {}) finished starting leader
services while load";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FINISHED_STARTING_LEADER_SERVICES_WHILE_LOAD_WARM_UP_IS_STILL_IN_PROGRESS_ARG_17C09A31
=
- "Current ConfigNode(nodeId: {}, ip: {}) finished starting leader
services while load warm-up "
+ "[ConfigRegion Update] Current ConfigNode(nodeId: {}, ip: {}) finished
starting leader services while load warm-up "
+ "is still in progress: {}";
public static final String
MESSAGE_UNEXPECTED_INTERRUPTION_WHILE_WAITING_FOR_CONFIGNODE_LEADER_LOAD_WARM_UP_BB5AA4F7
=
- "Unexpected interruption while waiting for ConfigNode leader load
warm-up.";
+ "[ConfigRegion Update] Unexpected interruption while waiting for
ConfigNode leader load warm-up.";
public static final String
EXCEPTION_PROCEDURE_FILE_ARG_EXCEEDS_THE_LOAD_BUFFER_LIMIT_ARG_ACTUAL_SIZE_ARG_62375B4C
=
"Procedure file %s exceeds the load buffer limit %s, actual size %s";
public static final String
MESSAGE_CONFIGNODE_LEADER_IS_WARMING_UP_BEFORE_SERVING_THE_REGISTERING_CONFIGNODE_WILL_WAIT_2E051639
=
diff --git
a/iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
b/iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
index 20787786a74..9f21686d880 100644
---
a/iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
+++
b/iotdb-core/confignode/src/main/i18n/zh/org/apache/iotdb/confignode/i18n/ConfigNodeMessages.java
@@ -21,6 +21,15 @@ package org.apache.iotdb.confignode.i18n;
public final class ConfigNodeMessages {
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_A_CONFIGREGION_FOLLOWER_NEW_LEADER_NODEID_ARG_STOPPING_LEADER_SERVICES_A1962CD2
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}] 为
ConfigRegion follower；新 leader 的 nodeId: {}。开始停止 leader 服务。";
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_NO_LONGER_THE_CONFIGREGION_LEADER_STOPPING_LEADER_SERVICES_5DB0DA66
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
不再是 ConfigRegion leader；开始停止 leader 服务。";
+ public static final String
LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_COMPLETED_STOPPING_LEADER_SERVICES_62381EE1
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
已完成停止 leader 服务。";
+ public static final String
LOG_CONFIGREGION_UPDATE_FAILED_TO_CLOSE_THE_CONFIGNODE_SIMPLECONSENSUS_LOG_FILEPATH_ARG_RETRY_ARG_188A702E
=
+ "[ConfigRegion Update] 关闭 ConfigNode SimpleConsensus 日志失败，filePath:
{}，重试: {}。";
+
public static final String ACQUIRE_TRIGGERTABLELOCK = "获取 TriggerTableLock";
public static final String ACQUIRE_UDFTABLELOCK = "获取 UDFTableLock";
public static final String ACTIVATING = "正在激活 {}...";
@@ -37,19 +46,17 @@ public final class ConfigNodeMessages {
public static final String
CANNOT_FIND_REGIONGROUP_FOR_REGION_WHEN_REMOVEREGIONOLDLOCATION_IN =
"在 {} 中执行 removeRegionOldLocation 时，找不到 region {} 对应的 RegionGroup";
public static final String CAN_ONLY_ALTER_DATATYPE_OF_FIELD_COLUMNS = "只能修改
FIELD 列的数据类型";
- public static final String
CAN_T_CLOSE_STANDALONELOG_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "无法为 ConfigNode SimpleConsensus 模式关闭 StandAloneLog，";
public static final String CAN_T_CONNECT_TO_DATA_NODE = "无法连接到 DataNode：{}";
public static final String CAN_T_CONSTRUCT_CLUSTERSCHEMAINFO = "无法构建
ClusterSchemaInfo";
public static final String CAN_T_DELETE_TEMPORARY_SNAPSHOT_FILE_RETRYING =
"无法删除临时快照文件：{}，正在重试...";
public static final String
CAN_T_FORCE_LOGWRITER_FOR_CONFIGNODE_FLUSHWALFORSIMPLECONSENSUS =
- "无法为 ConfigNode flushWALForSimpleConsensus 强制写入 logWriter";
+ "[ConfigRegion Update] 无法为 ConfigNode flushWALForSimpleConsensus 强制写入
logWriter";
public static final String
CAN_T_FORCE_LOGWRITER_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "无法为 ConfigNode SimpleConsensus 模式强制写入 logWriter";
+ "[ConfigRegion Update] 无法为 ConfigNode SimpleConsensus 模式强制写入 logWriter";
public static final String
CAN_T_SERIALIZE_CURRENT_CONFIGPHYSICALPLAN_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE =
- "无法为 ConfigNode SimpleConsensus 模式序列化当前 ConfigPhysicalPlan";
+ "[ConfigRegion Update] 无法为 ConfigNode SimpleConsensus 模式序列化当前
ConfigPhysicalPlan";
public static final String CAN_T_START_CONFIGNODE_CONSENSUS_GROUP = "无法启动
ConfigNode 共识组！";
public static final String CHANGE_REGIONS_LEADER_ERROR_ON_DATE_NODE =
"在 DataNode: {} 上切换 region leader 失败";
@@ -89,12 +96,12 @@ public final class ConfigNodeMessages {
public static final String
CONFIGNODE_RPC_SERVICE_START_TO_REMOVE_DATANODE_REQ =
"ConfigNode RPC Service 开始移除 DataNode，请求：{}";
public static final String
CONFIGNODE_SIMPLECONSENSUSFILE_HAS_EXISTED_FILEPATH =
- "ConfigNode SimpleConsensusFile 已存在，filePath:{}";
+ "[ConfigRegion Update] ConfigNode SimpleConsensusFile 已存在，filePath:{}";
public static final String
CONFIG_REGION_LISTENING_QUEUE_LISTEN_TO_SNAPSHOT_FAILED_THE_HISTORICAL =
- "Config Region Listening Queue 监听快照失败，历史数据可能未被传输。";
+ "[ConfigRegion Update] Config Region Listening Queue
监听快照失败，历史数据可能未被传输。";
public static final String
CONFIG_REGION_LISTENING_QUEUE_LISTEN_TO_SNAPSHOT_FAILED_WHEN_STARTUP =
- "Config Region Listening Queue 启动时监听快照失败，将在启动 schema 传输 pipe 时再次尝试";
+ "[ConfigRegion Update] Config Region Listening Queue 启动时监听快照失败，将在启动
schema 传输 pipe 时再次尝试";
public static final String
CONTINUOUS_QUERY_MIN_EVERY_INTERVAL_IN_MS_SHOULD_BE_GREATER =
"continuous_query_min_every_interval_in_ms 应大于 0，但当前值为 {}，忽略并使用默认值 {}";
public static final String
CONTINUOUS_QUERY_SUBMIT_THREAD_SHOULD_BE_GREATER_THAN_0 =
@@ -107,18 +114,15 @@ public final class ConfigNodeMessages {
CREATEREGIONGROUPS_DATABASE_HAS_BEEN_DELETED_CORRESPONDING_REGIONGROUPS =
"[CreateRegionGroups] Database {} 已被删除，不会创建对应的 RegionGroup。";
public static final String CREATE_CONFIGNODE_SIMPLECONSENSUSFILE =
- "创建 ConfigNode SimpleConsensusFile: {}";
+ "[ConfigRegion Update] 创建 ConfigNode SimpleConsensusFile: {}";
public static final String
CREATE_CONFIGNODE_SIMPLECONSENSUSFILE_FAILED_FILEPATH =
- "创建 ConfigNode SimpleConsensusFile 失败，filePath: {}";
+ "[ConfigRegion Update] 创建 ConfigNode SimpleConsensusFile 失败，filePath:
{}";
public static final String
CURRENT_NODE_NODEID_IP_PORT_AS_CONFIG_REGION_LEADER_IS =
- "当前节点 [nodeId: {}, ip:port: {}] 作为 config region leader 已就绪";
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}]
已完成 leader 服务启动流程。";
public static final String
CURRENT_NODE_NODEID_IP_PORT_BECOMES_CONFIG_REGION_LEADER =
- "当前节点 [nodeId: {}, ip:port: {}] 成为 config region leader";
- public static final String
CURRENT_NODE_NODEID_IP_PORT_IS_NO_LONGER_THE_LEADER =
- "当前节点 [nodeId:{}, ip:port: {}] 已不再是 leader，";
- public static final String
-
MESSAGE_CURRENT_NODE_NODEID_ARG_IP_PORT_ARG_IS_NO_LONGER_THE_LEADER_SKIP_STARTING_LEADER_SERVICES_BECAUSE_THE_LEADER_EPOCH_IS_STALE_CCF39435
=
- "当前节点 [nodeId:{}，ip:port: {}] 已不再是 leader，跳过 leader 服务启动，因为 leader
epoch 已过期";
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}] 成为
ConfigRegion leader；开始启动 leader 服务。";
+ public static final String
MESSAGE_CURRENT_NODE_NODEID_ARG_IP_PORT_ARG_IS_NO_LONGER_THE_LEADER_SKIP_STARTING_LEADER_SERVICES_BECAUSE_THE_LEADER_EPOCH_IS_STALE_CCF39435
=
+ "[ConfigRegion Update] ConfigNode [nodeId: {}, consensusEndpoint: {}] 的
leadership epoch 已过期，跳过 leader 服务启动。";
public static final String
DATABASE_INCONSISTENCY_DETECTED_WHEN_ADJUSTING_MAX_REGION_GROUP_COUNT_MESSAGE =
"调整最大 region group 数量时检测到数据库不一致，消息：{}，将通过以下调整计划进行修正";
@@ -130,7 +134,7 @@ public final class ConfigNodeMessages {
public static final String DELETED_FAILED_TAKE_APPROPRIATE_ACTION = "{}
删除失败，请采取相应处理。";
public static final String DELETE_USELESS_PROCEDURE_WAL_DIR_FAIL = "删除无用的
procedure WAL 目录失败。";
public static final String
DESERIALIZATION_ERROR_FOR_WRITE_PLAN_REQUEST_BYTEBUFFER =
- "反序列化写入计划出错，请求：{}，bytebuffer: {}";
+ "[ConfigRegion Update] 反序列化写入计划出错，请求：{}，bytebuffer: {}";
public static final String DOES_NOT_EXIST = "%s 不存在";
public static final String DROPPING_TAG_OR_TIME_COLUMN_IS_NOT_SUPPORTED =
"不支持删除标签列或时间列。";
public static final String DROP_CQ_FAILED_BECAUSE_ITS_TOKEN_DOESN_T_MATCH =
@@ -149,8 +153,8 @@ public final class ConfigNodeMessages {
public static final String EXECUTE_GETCLUSTERID_WITH_RESULT = "执行
getClusterId，结果 {}";
public static final String EXECUTE_GETSYSTEMCONFIGURATION_WITH_RESULT =
"执行 GetSystemConfiguration，结果 {}";
- public static final String EXECUTE_NON_QUERY_PLAN_FAILED = "执行非查询计划失败";
- public static final String EXECUTE_QUERY_PLAN_FAILED = "执行查询计划失败";
+ public static final String EXECUTE_NON_QUERY_PLAN_FAILED = "[ConfigRegion
Update] 执行非查询计划失败";
+ public static final String EXECUTE_QUERY_PLAN_FAILED = "[ConfigRegion
Update] 执行查询计划失败";
public static final String EXECUTE_REGISTERAINODEREQUEST_WITH_RESULT =
"执行 RegisterAINodeRequest {}，结果 {}";
public static final String EXECUTE_REGISTERCONFIGNODEREQUEST_WITH_RESULT =
@@ -286,7 +290,7 @@ public final class ConfigNodeMessages {
public static final String ID_TOOK_SNAPSHOT_FAIL = "{} id {} 创建快照失败";
public static final String
INITSTANDALONECONFIGNODE_MEETS_ERROR_CAN_T_FIND_STANDALONE_LOG_FILES_FILEPATH =
- "InitStandAloneConfigNode 出错，找不到 standalone log 文件，filePath: {}";
+ "[ConfigRegion Update] InitStandAloneConfigNode 出错，找不到 standalone
log 文件，filePath: {}";
public static final String INVALID_AUTHOR_TYPE_ORDINAL = "无效的 Author 类型序号";
public static final String IOTDB_STARTED = "IoTDB 已启动";
public static final String IS_DEACTIVATED = "{} 已停用。";
@@ -435,15 +439,15 @@ public final class ConfigNodeMessages {
"time_partition_interval 应为正数";
public static final String THE_TIME_PARTITION_ORIGIN_SHOULD_BE_NON_NEGATIVE =
"time_partition_origin 应为非负数";
- public static final String TRY_LISTEN_TO_PLAN_FAILED = "尝试监听计划失败";
+ public static final String TRY_LISTEN_TO_PLAN_FAILED = "[ConfigRegion
Update] 尝试监听计划失败";
public static final String UNDEFINED_TEMPLATE = "未定义的模板 {}";
public static final String
UNEXPECTED_INTERRUPTION_DURING_THE_CLOSE_METHOD_OF_LOGWRITER =
- "关闭 logWriter 过程中发生意外中断";
+ "[ConfigRegion Update] 关闭 logWriter 过程中发生意外中断";
public static final String
UNEXPECTED_INTERRUPTION_DURING_WAITING_FOR_LEADER_ELECTION =
"等待 leader 选举过程中发生意外中断。";
- public static final String UNEXPECTED_READ_PLAN = "意外的读取计划：{}";
+ public static final String UNEXPECTED_READ_PLAN = "[ConfigRegion Update]
意外的读取计划：{}";
public static final String UNEXPECTED_WRITE_PLAN_REQUEST_BYTEBUFFER =
- "意外的写入计划，请求：{}，bytebuffer: {}";
+ "[ConfigRegion Update] 意外的写入计划，请求：{}，bytebuffer: {}";
public static final String UNKNOWN_FAILURE_DETECTOR =
"未知 failure_detector：%s，请设置为 \"fixed\" 或 \"phi_accrual\"";
public static final String UNKNOWN_HOST_WHEN_CHECKING_SEED_CONFIGNODE_IP =
@@ -654,11 +658,6 @@ public final class ConfigNodeMessages {
public static final String
LOG_PID_ARG_FAILED_WRITE_DELETE_API_EXECUTING_CONSENSUS_LAYER_0E758BF5 =
"pid={} 执行共识层写入删除 API 失败，原因：";
- public static final String LOG_NEW_LEADER_NODEID_ARG_0A63760B = "新的 leader 为
[nodeId:{}]";
- public static final String LOG_START_CLEANING_UP_RELATED_SERVICES_A409E261 =
"开始清理相关服务";
- public static final String
LOG_ALL_SERVICES_OLD_LEADER_UNAVAILABLE_NOW_8A22E60F =
- "旧 leader 上的所有服务现在均不可用。";
- public static final String LOG_FILEPATH_ARG_RETRY_ARG_16284354 =
"filePath：{}，重试：{}";
public static final String EXCEPTION_COLON_5D70AD09 = ":";
public static final String MESSAGE_COLON_CEFF3F4D = ": ";
public static final String EMPTY_MESSAGE = "";
@@ -669,16 +668,16 @@ public final class ConfigNodeMessages {
"当前 ConfigNode(nodeId: {}, ip: {}) 启动 leader 服务 [{}] 失败，该";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FAILED_TO_START_LEADER_SERVICE_ARG_THE_NODE_WILL_STILL_FINISH_WARMING_UP_THIS_SERVICE_STAYS_UNAVAILABLE_UNTIL_THE_NEXT_LEADERSHIP_TRANSITION_E89A98E7
=
- "当前 ConfigNode(nodeId: {}, ip: {}) 启动 leader 服务 [{}]
失败，该节点仍会完成预热；在下次 leader 切换前，该服务保持不可用。";
+ "[ConfigRegion Update] 当前 ConfigNode(nodeId: {}, ip: {}) 启动 leader
服务 [{}] 失败，该节点仍会完成预热；在下次 leader 切换前，该服务保持不可用。";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FINISHED_STARTING_LEADER_SERVICES_WHILE_LOAD_0C57A408
=
"当前 ConfigNode(nodeId: {}, ip: {}) 已完成 leader 服务启动，但 load";
public static final String
MESSAGE_CURRENT_CONFIGNODE_NODEID_ARG_IP_ARG_FINISHED_STARTING_LEADER_SERVICES_WHILE_LOAD_WARM_UP_IS_STILL_IN_PROGRESS_ARG_17C09A31
=
- "当前 ConfigNode(nodeId: {}, ip: {}) 已完成 leader 服务启动，但 load
预热仍在进行中：{}";
+ "[ConfigRegion Update] 当前 ConfigNode(nodeId: {}, ip: {}) 已完成 leader
服务启动，但 load 预热仍在进行中：{}";
public static final String
MESSAGE_UNEXPECTED_INTERRUPTION_WHILE_WAITING_FOR_CONFIGNODE_LEADER_LOAD_WARM_UP_BB5AA4F7
=
- "等待 ConfigNode leader load 预热时遭到意外中断。";
+ "[ConfigRegion Update] 等待 ConfigNode leader load 预热时遭到意外中断。";
public static final String
EXCEPTION_PROCEDURE_FILE_ARG_EXCEEDS_THE_LOAD_BUFFER_LIMIT_ARG_ACTUAL_SIZE_ARG_62375B4C
=
"Procedure 文件 %s 超过了加载缓冲区限制 %s，实际大小为 %s";
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachine.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachine.java
index f44d353a65f..6b4da5445d3 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachine.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/statemachine/ConfigRegionStateMachine.java
@@ -277,8 +277,8 @@ public class ConfigRegionStateMachine implements
IStateMachine, IStateMachine.Ev
final int currentNodeId =
ConfigNodeDescriptor.getInstance().getConf().getConfigNodeId();
if (currentNodeId != newLeaderId) {
LOGGER.info(
-
ConfigNodeMessages.CURRENT_NODE_NODEID_IP_PORT_IS_NO_LONGER_THE_LEADER
- + ConfigNodeMessages.LOG_NEW_LEADER_NODEID_ARG_0A63760B,
+ ConfigNodeMessages
+
.LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_A_CONFIGREGION_FOLLOWER_NEW_LEADER_NODEID_ARG_STOPPING_LEADER_SERVICES_A1962CD2,
currentNodeId,
currentNodeTEndPoint,
newLeaderId);
@@ -292,8 +292,8 @@ public class ConfigRegionStateMachine implements
IStateMachine, IStateMachine.Ev
// couldn't initialize earlier than the ConfigRegionStateMachine
final int currentNodeId =
ConfigNodeDescriptor.getInstance().getConf().getConfigNodeId();
LOGGER.info(
- ConfigNodeMessages.CURRENT_NODE_NODEID_IP_PORT_IS_NO_LONGER_THE_LEADER
- +
ConfigNodeMessages.LOG_START_CLEANING_UP_RELATED_SERVICES_A409E261,
+ ConfigNodeMessages
+
.LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_IS_NO_LONGER_THE_CONFIGREGION_LEADER_STOPPING_LEADER_SERVICES_5DB0DA66,
currentNodeId,
currentNodeTEndPoint);
resignLeaderAsync();
@@ -449,8 +449,8 @@ public class ConfigRegionStateMachine implements
IStateMachine, IStateMachine.Ev
PipeConfigNodeAgent.receiver().cleanPipeReceiverDir();
LOGGER.info(
- ConfigNodeMessages.CURRENT_NODE_NODEID_IP_PORT_IS_NO_LONGER_THE_LEADER
- +
ConfigNodeMessages.LOG_ALL_SERVICES_OLD_LEADER_UNAVAILABLE_NOW_8A22E60F,
+ ConfigNodeMessages
+
.LOG_CONFIGREGION_UPDATE_CONFIGNODE_NODEID_ARG_CONSENSUSENDPOINT_ARG_COMPLETED_STOPPING_LEADER_SERVICES_62381EE1,
currentNodeId,
currentNodeTEndPoint);
}
@@ -595,8 +595,8 @@ public class ConfigRegionStateMachine implements
IStateMachine, IStateMachine.Ev
simpleLogWriter.close();
} catch (IOException e) {
LOGGER.warn(
-
ConfigNodeMessages.CAN_T_CLOSE_STANDALONELOG_FOR_CONFIGNODE_SIMPLECONSENSUS_MODE
- + ConfigNodeMessages.LOG_FILEPATH_ARG_RETRY_ARG_16284354,
+ ConfigNodeMessages
+
.LOG_CONFIGREGION_UPDATE_FAILED_TO_CLOSE_THE_CONFIGNODE_SIMPLECONSENSUS_LOG_FILEPATH_ARG_RETRY_ARG_188A702E,
simpleLogFile.getAbsolutePath(),
retry);
try {
