[HUDI-2678] flink writer writes huge log file (#3916)

2021-11-03 22:12:49 +08:00
parent acc40625f5
commit 8932c4f7b5
1 changed files with 0 additions and 5 deletions
--- 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 {