hbase 允许填充null值

Author: dapeng

hbase/hbase-sink/src/main/java/com/dtstack/flink/sql/sink/hbase/HbaseOutputFormat.java

@@ -213,10 +213,10 @@ private Put getPutByRow(Row record) {
         Put put = new Put(rowKey.getBytes());
         for (int i = 0; i < record.getArity(); ++i) {
             Object fieldVal = record.getField(i);
-            if (fieldVal == null) {
-                continue;
+            byte[] val = null;
+            if (fieldVal != null) {
+                val = fieldVal.toString().getBytes();
             }
-            byte[] val = fieldVal.toString().getBytes();
             byte[] cf = families[i].getBytes();
             byte[] qualifier = qualifiers[i].getBytes();