diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java index f11ca88d29c0f..65a7259a6f14d 100644 --- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java +++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java @@ -49,6 +49,8 @@ import org.apache.hudi.hadoop.realtime.HoodieVirtualKeyInfo; import org.apache.hudi.hadoop.utils.HoodieHiveUtils; import org.apache.hudi.hadoop.utils.HoodieInputFormatUtils; +import org.apache.log4j.LogManager; +import org.apache.log4j.Logger; import javax.annotation.Nonnull; import java.io.IOException; @@ -77,6 +79,8 @@ */ public class HoodieCopyOnWriteTableInputFormat extends HoodieTableInputFormat { + private static final Logger LOG = LogManager.getLogger(HoodieCopyOnWriteTableInputFormat.class); + @Override protected boolean isSplitable(FileSystem fs, Path filename) { return !(filename instanceof PathWithBootstrapFileStatus);