You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/07/31 09:03:18 UTC
(iotdb) 01/02: Prevent NPE
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 <ro...@apache.org>
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()