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 : {}",