Minor, Improve naming of state tables used in tests (#322)

memiiso · May 17, 2024 · 37c8e6f · 37c8e6f
1 parent 1ef7ee9
commit 37c8e6f
Show file tree

Hide file tree

Showing 3 changed files with 5 additions and 6 deletions.
diff --git a/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java b/...rver-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
@@ -294,7 +294,7 @@ public void testSimpleUpload() {
 
     Awaitility.await().atMost(Duration.ofSeconds(120)).until(() -> {
       try {
-        CloseableIterable<Record> d = getTableDataV2(TableIdentifier.of("debeziumevents", "debezium_offset_storage_custom_table"));
+        CloseableIterable<Record> d = getTableDataV2(TableIdentifier.of("debeziumevents", "debezium_offset_storage_table"));
         System.out.println(Lists.newArrayList(d));
         return Lists.newArrayList(d).size() == 1;
       } catch (Exception e) {

diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/TestConfigSource.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/TestConfigSource.java
@@ -58,9 +58,9 @@ public TestConfigSource() {
 
     // DEBEZIUM SOURCE conf
     config.put("debezium.source.offset.storage", "io.debezium.server.iceberg.offset.IcebergOffsetBackingStore");
-    config.put("debezium.source.offset.storage.iceberg.table-name", "debezium_offset_storage_custom_table");
+    config.put("debezium.source.offset.storage.iceberg.table-name", "debezium_offset_storage_table");
     config.put("debezium.source.schema.history.internal", "io.debezium.server.iceberg.history.IcebergSchemaHistory");
-    config.put("debezium.source.schema.history.internal.iceberg.table-name", "debezium_database_history_storage_test");
+    config.put("debezium.source.schema.history.internal.iceberg.table-name", "debezium_database_history_storage_table");
     config.put("debezium.source.offset.flush.interval.ms", "1000");
     config.put("debezium.source.database.server.name", "testc");
     config.put("debezium.source.database.server.id", "1234");
@@ -76,7 +76,6 @@ public TestConfigSource() {
     config.put("quarkus.log.category.\"org.apache.parquet\".level", "WARN");
     config.put("quarkus.log.category.\"org.eclipse.jetty\".level", "WARN");
     config.put("quarkus.log.category.\"org.apache.iceberg\".level", "ERROR");
-
   }
 
   @Override

diff --git a/...eberg-sink/src/test/java/io/debezium/server/iceberg/history/IcebergSchemaHistoryTest.java b/...eberg-sink/src/test/java/io/debezium/server/iceberg/history/IcebergSchemaHistoryTest.java
@@ -50,7 +50,7 @@ public void testSimpleUpload() {
     // test nested data(struct) consumed
     Awaitility.await().atMost(Duration.ofSeconds(120)).until(() -> {
       try {
-        return Lists.newArrayList(getTableDataV2(TableIdentifier.of("mycatalog", "debezium_database_history_storage_test"))).size() >= 5;
+        return Lists.newArrayList(getTableDataV2(TableIdentifier.of("mycatalog", "debezium_database_history_storage_table"))).size() >= 5;
       } catch (Exception e) {
         e.printStackTrace();
         return false;
@@ -66,7 +66,7 @@ public Map<String, String> getConfigOverrides() {
       config.put("quarkus.profile", "mysql");
       config.put("%mysql.debezium.source.connector.class", "io.debezium.connector.mysql.MySqlConnector");
       config.put("debezium.source.schema.history.internal", "io.debezium.server.iceberg.history.IcebergSchemaHistory");
-      config.put("debezium.source.schema.history.internal.iceberg.table-name", "debezium_database_history_storage_test");
+      config.put("debezium.source.schema.history.internal.iceberg.table-name", "debezium_database_history_storage_table");
       config.put("debezium.source.table.whitelist", "inventory.customers");
       return config;
     }