Merge branch 'v1.8.0_dev_bugfix_hbase' into 'v1.8.0_dev'

流表前缀扫描的方式join hbase维表时，如果扫描到了多条记录，只会输入一条记录



See merge request !119

Author: simenliuxing

hbase/hbase-side/hbase-async-side/src/main/java/com/dtstack/flink/sql/side/hbase/rowkeydealer/PreRowKeyModeDealerDealer.java

@@ -88,6 +88,7 @@ private String dealOneRow(ArrayList<ArrayList<KeyValue>> args, String rowKeyStr,
         }
 
         List<Object> cacheContent = Lists.newArrayList();
+        List<Row> rowList = Lists.newArrayList();
 
         for(List<KeyValue> oneRow : args){
             try {
@@ -120,8 +121,7 @@ private String dealOneRow(ArrayList<ArrayList<KeyValue>> args, String rowKeyStr,
                     if (openCache) {
                         cacheContent.add(sideVal);
                     }
-
-                    resultFuture.complete(Collections.singleton(row));
+                    rowList.add(row);
                 }
             } catch (Exception e) {
                 resultFuture.complete(null);
@@ -130,6 +130,10 @@ private String dealOneRow(ArrayList<ArrayList<KeyValue>> args, String rowKeyStr,
             }
         }
 
+        if (rowList.size() > 0){
+            resultFuture.complete(rowList);
+        }
+
         if(openCache){
             sideCache.putCache(rowKeyStr, CacheObj.buildCacheObj(ECacheContentType.MultiLine, cacheContent));
         }