change to debug level

gavingaozhangmin · gavingaozhangmin · commit ccfc9a0b57dc · 2021-11-08T16:21:05.000+08:00
diff --git a/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSinkBase.java b/pulsar-flink-connector/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/pulsar-flink-connector/src/main/java/org/apache/flink/streaming/connectors/pulsar/FlinkPulsarSource.java b/pulsar-flink-connector/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);
             }

Original file line number	Diff line number	Diff line change
`@@ -273,11 +273,11 @@ public void open(Configuration parameters) throws Exception {`
`273`	`273`	`topic2Producer = new HashMap<>();`
`274`	`274`	`}`
`275`	`275`	`//super.open(parameters);`
`276`		`- if (log.isInfoEnabled()) {`
	`276`	`+ if (log.isDebugEnabled()) {`
`277`	`277`	`try {`
`278`	`278`	`ObjectMapper m = new ObjectMapper();`
`279`	`279`	`ObjectWriter w = m.writerWithDefaultPrettyPrinter();`
`280`		`- log.info("Pulsar sink config: {}", w.writeValueAsString(properties));`
	`280`	`+ log.debug("Pulsar sink config: {}", w.writeValueAsString(properties));`
`281`	`281`	`} catch (IOException e) {`
`282`	`282`	`log.error("Failed to dump sink config info", e);`
`283`	`283`	`}`
Original file line number	Diff line number	Diff line change
`@@ -505,11 +505,11 @@ public void open(Configuration parameters) throws Exception {`
`505`	`505`	`}`
`506`	`506`	`}`
`507`	`507`
`508`		`- if (log.isInfoEnabled()) {`
	`508`	`+ if (log.isDebugEnabled()) {`
`509`	`509`	`try {`
`510`	`510`	`ObjectMapper m = new ObjectMapper();`
`511`	`511`	`ObjectWriter w = m.writerWithDefaultPrettyPrinter();`
`512`		`- log.info("Pulsar source config: {}", w.writeValueAsString(properties));`
	`512`	`+ log.debug("Pulsar source config: {}", w.writeValueAsString(properties));`
`513`	`513`	`} catch (IOException e) {`
`514`	`514`	`log.error("Failed to dump source config info", e);`
`515`	`515`	`}`