diff --git a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormatBase.java b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormatBase.java index ed88acacb4d2f..a37c4ed1d8f11 100644 --- a/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormatBase.java +++ b/hudi-hadoop-mr/src/main/java/org/apache/hudi/hadoop/HoodieParquetInputFormatBase.java @@ -23,6 +23,7 @@ import org.apache.hadoop.fs.FileStatus; import org.apache.hadoop.fs.FileSystem; import org.apache.hadoop.fs.Path; +import org.apache.hadoop.hive.ql.io.SelfDescribingInputFormatInterface; import org.apache.hadoop.hive.ql.io.parquet.MapredParquetInputFormat; import org.apache.hadoop.mapred.FileInputFormat; import org.apache.hadoop.mapred.FileSplit; @@ -45,7 +46,8 @@ * either {@link HoodieCopyOnWriteTableInputFormat} or {@link HoodieMergeOnReadTableInputFormat} to be supplied * to which it delegates all of its necessary methods. */ -public abstract class HoodieParquetInputFormatBase extends MapredParquetInputFormat implements Configurable { +public abstract class HoodieParquetInputFormatBase extends MapredParquetInputFormat implements Configurable, + SelfDescribingInputFormatInterface { private final HoodieTableInputFormat inputFormatDelegate; diff --git a/hudi-spark-datasource/hudi-spark-common/pom.xml b/hudi-spark-datasource/hudi-spark-common/pom.xml index 81c0ba6f73f52..78d67f2cc05aa 100644 --- a/hudi-spark-datasource/hudi-spark-common/pom.xml +++ b/hudi-spark-datasource/hudi-spark-common/pom.xml @@ -222,6 +222,19 @@ test + + + ${hive.groupid} + hive-exec + ${hive.version} + + + * + * + + + + org.apache.hudi diff --git a/hudi-sync/hudi-hive-sync/pom.xml b/hudi-sync/hudi-hive-sync/pom.xml index dde36c4704fb0..5617e59693261 100644 --- a/hudi-sync/hudi-hive-sync/pom.xml +++ b/hudi-sync/hudi-hive-sync/pom.xml @@ -121,6 +121,17 @@ hive-common ${hive.version} + + ${hive.groupid} + hive-exec + ${hive.version} + + + * + * + + +