(iotdb) branch rc/1.3.3 updated: Subscription: always return negative TabletsPayload resp for tablets streaming transmission (#13339) (#13343)

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

commit fb237e3969f5590347f2f252ec532f2e686614f2
Author: V_Galaxy <vgalax...@apache.org>
AuthorDate: Thu Aug 29 19:27:37 2024 +0800

    Subscription: always return negative TabletsPayload resp for tablets 
streaming transmission (#13339) (#13343)
---
 .../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));
   }