From ced068e1ee79147dfe959676c953441bf6da5e87 Mon Sep 17 00:00:00 2001 From: wangxianghu Date: Thu, 20 May 2021 10:18:07 +0800 Subject: [PATCH] [MINOR] Remove unused method in BaseSparkCommitActionExecutor (#2965) --- .../action/commit/BaseSparkCommitActionExecutor.java | 8 -------- 1 file changed, 8 deletions(-) diff --git a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java index aa199c2b5..eceac7bd1 100644 --- a/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java +++ b/hudi-client/hudi-spark-client/src/main/java/org/apache/hudi/table/action/commit/BaseSparkCommitActionExecutor.java @@ -21,7 +21,6 @@ package org.apache.hudi.table.action.commit; import org.apache.hudi.client.WriteStatus; import org.apache.hudi.client.utils.SparkMemoryUtils; import org.apache.hudi.common.engine.HoodieEngineContext; -import org.apache.hudi.common.model.HoodieBaseFile; import org.apache.hudi.common.model.HoodieCommitMetadata; import org.apache.hudi.common.model.HoodieKey; import org.apache.hudi.common.model.HoodieRecord; @@ -336,13 +335,6 @@ public abstract class BaseSparkCommitActionExecutor> keyToNewRecords, - HoodieBaseFile dataFileToBeMerged) { - return new HoodieMergeHandle<>(config, instantTime, table, keyToNewRecords, - partitionPath, fileId, dataFileToBeMerged, taskContextSupplier); - } - @Override public void syncTableMetadata() { // Open up the metadata table again, for syncing