add isinfoEnabled

streamnative · Sep 2, 2021 · ef03236 · ef03236
1 parent 9453349
commit ef03236
Show file tree

Hide file tree

Showing 2 changed files with 16 additions and 13 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,13 +273,14 @@ public void open(Configuration parameters) throws Exception {
             topic2Producer = new HashMap<>();
         }
        //super.open(parameters);
-
-        try {
-            ObjectMapper m = new ObjectMapper();
-            ObjectWriter w = m.writerWithDefaultPrettyPrinter();
-            log.info("Pulsar sink config: {}", w.writeValueAsString(properties));
-        } catch (IOException e) {
-            log.error("Failed to dump sink config info", e);
+        if (log.isInfoEnabled()) {
+            try {
+                ObjectMapper m = new ObjectMapper();
+                ObjectWriter w = m.writerWithDefaultPrettyPrinter();
+                log.info("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,12 +505,14 @@ public void open(Configuration parameters) throws Exception {
             }
         }
 
-        try {
-            ObjectMapper m = new ObjectMapper();
-            ObjectWriter w = m.writerWithDefaultPrettyPrinter();
-            log.info("Pulsar source config: {}", w.writeValueAsString(properties));
-        } catch (IOException e) {
-            log.error("Failed to dump source config info", e);
+        if (log.isInfoEnabled()) {
+            try {
+                ObjectMapper m = new ObjectMapper();
+                ObjectWriter w = m.writerWithDefaultPrettyPrinter();
+                log.info("Pulsar source config: {}", w.writeValueAsString(properties));
+            } catch (IOException e) {
+                log.error("Failed to dump source config info", e);
+            }
         }
     }