diff --git a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java
index 9cb633700..1872637ae 100644
--- a/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java
+++ b/hudi-client/hudi-flink-client/src/main/java/org/apache/hudi/io/FlinkAppendHandle.java
@@ -88,11 +88,6 @@ public class FlinkAppendHandle<T extends HoodieRecordPayload, I, K, O>
         && hoodieRecord.getCurrentLocation().getInstantTime().equals("U");
   }
 
-  @Override
-  public boolean canWrite(HoodieRecord record) {
-    return true;
-  }
-
   @Override
   public List<WriteStatus> close() {
     try {