fix asyn rdb write only one record

Author: todd5167

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/async/RdbAsyncReqRow.java

@@ -90,11 +90,14 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
                     return;
                 } else if (ECacheContentType.MultiLine == val.getType()) {
 
+                    List<Row> rowList = Lists.newArrayList();
                     for (Object jsonArray : (List) val.getContent()) {
                         Row row = fillData(input, jsonArray);
-                        resultFuture.complete(Collections.singleton(row));
+                        rowList.add(row);
                     }
 
+                    resultFuture.complete(rowList);
+
                 } else {
                     throw new RuntimeException("not support cache obj type " + val.getType());
                 }
@@ -122,18 +125,18 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
 
                 int resultSize = rs.result().getResults().size();
                 if (resultSize > 0) {
+                    List<Row> rowList = Lists.newArrayList();
                     for (JsonArray line : rs.result().getResults()) {
-
                         Row row = fillData(input, line);
                         if (openCache()) {
                             cacheContent.add(line);
                         }
-                        resultFuture.complete(Collections.singleton(row));
+                        rowList.add(row);
                     }
-
                     if (openCache()) {
                         putCache(key, CacheObj.buildCacheObj(ECacheContentType.MultiLine, cacheContent));
                     }
+                    resultFuture.complete(rowList);
                 } else {
                     dealMissKey(input, resultFuture);
                     if (openCache()) {