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 9cb6337003cea..1872637aeefde 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 @@ protected boolean isUpdateRecord(HoodieRecord<T> hoodieRecord) {
         && hoodieRecord.getCurrentLocation().getInstantTime().equals("U");
   }
 
-  @Override
-  public boolean canWrite(HoodieRecord record) {
-    return true;
-  }
-
   @Override
   public List<WriteStatus> close() {
     try {