Fix changelog test case

apache · Apr 21, 2022 · 9054f71 · 9054f71
1 parent 83cb435
commit 9054f71
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java b/flink/v1.15/flink/src/test/java/org/apache/iceberg/flink/TestChangeLogTable.java
@@ -90,6 +90,10 @@ public void before() {
     sql("USE CATALOG %s", CATALOG_NAME);
     sql("CREATE DATABASE %s", DATABASE_NAME);
     sql("USE %s", DATABASE_NAME);
+    // https://nightlies.apache.org/flink/flink-docs-master/docs/dev/table/config/#table-exec-sink-upsert-materialize
+    // UPDATED - Needed to make testChangeLogOnDataKey work.
+    // TODO - Add tests with all configuraiton values.
+    getTableEnv().getConfig().set("table.exec.sink.upsert-materialize", "NONE");
   }
 
   @After