lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] Add logger for HoodieCopyOnWriteTableInputFormat (#6161)

Browse Source 
Co-authored-by: Wenning Ding <wenningd@amazon.com>
This commit is contained in:
Rahil C
2022-07-21 09:57:18 -07:00
committed by GitHub
parent a33bdd32e3
commit 2bf7920bd9
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieCopyOnWriteTableInputFormat.java
View File

@@ -49,6 +49,8 @@ import org.apache.hudi.exception.HoodieIOException;
import org.apache.hudi.hadoop.realtime.HoodieVirtualKeyInfo; import org.apache.hudi.hadoop.realtime.HoodieVirtualKeyInfo;
import org.apache.hudi.hadoop.utils.HoodieHiveUtils; import org.apache.hudi.hadoop.utils.HoodieHiveUtils;
import org.apache.hudi.hadoop.utils.HoodieInputFormatUtils; import org.apache.hudi.hadoop.utils.HoodieInputFormatUtils;
import org.apache.log4j.LogManager;
import org.apache.log4j.Logger;
import javax.annotation.Nonnull; import javax.annotation.Nonnull;
import java.io.IOException; import java.io.IOException;
@@ -77,6 +79,8 @@ import static org.apache.hudi.common.util.ValidationUtils.checkState;
*/ */
public class HoodieCopyOnWriteTableInputFormat extends HoodieTableInputFormat { public class HoodieCopyOnWriteTableInputFormat extends HoodieTableInputFormat {
private static final Logger LOG = LogManager.getLogger(HoodieCopyOnWriteTableInputFormat.class);
@Override @Override
protected boolean isSplitable(FileSystem fs, Path filename) { protected boolean isSplitable(FileSystem fs, Path filename) {
return !(filename instanceof PathWithBootstrapFileStatus); return !(filename instanceof PathWithBootstrapFileStatus);