添加空置判断

dapeng · dapeng · commit 28ae8889c12c · 2020-06-03T14:05:59.000+08:00
diff --git a/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java b/hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java
@@ -165,7 +165,7 @@ public void writeRecord(Tuple2 tuple2) {
 
     protected void dealInsert(Row record) {
         Put put = getPutByRow(record);
-        if (put.isEmpty()) {
+        if (put == null || put.isEmpty()) {
             return;
         }
 

Original file line number	Diff line number	Diff line change
`@@ -165,7 +165,7 @@ public void writeRecord(Tuple2 tuple2) {`
`165`	`165`
`166`	`166`	`protected void dealInsert(Row record) {`
`167`	`167`	`Put put = getPutByRow(record);`
`168`		`- if (put.isEmpty()) {`
	`168`	`+ if (put == null \|\| put.isEmpty()) {`
`169`	`169`	`return;`
`170`	`170`	`}`
`171`	`171`