minor improve

apache · Sep 26, 2024 · 85f2a7d · 85f2a7d
1 parent a995a80
commit 85f2a7d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...in/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTsFilePlainEvent.java b/...in/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTsFilePlainEvent.java
@@ -60,6 +60,6 @@ public String toString() {
 
   @Override
   public int getPipeEventCount(final boolean forCommitRate) {
-    return 1;
+    return forCommitRate ? (tsFileInsertionEvent.needToCommitRate() ? 1 : 0) : 1;
   }
 }