From 8932c4f7b57ef5290f48f35c9a8362bd28b0ca42 Mon Sep 17 00:00:00 2001
From: Danny Chan <yuzhao.cyz@gmail.com>
Date: Wed, 3 Nov 2021 22:12:49 +0800
Subject: [PATCH] [HUDI-2678] flink writer writes huge log file (#3916)

---
 .../src/main/java/org/apache/hudi/io/FlinkAppendHandle.java  | 5 -----
 1 file changed, 5 deletions(-)

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 {