This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch show-pipes-npe in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit da67a04fe80cf88a4ed205bce672e91d0d3a6b82 Author: Steve Yurong Su <[email protected]> AuthorDate: Wed Jul 31 16:37:17 2024 +0800 Prevent NPE --- .../impl/subscription/topic/CreateTopicProcedure.java | 14 +++++--------- 1 file changed, 5 insertions(+), 9 deletions(-) diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java index ed3d59bd3d4..ea3eaf9b8aa 100644 --- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java +++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/subscription/topic/CreateTopicProcedure.java @@ -83,8 +83,7 @@ public class CreateTopicProcedure extends AbstractOperateSubscriptionProcedure { @Override protected void executeFromOperateOnConfigNodes(ConfigNodeProcedureEnv env) throws SubscriptionException { - LOGGER.info( - "CreateTopicProcedure: executeFromOperateOnConfigNodes({})", topicMeta.getTopicName()); + LOGGER.info("CreateTopicProcedure: executeFromOperateOnConfigNodes({})", topicMeta); TSStatus response; try { @@ -105,8 +104,7 @@ public class CreateTopicProcedure extends AbstractOperateSubscriptionProcedure { @Override protected void executeFromOperateOnDataNodes(ConfigNodeProcedureEnv env) throws SubscriptionException { - LOGGER.info( - "CreateTopicProcedure: executeFromOperateOnDataNodes({})", topicMeta.getTopicName()); + LOGGER.info("CreateTopicProcedure: executeFromOperateOnDataNodes({})", topicMeta); try { final List<TSStatus> statuses = env.pushSingleTopicOnDataNode(topicMeta.serialize()); @@ -126,13 +124,12 @@ public class CreateTopicProcedure extends AbstractOperateSubscriptionProcedure { @Override protected void rollbackFromValidate(ConfigNodeProcedureEnv env) { - LOGGER.info("CreateTopicProcedure: rollbackFromValidate({})", topicMeta.getTopicName()); + LOGGER.info("CreateTopicProcedure: rollbackFromValidate({})", topicMeta); } @Override protected void rollbackFromOperateOnConfigNodes(ConfigNodeProcedureEnv env) { - LOGGER.info( - "CreateTopicProcedure: rollbackFromCreateOnConfigNodes({})", topicMeta.getTopicName()); + LOGGER.info("CreateTopicProcedure: rollbackFromCreateOnConfigNodes({})", topicMeta); TSStatus response; try { @@ -155,8 +152,7 @@ public class CreateTopicProcedure extends AbstractOperateSubscriptionProcedure { @Override protected void rollbackFromOperateOnDataNodes(ConfigNodeProcedureEnv env) { - LOGGER.info( - "CreateTopicProcedure: rollbackFromCreateOnDataNodes({})", topicMeta.getTopicName()); + LOGGER.info("CreateTopicProcedure: rollbackFromCreateOnDataNodes({})", topicMeta); final List<TSStatus> statuses = env.dropSingleTopicOnDataNode(topicMeta.getTopicName()); if (RpcUtils.squashResponseStatusList(statuses).getCode()
