Merge branch 'hotfix_1.10_4.0.x_30677' into 1.10_release_4.0.x

Author: gituser

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

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