fixed

sunxiaojian · Apr 17, 2024 · 6401923 · 6401923
1 parent 6a4a6f1
commit 6401923
Showing 1 changed file with 12 additions and 12 deletions.
diff --git a/...st/java/org/apache/paimon/flink/action/cdc/postgres/PostgresSyncDatabaseActionITCase.java b/...st/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();