From 2bd4b46fa2bcc301a0e867883e14ab6ccb8b1dec Mon Sep 17 00:00:00 2001 From: luolh Date: Wed, 9 Sep 2020 15:09:04 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8Dhbase=20reader=20task=20?= =?UTF-8?q?=E5=AD=97=E6=AE=B5=E5=80=BC=E4=B8=BAnull=E7=9A=84bug?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../reader/hbase20xsqlreader/HBase20xSQLReaderTask.java | 8 +++++--- 1 file changed, 5 insertions(+), 3 deletions(-) diff --git a/hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20xSQLReaderTask.java b/hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20xSQLReaderTask.java index 866cef38..3ebc704c 100644 --- a/hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20xSQLReaderTask.java +++ b/hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20xSQLReaderTask.java @@ -86,16 +86,18 @@ public class HBase20xSQLReaderTask { column = new LongColumn((Integer) value); break; case Types.TINYINT: - column = new LongColumn(((Byte) value).longValue()); + Byte aByte = (Byte) value; + column = new LongColumn(null == aByte ? null : aByte.longValue()); break; case Types.SMALLINT: - column = new LongColumn(((Short) value).longValue()); + Short aShort = (Short) value; + column = new LongColumn(null == aShort ? null : aShort.longValue()); break; case Types.BIGINT: column = new LongColumn((Long) value); break; case Types.FLOAT: - column = new DoubleColumn((Float.valueOf(value.toString()))); + column = new DoubleColumn(null == value ? null : (Float.valueOf(value.toString()))); break; case Types.DECIMAL: column = new DoubleColumn((BigDecimal)value);