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

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


The following commit(s) were added to refs/heads/dev/1.3 by this push:
     new fef75dcb1fb Subscription: fix  method in tablet batch to support 
multiple tsfile in the same batch (#14715) (#14716)
fef75dcb1fb is described below

commit fef75dcb1fb316a4c60675a7bf943a8e896d412a
Author: VGalaxies <[email protected]>
AuthorDate: Fri Jan 17 11:22:40 2025 +0800

    Subscription: fix  method in tablet batch to support multiple tsfile in the 
same batch (#14715) (#14716)
---
 .../db/subscription/event/batch/SubscriptionPipeTabletEventBatch.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

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 1031e1e2279..d1d56e6c5a7 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
@@ -216,7 +216,7 @@ public class SubscriptionPipeTabletEventBatch extends 
SubscriptionPipeEventBatch
         // reset
         currentTabletInsertionEventsIterator = null;
         currentTsFileInsertionEvent = null;
-        return false;
+        return hasNext();
       }
     }
 

Reply via email to