From 6719d8c1380628dee65b7e349d70eca701b74d9f Mon Sep 17 00:00:00 2001 From: Anukalp Date: Sat, 31 Jan 2026 21:40:58 +0530 Subject: [PATCH] Fix checkstyle line length in subscription exception message --- .../task/subtask/SubscriptionSinkSubtaskManager.java | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionSinkSubtaskManager.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionSinkSubtaskManager.java index 07def3ff4d39..96233ee1dc79 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionSinkSubtaskManager.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/task/subtask/SubscriptionSinkSubtaskManager.java @@ -127,8 +127,10 @@ public synchronized String register( if (Objects.isNull(topicName) || Objects.isNull(consumerGroupId)) { throw new SubscriptionException( String.format( - "Failed to construct subscription sink, because of %s or %s does not exist in pipe connector parameters", - PipeSinkConstant.SINK_TOPIC_KEY, PipeSinkConstant.SINK_CONSUMER_GROUP_KEY)); + "Failed to construct subscription sink, because of %s or %s " + + "does not exist in pipe connector parameters", + PipeSinkConstant.SINK_TOPIC_KEY, + PipeSinkConstant.SINK_CONSUMER_GROUP_KEY)); } // 3. Construct PipeConnectorSubtaskLifeCycle to manage PipeConnectorSubtask's life cycle