add log

yanxi0227 · yanxi0227 · commit 713b64ac0be5 · 2019-07-28T12:46:03.000+08:00
diff --git a/kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java b/kafka09/kafka09-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java
@@ -144,7 +144,7 @@ public Row deserialize(byte[] message) throws IOException {
         } catch (Throwable t) {
             //add metric of dirty data
             if (dirtyDataCounter.getCount()%rowLenth == 0){
-                LOG.info(objectMapper.readTree(message).toString());
+                LOG.info("dirtyData: " + new String(message));
             }
             dirtyDataCounter.inc();
             return null;
diff --git a/kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java b/kafka10/kafka10-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java
@@ -144,7 +144,7 @@ public Row deserialize(byte[] message) throws IOException {
         } catch (Throwable t) {
             //add metric of dirty data
             if (dirtyDataCounter.getCount()%rowLenth == 0){
-                LOG.info(objectMapper.readTree(message).toString());
+                LOG.info("dirtyData: " + new String(message));
             }
             dirtyDataCounter.inc();
             return null;
diff --git a/kafka11/kafka11-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java b/kafka11/kafka11-source/src/main/java/com/dtstack/flink/sql/source/kafka/CustomerJsonDeserialization.java
@@ -147,7 +147,7 @@ public Row deserialize(byte[] message) throws IOException {
         } catch (Throwable t) {
             //add metric of dirty data
             if (dirtyDataCounter.getCount()%rowLenth == 0){
-                LOG.info(objectMapper.readTree(message).toString());
+                LOG.info("dirtyData: " + new String(message));
             }
             dirtyDataCounter.inc();
             return null;

Original file line number	Diff line number	Diff line change
`@@ -144,7 +144,7 @@ public Row deserialize(byte[] message) throws IOException {`
`144`	`144`	`} catch (Throwable t) {`
`145`	`145`	`//add metric of dirty data`
`146`	`146`	`if (dirtyDataCounter.getCount()%rowLenth == 0){`
`147`		`- LOG.info(objectMapper.readTree(message).toString());`
	`147`	`+ LOG.info("dirtyData: " + new String(message));`
`148`	`148`	`}`
`149`	`149`	`dirtyDataCounter.inc();`
`150`	`150`	`return null;`
Original file line number	Diff line number	Diff line change
`@@ -147,7 +147,7 @@ public Row deserialize(byte[] message) throws IOException {`
`147`	`147`	`} catch (Throwable t) {`
`148`	`148`	`//add metric of dirty data`
`149`	`149`	`if (dirtyDataCounter.getCount()%rowLenth == 0){`
`150`		`- LOG.info(objectMapper.readTree(message).toString());`
	`150`	`+ LOG.info("dirtyData: " + new String(message));`
`151`	`151`	`}`
`152`	`152`	`dirtyDataCounter.inc();`
`153`	`153`	`return null;`