Merge branch 'hotfix_1.8_3.10.x_25114' into 1.8_zy_3.10.x

Author: dapeng

hbase/hbase-side/hbase-side-core/src/main/java/com/dtstack/flink/sql/side/hbase/utils/HbaseUtils.java

@@ -66,9 +66,12 @@ public static Object convertByte(byte[] hbaseData, String type){
 
             case "double":
                 return Bytes.toDouble(hbaseData);
-
+            case "decimal":
+                return Bytes.toBigDecimal(hbaseData);
+            default:
+                throw new RuntimeException("not support type of " + type);
         }
-
-        throw new RuntimeException("not support type of " + type);
     }
+
+
 }

launcher/src/main/test/java/com/dtstack/flink/sql/launcher/PluginLoadModeTest.java

@@ -48,8 +48,22 @@ public static void testClasspathMode() throws Exception {
         LauncherMain.main(sql);
     }
 
+    
+    public static void testRocSql() throws Exception{
+        String[] sql = new String[]{"-mode", "local", "-sql", "/Users/roc/Documents/flink_sql/sql/zy_sql/hbase_side.sql", "-name", "roc",
+                "-localSqlPluginPath", "/Users/roc/workspace/git_code/flinkStreamSQL/plugins",
+                "-remoteSqlPluginPath", "/Users/roc/workspace/git_code/flinkStreamSQL/plugins",
+                "-flinkconf", "/Users/roc/Documents/flink_sql/flinkconf",
+                "-confProp", "{\"sql.checkpoint.cleanup.mode\":\"false\",\"sql.checkpoint.interval\":10000,\"time.characteristic\":\"EventTime\"}",
+                "-yarnconf", "/Users/roc/Documents/flink_sql/yarnconf",
+                "-flinkJarPath", "/Users/roc/Documents/flink_sql/flinkJarPath", "-queue", "c", "-pluginLoadMode", "classpath"};
+        System.setProperty("HADOOP_USER_NAME", "admin");
+        LauncherMain.main(sql);
+    }
+
     public static void main(String[] args) throws Exception {
-        testShipfileMode();
+        testRocSql();
+//        testShipfileMode();
 //        testClasspathMode();
     }
 }