From 6401923609e7763355ee2d192465f604157ebc1b Mon Sep 17 00:00:00 2001
From: sunxiaojian <sunxiaojian926@163.com>
Date: Wed, 17 Apr 2024 14:16:00 +0800
Subject: [PATCH] fixed

---
 .../PostgresSyncDatabaseActionITCase.java     | 24 +++++++++----------
 1 file changed, 12 insertions(+), 12 deletions(-)

diff --git a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncDatabaseActionITCase.java b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncDatabaseActionITCase.java
index b3da8507f38e..f0a0de67caa8 100644
--- a/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncDatabaseActionITCase.java
+++ b/paimon-flink/paimon-flink-cdc/src/test/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncDatabaseActionITCase.java
@@ -254,11 +254,11 @@ public void testIgnoreIncompatibleTables() throws Exception {
                 Collections.emptyMap());
 
         // try synchronization
-        Map<String, String> PostgresConfig = getBasicPostgresConfig();
-        PostgresConfig.put("schema-name", "paimon_sync_schema_ignore_incompatible");
+        Map<String, String> postgresConfig = getBasicPostgresConfig();
+        postgresConfig.put("schema-name", "paimon_sync_schema_ignore_incompatible");
 
         PostgresSyncDatabaseAction action =
-                syncDatabaseActionBuilder(PostgresConfig)
+                syncDatabaseActionBuilder(postgresConfig)
                         .withTableConfig(getBasicTableConfig())
                         .ignoreIncompatible(true)
                         .build();
@@ -301,11 +301,11 @@ public void testTableAffix() throws Exception {
                 Collections.emptyMap());
 
         // try synchronization
-        Map<String, String> PostgresConfig = getBasicPostgresConfig();
-        PostgresConfig.put("schema-name", "paimon_sync_schema_affix");
+        Map<String, String> postgresConfig = getBasicPostgresConfig();
+        postgresConfig.put("schema-name", "paimon_sync_schema_affix");
 
         PostgresSyncDatabaseAction action =
-                syncDatabaseActionBuilder(PostgresConfig)
+                syncDatabaseActionBuilder(postgresConfig)
                         .withTableConfig(getBasicTableConfig())
                         .withTablePrefix("test_prefix_")
                         .withTableSuffix("_test_suffix")
@@ -1055,12 +1055,12 @@ public void testSyncMultipleShards() throws Exception {
     @Test
     @Timeout(60)
     public void testSyncMultipleShardsWithoutMerging() throws Exception {
-        Map<String, String> PostgresConfig = getBasicPostgresConfig();
-        PostgresConfig.put("schema-name", "without_merging_shard_.*");
+        Map<String, String> postgresConfig = getBasicPostgresConfig();
+        postgresConfig.put("schema-name", "without_merging_shard_.*");
 
         MultiTablesSinkMode mode = ThreadLocalRandom.current().nextBoolean() ? DIVIDED : COMBINED;
         PostgresSyncDatabaseAction action =
-                syncDatabaseActionBuilder(PostgresConfig)
+                syncDatabaseActionBuilder(postgresConfig)
                         .withTableConfig(getBasicTableConfig())
                         .mergeShards(false)
                         .withMode(mode.configString())
@@ -1174,11 +1174,11 @@ public void testMonitoredAndExcludedTablesWithMering() throws Exception {
                 Collections.singletonList("k"),
                 Collections.emptyMap());
 
-        Map<String, String> PostgresConfig = getBasicPostgresConfig();
-        PostgresConfig.put("schema-name", "monitored_and_excluded_shard_.*");
+        Map<String, String> postgresConfig = getBasicPostgresConfig();
+        postgresConfig.put("schema-name", "monitored_and_excluded_shard_.*");
 
         PostgresSyncDatabaseAction action =
-                syncDatabaseActionBuilder(PostgresConfig)
+                syncDatabaseActionBuilder(postgresConfig)
                         .ignoreIncompatible(true)
                         .withMode(COMBINED.configString())
                         .build();