test log

dapeng · dapeng · commit 174f70fe8a9e · 2020-03-03T13:37:49.000+08:00
diff --git a/kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/CustomerKeyedSerializationSchema.java b/kafka-base/kafka-base-sink/src/main/java/com/dtstack/flink/sql/sink/kafka/CustomerKeyedSerializationSchema.java
@@ -51,7 +51,7 @@ private byte[] serializeJsonKey(JsonRowSerializationSchema jsonRowSerializationS
                     sb.append(objectNode.get(key));
                 }
             }
-            return sb.toString().getBytes();
+            return null;
         }catch (Exception e){
 
         }

Original file line number	Diff line number	Diff line change
`@@ -51,7 +51,7 @@ private byte[] serializeJsonKey(JsonRowSerializationSchema jsonRowSerializationS`
`51`	`51`	`sb.append(objectNode.get(key));`
`52`	`52`	`}`
`53`	`53`	`}`
`54`		`- return sb.toString().getBytes();`
	`54`	`+ return null;`
`55`	`55`	`}catch (Exception e){`
`56`	`56`
`57`	`57`	`}`