This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch rc-1.3.3-13155 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 3af2bc9809ad34d758b9a03fa082dbcc2b2f20db Author: Christofer Dutz <[email protected]> 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) (cherry picked from commit bc85409c6cf9b8701f869eac35c2903b469f10e1) --- .../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(
