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

修复hbase11xwriter插件指定字段类型为boolean、short、int、long、float、double时目标端写入乱码问题。
---
 .../writer/hbase11xwriter/HbaseAbstractTask.java     | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/HbaseAbstractTask.java b/hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/HbaseAbstractTask.java
index 22e6144c..4307dad3 100755
--- a/hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/HbaseAbstractTask.java
+++ b/hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/HbaseAbstractTask.java
@@ -90,22 +90,22 @@ public abstract class HbaseAbstractTask {
         if(column.getRawData() != null){
             switch (columnType) {
                 case INT:
-                    bytes = Bytes.toBytes(column.asLong().intValue());
+                    bytes = Bytes.toBytes(String.valueOf(column.asLong().intValue()));
                     break;
                 case LONG:
-                    bytes = Bytes.toBytes(column.asLong());
+                    bytes = Bytes.toBytes(String.valueOf(column.asLong()));
                     break;
                 case DOUBLE:
-                    bytes = Bytes.toBytes(column.asDouble());
+                    bytes = Bytes.toBytes(String.valueOf(column.asDouble()));
                     break;
                 case FLOAT:
-                    bytes = Bytes.toBytes(column.asDouble().floatValue());
+                    bytes = Bytes.toBytes(String.valueOf(column.asDouble().floatValue()));
                     break;
                 case SHORT:
-                    bytes = Bytes.toBytes(column.asLong().shortValue());
+                    bytes = Bytes.toBytes(String.valueOf(column.asLong().shortValue()));
                     break;
                 case BOOLEAN:
-                    bytes = Bytes.toBytes(column.asBoolean());
+                    bytes = Bytes.toBytes(String.valueOf(column.asBoolean()));
                     break;
                 case STRING:
                     bytes = this.getValueByte(columnType,column.asString());