From fb989b55e366c51533600cbe66048909f294b776 Mon Sep 17 00:00:00 2001
From: Jingsong <jingsonglee0@gmail.com>
Date: Mon, 29 Jul 2024 19:14:57 +0800
Subject: [PATCH] fix

---
 .../java/org/apache/paimon/flink/action/ActionBase.java    | 7 +++++--
 1 file changed, 5 insertions(+), 2 deletions(-)

diff --git a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java
index ea05c5faffe66..30e32d62efec9 100644
--- a/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java
+++ b/paimon-flink/paimon-flink-common/src/main/java/org/apache/paimon/flink/action/ActionBase.java
@@ -54,11 +54,14 @@ public abstract class ActionBase implements Action {
     protected StreamTableEnvironment batchTEnv;
 
     public ActionBase(String warehouse, Map<String, String> catalogConfig) {
-        // disable cache to avoid concurrent modification exception
-        catalogConfig.putIfAbsent(CACHE_ENABLED.key(), "false");
         catalogOptions = Options.fromMap(catalogConfig);
         catalogOptions.set(CatalogOptions.WAREHOUSE, warehouse);
 
+        // disable cache to avoid concurrent modification exception
+        if (!catalogOptions.contains(CACHE_ENABLED)) {
+            catalogOptions.set(CACHE_ENABLED, false);
+        }
+
         catalog = initPaimonCatalog();
         flinkCatalog = initFlinkCatalog();