From 2bf7920bd9dcd1c357854c5aacba87251b60faf4 Mon Sep 17 00:00:00 2001 From: Rahil C <32500120+rahil-c@users.noreply.github.com> Date: Thu, 21 Jul 2022 09:57:18 -0700 Subject: [PATCH] [MINOR] Add logger for HoodieCopyOnWriteTableInputFormat (#6161) Co-authored-by: Wenning Ding --- .../apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java | 4 ++++ 1 file changed, 4 insertions(+) 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 f11ca88d2..65a7259a6 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.exception.HoodieIOException; 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 @@ import static org.apache.hudi.common.util.ValidationUtils.checkState; */ 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);