diff --git a/debezium-server-iceberg-sink/pom.xml b/debezium-server-iceberg-sink/pom.xml index 222e2b11..f83f70cb 100644 --- a/debezium-server-iceberg-sink/pom.xml +++ b/debezium-server-iceberg-sink/pom.xml @@ -50,13 +50,43 @@ org.apache.iceberg - iceberg-spark-runtime-${version.spark.major}_${version.spark.scala} + iceberg-core + ${version.iceberg} + + + org.apache.iceberg + iceberg-data + ${version.iceberg} + + + org.apache.iceberg + iceberg-parquet + ${version.iceberg} + + + org.apache.iceberg + iceberg-orc + ${version.iceberg} + + + org.apache.iceberg + iceberg-arrow ${version.iceberg} org.apache.hive hive-metastore ${version.hive} + + + org.apache.parquet + parquet-hadoop-bundle + + + org.apache.arrow + arrow-* + + org.apache.iceberg @@ -230,7 +260,18 @@ ${version.spark} test - + + org.apache.iceberg + iceberg-spark-${version.spark.major}_${version.spark.scala} + ${version.iceberg} + test + + + org.apache.iceberg + iceberg-spark-extensions-${version.spark.major}_${version.spark.scala} + ${version.iceberg} + test + io.quarkus quarkus-junit5 diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java index 2547db30..ed0614db 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java +++ b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/IcebergUtil.java @@ -28,7 +28,7 @@ import org.apache.iceberg.data.GenericAppenderFactory; import org.apache.iceberg.exceptions.NoSuchTableException; import org.apache.iceberg.io.OutputFileFactory; -import org.apache.iceberg.relocated.com.google.common.primitives.Ints; +import com.google.common.primitives.Ints; import org.eclipse.microprofile.config.Config; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/BaseDeltaTaskWriter.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/BaseDeltaTaskWriter.java index ea0867d9..6718516e 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/BaseDeltaTaskWriter.java +++ b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/BaseDeltaTaskWriter.java @@ -10,7 +10,7 @@ import org.apache.iceberg.io.FileAppenderFactory; import org.apache.iceberg.io.FileIO; import org.apache.iceberg.io.OutputFileFactory; -import org.apache.iceberg.relocated.com.google.common.collect.Sets; +import com.google.common.collect.Sets; import org.apache.iceberg.types.TypeUtil; abstract class BaseDeltaTaskWriter extends BaseTaskWriter { diff --git a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/PartitionedDeltaWriter.java b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/PartitionedDeltaWriter.java index cab3ecea..2530b693 100644 --- a/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/PartitionedDeltaWriter.java +++ b/debezium-server-iceberg-sink/src/main/java/io/debezium/server/iceberg/tableoperator/PartitionedDeltaWriter.java @@ -13,7 +13,7 @@ import org.apache.iceberg.io.FileAppenderFactory; import org.apache.iceberg.io.FileIO; import org.apache.iceberg.io.OutputFileFactory; -import org.apache.iceberg.relocated.com.google.common.collect.Maps; +import com.google.common.collect.Maps; import org.apache.iceberg.util.Tasks; class PartitionedDeltaWriter extends BaseDeltaTaskWriter {