From 85f2a7d9339c1a6e6bfa90e5ed94e3fcb05d9bee Mon Sep 17 00:00:00 2001
From: VGalaxies <vgalaxies@apache.org>
Date: Thu, 26 Sep 2024 23:06:29 +0800
Subject: [PATCH] minor improve

---
 .../event/pipe/SubscriptionPipeTsFilePlainEvent.java            | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTsFilePlainEvent.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTsFilePlainEvent.java
index 09707a24fbfd..1153bd65ace6 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/event/pipe/SubscriptionPipeTsFilePlainEvent.java
+++ b/iotdb-core/datanode/src/main/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;
   }
 }