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();
}
}