From 17d11f4839753553f7a58052a01f94bc653e1a55 Mon Sep 17 00:00:00 2001
From: Bo Cui <cuibo0108@163.com>
Date: Thu, 31 Mar 2022 05:30:06 +0800
Subject: [PATCH] [MINOR] Repeated execution of update status (#5089)

---
 .../org/apache/hudi/sink/partitioner/BucketAssignFunction.java   | 1 -
 1 file changed, 1 deletion(-)

diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
index d01db962c..c4b83bf51 100644
--- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
+++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/sink/partitioner/BucketAssignFunction.java
@@ -188,7 +188,6 @@ public class BucketAssignFunction<K, I, O extends HoodieRecord<?>>
           out.collect((O) deleteRecord);
         }
         location = getNewRecordLocation(partitionPath);
-        updateIndexState(partitionPath, location);
       } else {
         location = oldLoc.toLocal("U");
         this.bucketAssigner.addUpdate(partitionPath, location.getFileId());