[fix] fix hbase null should ignore
@@ -215,15 +215,14 @@ public class HbaseOutputFormat extends AbstractDtRichOutputFormat<Tuple2> {
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[] val = fieldVal.toString().getBytes();
byte[] cf = families[i].getBytes();
byte[] qualifier = qualifiers[i].getBytes();
put.addColumn(cf, qualifier, val);
}
+ }
return put;
}
