change to debug level

streamnative · Nov 8, 2021 · ccfc9a0 · ccfc9a0
1 parent ef03236
commit ccfc9a0
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...ector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java b/...ector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java
@@ -273,11 +273,11 @@ public void open(Configuration parameters) throws Exception {
             topic2Producer = new HashMap<>();
         }
        //super.open(parameters);
-        if (log.isInfoEnabled()) {
+        if (log.isDebugEnabled()) {
             try {
                 ObjectMapper m = new ObjectMapper();
                 ObjectWriter w = m.writerWithDefaultPrettyPrinter();
-                log.info("Pulsar sink config: {}", w.writeValueAsString(properties));
+                log.debug("Pulsar sink config: {}", w.writeValueAsString(properties));
             } catch (IOException e) {
                 log.error("Failed to dump sink config info", e);
             }

diff --git a/...nnector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSource.java b/...nnector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSource.java
@@ -505,11 +505,11 @@ public void open(Configuration parameters) throws Exception {
             }
         }
 
-        if (log.isInfoEnabled()) {
+        if (log.isDebugEnabled()) {
             try {
                 ObjectMapper m = new ObjectMapper();
                 ObjectWriter w = m.writerWithDefaultPrettyPrinter();
-                log.info("Pulsar source config: {}", w.writeValueAsString(properties));
+                log.debug("Pulsar source config: {}", w.writeValueAsString(properties));
             } catch (IOException e) {
                 log.error("Failed to dump source config info", e);
             }