From 0cd1472bf89cd629aa446becc9b226869a54d71a Mon Sep 17 00:00:00 2001
From: airyv <68733037+airyv@users.noreply.github.com>
Date: Fri, 8 Sep 2023 14:21:43 +0800
Subject: [PATCH] Update HbaseAbstractTask.java
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

修复hbase11xreader插件指定字段类型为boolean、short、int、long、float、double时转换失败问题，例如，当指定字段类型为int时，会报错："exception":"offset (0)+Length (4)exceed the capacity of the array:1"
---
 .../reader/hbase11xreader/HbaseAbstractTask.java     | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseAbstractTask.java b/hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseAbstractTask.java
index c32343a9..e2a75b87 100755
--- a/hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseAbstractTask.java
+++ b/hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseAbstractTask.java
@@ -92,22 +92,22 @@ public abstract class HbaseAbstractTask {
         Column column;
         switch (columnType) {
             case BOOLEAN:
-                column = new BoolColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toBoolean(byteArray));
+                column = new BoolColumn(ArrayUtils.isEmpty(byteArray) ? null : Boolean.valueOf(Bytes.toString(byteArray)));
                 break;
             case SHORT:
-                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : String.valueOf(Bytes.toShort(byteArray)));
+                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toString(byteArray));
                 break;
             case INT:
-                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toInt(byteArray));
+                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : Integer.valueOf(Bytes.toString(byteArray)));
                 break;
             case LONG:
-                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toLong(byteArray));
+                column = new LongColumn(ArrayUtils.isEmpty(byteArray) ? null : Long.valueOf(Bytes.toString(byteArray)));
                 break;
             case FLOAT:
-                column = new DoubleColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toFloat(byteArray));
+                column = new DoubleColumn(ArrayUtils.isEmpty(byteArray) ? null : Float.valueOf(Bytes.toString(byteArray)));
                 break;
             case DOUBLE:
-                column = new DoubleColumn(ArrayUtils.isEmpty(byteArray) ? null : Bytes.toDouble(byteArray));
+                column = new DoubleColumn(ArrayUtils.isEmpty(byteArray) ? null : Double.valueOf(Bytes.toString(byteArray)));
                 break;
             case STRING:
                 column = new StringColumn(ArrayUtils.isEmpty(byteArray) ? null : new String(byteArray, encoding));