Subscription: fix drop subscription from session under table model (#15725)

VGalaxies · web-flow · commit 726d09353206 · 2025-06-17T12:03:56.000+08:00
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/subscription/SubscriptionCoordinator.java
@@ -267,7 +267,8 @@ public TSStatus dropSubscription(TDropSubscriptionReq req) {
             new TUnsubscribeReq()
                 .setConsumerId(null)
                 .setConsumerGroupId(topicNameWithConsumerGroupName.get().right)
-                .setTopicNames(Collections.singleton(topicNameWithConsumerGroupName.get().left)));
+                .setTopicNames(Collections.singleton(topicNameWithConsumerGroupName.get().left))
+                .setIsTableModel(req.isTableModel));
   }
 
   public TShowSubscriptionResp showSubscription(TShowSubscriptionReq req) {

Original file line number	Diff line number	Diff line change
`@@ -267,7 +267,8 @@ public TSStatus dropSubscription(TDropSubscriptionReq req) {`
`267`	`267`	`new TUnsubscribeReq()`
`268`	`268`	`.setConsumerId(null)`
`269`	`269`	`.setConsumerGroupId(topicNameWithConsumerGroupName.get().right)`
`270`		`- .setTopicNames(Collections.singleton(topicNameWithConsumerGroupName.get().left)));`
	`270`	`+ .setTopicNames(Collections.singleton(topicNameWithConsumerGroupName.get().left))`
	`271`	`+ .setIsTableModel(req.isTableModel));`
`271`	`272`	`}`
`272`	`273`
`273`	`274`	`public TShowSubscriptionResp showSubscription(TShowSubscriptionReq req) {`