(iotdb) branch master updated: Subscription: always return negative TabletsPayload resp for tablets streaming transmission (#13339)

[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 e0c695aa2ad Subscription: always return negative TabletsPayload resp 
for tablets streaming transmission (#13339)
e0c695aa2ad is described below

commit e0c695aa2addc9d86c1187375b2a8571812d195e
Author: V_Galaxy <vgalax...@apache.org>
AuthorDate: Thu Aug 29 17:21:40 2024 +0800

    Subscription: always return negative TabletsPayload resp for tablets 
streaming transmission (#13339)
---
 .../event/batch/SubscriptionPipeTabletEventBatch.java        | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
index 006a2b37837..abd73e03069 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java
@@ -141,13 +141,11 @@ public class SubscriptionPipeTabletEventBatch extends 
SubscriptionPipeEventBatch
       currentTablets.add(tablet);
       currentTotalBufferSize += bufferSize;
     }
-    if (!currentTablets.isEmpty()) {
-      responses.add(
-          new SubscriptionPollResponse(
-              SubscriptionPollResponseType.TABLETS.getType(),
-              new TabletsPayload(new ArrayList<>(currentTablets), 
-tablets.size()),
-              commitContext));
-    }
+    responses.add(
+        new SubscriptionPollResponse(
+            SubscriptionPollResponseType.TABLETS.getType(),
+            new TabletsPayload(new ArrayList<>(currentTablets), 
-tablets.size()),
+            commitContext));
     return Collections.singletonList(
         new SubscriptionEvent(new SubscriptionPipeTabletBatchEvents(this), 
responses));
   }