diff --git a/plugin/trino-hudi/pom.xml b/plugin/trino-hudi/pom.xml index 5e6c486cf3e1..d609063eb6fb 100644 --- a/plugin/trino-hudi/pom.xml +++ b/plugin/trino-hudi/pom.xml @@ -15,7 +15,8 @@ ${project.parent.basedir} - 0.12.3 + 0.14.0 + 2.4.9 @@ -188,6 +189,13 @@ runtime + + com.esotericsoftware + kryo-shaded + 4.0.2 + test + + io.airlift junit-extensions @@ -275,6 +283,32 @@ test + + org.apache.hbase + hbase-client + ${dep.hbase.version} + test + + + * + * + + + + + + org.apache.hbase + hbase-server + ${dep.hbase.version} + test + + + * + * + + + + org.apache.hudi hudi-client-common diff --git a/plugin/trino-hudi/src/test/java/io/trino/plugin/hudi/testing/TpchHudiTablesInitializer.java b/plugin/trino-hudi/src/test/java/io/trino/plugin/hudi/testing/TpchHudiTablesInitializer.java index 7807fdf12945..7763bb461783 100644 --- a/plugin/trino-hudi/src/test/java/io/trino/plugin/hudi/testing/TpchHudiTablesInitializer.java +++ b/plugin/trino-hudi/src/test/java/io/trino/plugin/hudi/testing/TpchHudiTablesInitializer.java @@ -40,6 +40,7 @@ import org.apache.hudi.client.HoodieJavaWriteClient; import org.apache.hudi.client.common.HoodieJavaEngineContext; import org.apache.hudi.common.bootstrap.index.NoOpBootstrapIndex; +import org.apache.hudi.common.config.HoodieMetadataConfig; import org.apache.hudi.common.model.HoodieAvroPayload; import org.apache.hudi.common.model.HoodieAvroRecord; import org.apache.hudi.common.model.HoodieKey; @@ -222,6 +223,9 @@ private HoodieJavaWriteClient createWriteClient(TpchTable .withArchivalConfig(archivalConfig) .withEmbeddedTimelineServerEnabled(false) .withMarkersType(MarkerType.DIRECT.name()) + // Disabling Hudi metadata table (MDT) in tests as the support of + // reading MDT is broken after removal of Hudi dependencies from compile time + .withMetadataConfig(HoodieMetadataConfig.newBuilder().enable(false).build()) .build(); return new HoodieJavaWriteClient<>(new HoodieJavaEngineContext(conf), cfg); } @@ -260,14 +264,7 @@ private static RecordConverter createRecordConverter(TpchTable table) // wrap to a HoodieRecord HoodieKey key = new HoodieKey(uuid, PARTITION_PATH); HoodieAvroPayload data = new HoodieAvroPayload(Option.of(record)); - return new HoodieRecord<>(key, data) - { - @Override - public HoodieRecord newInstance() - { - return new HoodieAvroRecord<>(key, data, null); - } - }; + return new HoodieAvroRecord<>(key, data, null); }; }