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

[rong]

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

rong pushed a commit to branch rc/1.3.3
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/rc/1.3.3 by this push:
     new ed9a4234c87 [ISSUE-13155] When having more than one pipeline 
subscription and restarting the server, the second subscription ends in a loop 
of doom (#13156) (#13160)
ed9a4234c87 is described below

commit ed9a4234c873c650e57fca9f4580d68b4ef7789e
Author: Steve Yurong Su <r...@apache.org>
AuthorDate: Wed Aug 14 11:13:36 2024 +0800

    [ISSUE-13155] When having more than one pipeline subscription and 
restarting the server, the second subscription ends in a loop of doom (#13156) 
(#13160)
    
    (cherry picked from commit bc85409c6cf9b8701f869eac35c2903b469f10e1)
    
    Co-authored-by: Christofer Dutz <cd...@apache.org>
---
 .../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(