(iotdb) branch master updated: [ISSUE-13155] When having more than one pipeline subscription and restarting the server, the second subscription ends in a loop of doom (#13156)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong 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 bc85409c6cf [ISSUE-13155] When having more than one pipeline 
subscription and restarting the server, the second subscription ends in a loop 
of doom (#13156)
bc85409c6cf is described below

commit bc85409c6cf9b8701f869eac35c2903b469f10e1
Author: Christofer Dutz <cd...@apache.org>
AuthorDate: Wed Aug 14 04:00:28 2024 +0200

    [ISSUE-13155] When having more than one pipeline subscription and 
restarting the server, the second subscription ends in a loop of doom (#13156)
---
 .../apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java    | 1 -
 1 file changed, 1 deletion(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
index 075098f8f93..0105700d3c8 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/agent/SubscriptionConsumerAgent.java
@@ -138,7 +138,6 @@ public class SubscriptionConsumerAgent {
           consumerGroupMetasFromCoordinator) {
         try {
           
handleSingleConsumerGroupMetaChangesInternal(consumerGroupMetaFromCoordinator);
-          return null;
         } catch (final Exception e) {
           final String consumerGroupId = 
consumerGroupMetaFromCoordinator.getConsumerGroupId();
           LOGGER.warn(