From affecf0b610776ebb470eb660d5e69e142c19143 Mon Sep 17 00:00:00 2001
From: Ismail Simsek <6005685+ismailsimsek@users.noreply.github.com>
Date: Fri, 17 May 2024 19:19:32 +0200
Subject: [PATCH] Minor, Improve naming of state tables used in tests

---
 .../debezium/server/iceberg/IcebergChangeConsumerTest.java   | 2 +-
 .../java/io/debezium/server/iceberg/TestConfigSource.java    | 5 ++---
 .../server/iceberg/history/IcebergSchemaHistoryTest.java     | 4 ++--
 3 files changed, 5 insertions(+), 6 deletions(-)

diff --git a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
index af617677..444cfce6 100644
--- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/IcebergChangeConsumerTest.java
+++ b/debezium-server-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
index f6dbfd18..d45f9636 100644
--- 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/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/history/IcebergSchemaHistoryTest.java b/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/history/IcebergSchemaHistoryTest.java
index 2296fbe1..f5a61f99 100644
--- a/debezium-server-iceberg-sink/src/test/java/io/debezium/server/iceberg/history/IcebergSchemaHistoryTest.java
+++ b/debezium-server-iceberg-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;
     }