This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b111d2f843 [Improve] Change catalog table log to debug level (#7136)
b111d2f843 is described below

commit b111d2f843c18c32b9371cff2ade003426f98c33
Author: Jia Fan <[email protected]>
AuthorDate: Tue Jul 9 15:45:42 2024 +0800

    [Improve] Change catalog table log to debug level (#7136)
---
 .../connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java         | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
index a11ec3d74d..83d5bfa769 100644
--- 
a/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
+++ 
b/seatunnel-connectors-v2/connector-jdbc/src/main/java/org/apache/seatunnel/connectors/seatunnel/jdbc/utils/JdbcCatalogUtils.java
@@ -93,7 +93,9 @@ public class JdbcCatalogUtils {
                                         .catalogTable(catalogTable)
                                         .build();
                         tables.put(tablePath, jdbcSourceTable);
-                        log.info("Loaded catalog table : {}, {}", tablePath, 
jdbcSourceTable);
+                        if (log.isDebugEnabled()) {
+                            log.debug("Loaded catalog table : {}, {}", 
tablePath, jdbcSourceTable);
+                        }
                     } catch (SeaTunnelRuntimeException e) {
                         if (e.getSeaTunnelErrorCode()
                                 .equals(
@@ -139,7 +141,9 @@ public class JdbcCatalogUtils {
                                 .build();
 
                 tables.put(tablePath, jdbcSourceTable);
-                log.info("Loaded catalog table : {}, {}", tablePath, 
jdbcSourceTable);
+                if (log.isDebugEnabled()) {
+                    log.debug("Loaded catalog table : {}, {}", tablePath, 
jdbcSourceTable);
+                }
             }
             log.info(
                     "Loaded {} catalog tables for jdbc : {}",

Reply via email to