Upgrade iceberg to 1.5.0 (#278)

memiiso · Mar 3, 2024 · d924073 · d924073
1 parent d5f2542
commit d924073
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/...rc/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java b/...rc/test/java/io/debezium/server/iceberg/IcebergChangeConsumerUpsertDeleteDeletesTest.java
@@ -145,7 +145,9 @@ public void testSimpleUpsertCompositeKey() throws Exception {
     ds = getTableData("testc.inventory.customers_upsert_compositekey");
     ds.show();
     Assertions.assertEquals(ds.count(), 0);
-    Assertions.assertEquals(ds.where("first_name= 'user2'").count(), 0);
+    // NOTE: using .rdd() before count otherwise its returning wrong count!!
+    // SEE: https://stackoverflow.com/a/69039097/2679740
+    Assertions.assertEquals(ds.where("first_name= 'user2'").rdd().count(), 0);
   }
 
   public static class TestProfile implements QuarkusTestProfile {

diff --git a/pom.xml b/pom.xml
@@ -31,7 +31,7 @@
         <version.assembly.plugin>3.6.0</version.assembly.plugin>
         <!-- Use same version as iceberg https://github.com/apache/iceberg/blob/main/gradle/libs.versions.toml#L53-->
         <version.jackson>2.14.2</version.jackson>
-        <version.iceberg>1.4.3</version.iceberg>
+        <version.iceberg>1.5.0</version.iceberg>
         <!-- Following two properties defines which version of iceberg-spark-runtime is used -->
         <!-- Example https://mvnrepository.com/artifact/org.apache.iceberg/iceberg-spark-runtime-3.4_2.13/1.4.3 -->
         <version.spark.major>3.5</version.spark.major>