(iotdb) branch hook updated: revert

[justinchen]

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

justinchen pushed a commit to branch hook
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/hook by this push:
     new 63f67002c29 revert
63f67002c29 is described below

commit 63f67002c292f7a6c8f62a70f086cfacbd628409
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Wed Mar 25 19:36:10 2026 +0800

    revert
---
 .../common/tablet/PipeRawTabletInsertionEvent.java | 25 ++++++++++++----------
 1 file changed, 14 insertions(+), 11 deletions(-)

diff --git 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
index a857c967db0..c4f900b7d5f 100644
--- 
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
+++ 
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeRawTabletInsertionEvent.java
@@ -116,18 +116,14 @@ public class PipeRawTabletInsertionEvent extends 
PipeInsertionEvent
     this.allocatedMemoryBlock =
         
PipeDataNodeResourceManager.memory().forceAllocateForTabletWithRetry(0);
 
-    triggerAddHook();
+    addOnCommittedHook(
+        () -> {
+          if (shouldReportOnCommit) {
+            eliminateProgressIndex();
+          }
+        });
   }
 
-  private void triggerAddHook() {
-    if (shouldReportOnCommit && needToReport && sourceEvent instanceof 
PipeTsFileInsertionEvent) {
-      final PipeTsFileInsertionEvent event = ((PipeTsFileInsertionEvent) 
sourceEvent);
-      addOnCommittedHook(event::eliminateProgressIndex);
-    }
-  }
-
-
-
   public PipeRawTabletInsertionEvent(
       final Boolean isTableModelEvent,
       final String databaseName,
@@ -306,6 +302,14 @@ public class PipeRawTabletInsertionEvent extends 
PipeInsertionEvent
     return true;
   }
 
+  protected void eliminateProgressIndex() {
+    if (needToReport) {
+      if (sourceEvent instanceof PipeTsFileInsertionEvent) {
+        ((PipeTsFileInsertionEvent) sourceEvent).eliminateProgressIndex();
+      }
+    }
+  }
+
   @Override
   public void bindProgressIndex(final ProgressIndex overridingProgressIndex) {
     // Normally not all events need to report progress, but if the 
overridingProgressIndex
@@ -384,7 +388,6 @@ public class PipeRawTabletInsertionEvent extends 
PipeInsertionEvent
 
   public void markAsNeedToReport() {
     this.needToReport = true;
-    triggerAddHook();
   }
 
   // This getter is reserved for user-defined plugins