fix

Author: Caideyipi

iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionConsumer.java

@@ -1401,7 +1401,8 @@ Map<Integer, TEndPoint> fetchAllEndPointsWithRedirection() throws SubscriptionEx
     if (providers.isEmpty()) {
       throw new SubscriptionConnectionException(
           String.format(
-              "Cluster has no available subscription providers when %s fetches all endpoints", this));
+              "Cluster has no available subscription providers when %s fetches all endpoints",
+              this));
     }
     for (final AbstractSubscriptionProvider provider : providers) {
       try {

iotdb-client/subscription/src/main/java/org/apache/iotdb/session/subscription/consumer/base/AbstractSubscriptionProviders.java

@@ -97,7 +97,8 @@ void openProviders(final AbstractSubscriptionConsumer consumer) throws Subscript
       try {
         allEndPoints = defaultProvider.heartbeat().getEndPoints();
       } catch (final Exception e) {
-        LOGGER.warn("{} failed to fetch all endpoints from {} because {}", consumer, endPoint, e, e);
+        LOGGER.warn(
+            "{} failed to fetch all endpoints from {} because {}", consumer, endPoint, e, e);
         break;
       }
 

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/SubscriptionBroker.java

@@ -187,10 +187,10 @@ private Set<String> prepareCandidateTopicNames(
       // If there is no prefetching queue for the topic, check if it's completed
       if (Objects.isNull(prefetchingQueue)) {
         if (completedTopicNames.containsKey(topicName)) {
-              LOGGER.info(
-                  "Subscription: prefetching queue bound to topic [{}] for consumer group [{}] is completed, returning termination response to client",
-                  topicName,
-                  brokerId);
+          LOGGER.info(
+              "Subscription: prefetching queue bound to topic [{}] for consumer group [{}] is completed, returning termination response to client",
+              topicName,
+              brokerId);
           // Add a termination event for the completed topic
           eventsToPoll.add(
               new SubscriptionEvent(

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/receiver/SubscriptionReceiverV1.java

@@ -240,8 +240,7 @@ private TPipeSubscribeResp handlePipeSubscribeHandshake(final PipeSubscribeHands
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_HANDSHAKING, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling handshake request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling handshake request %s: %s", req, e);
       return PipeSubscribeHandshakeResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_HANDSHAKE_ERROR, exceptionMessage),
           -1,
@@ -308,8 +307,7 @@ private TPipeSubscribeResp handlePipeSubscribeHeartbeat(final PipeSubscribeHeart
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_HEARTBEAT, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling heartbeat request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling heartbeat request %s: %s", req, e);
       return PipeSubscribeHeartbeatResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_HEARTBEAT_ERROR, exceptionMessage));
     }
@@ -384,8 +382,7 @@ private TPipeSubscribeResp handlePipeSubscribeSubscribe(final PipeSubscribeSubsc
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_SUBSCRIBING, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling subscribe request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling subscribe request %s: %s", req, e);
       return PipeSubscribeSubscribeResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_SUBSCRIBE_ERROR, exceptionMessage));
     }
@@ -466,8 +463,7 @@ private TPipeSubscribeResp handlePipeSubscribePoll(final PipeSubscribePollReq re
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_POLLING, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling poll request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling poll request %s: %s", req, e);
       return PipeSubscribePollResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_POLL_ERROR, exceptionMessage),
           Collections.emptyList());
@@ -645,8 +641,7 @@ private TPipeSubscribeResp handlePipeSubscribeCommit(final PipeSubscribeCommitRe
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_COMMITTING, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling commit request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling commit request %s: %s", req, e);
       return PipeSubscribeCommitResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_COMMIT_ERROR, exceptionMessage));
     }
@@ -692,8 +687,7 @@ private TPipeSubscribeResp handlePipeSubscribeClose(final PipeSubscribeCloseReq
       LOGGER.warn(DataNodeMiscMessages.SUBSCRIPTION_EXCEPTION_CLOSING, req, e);
       final String exceptionMessage =
           String.format(
-              "Subscription: unexpected exception while handling close request %s: %s",
-              req, e);
+              "Subscription: unexpected exception while handling close request %s: %s", req, e);
       return PipeSubscribeCloseResp.toTPipeSubscribeResp(
           RpcUtils.getStatus(TSStatusCode.SUBSCRIPTION_CLOSE_ERROR, exceptionMessage));
     }