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

流维join,源表的关联字段不输入,无法打入数据到结果表.关系型数据已经修改



See merge request !83

Author: zoudaokoulife

rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/RdbAllReqRow.java

@@ -119,6 +119,10 @@ public void flatMap(Row value, Collector<Row> out) throws Exception {
         for (Integer conValIndex : sideInfo.getEqualValIndex()) {
             Object equalObj = value.getField(conValIndex);
             if (equalObj == null) {
+                if (sideInfo.getJoinType() == JoinType.LEFT) {
+                    Row row = fillData(value, null);
+                    out.collect(row);
+                }
                 return;
             }
             inputParams.add(equalObj);

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

@@ -78,7 +78,7 @@ public void asyncInvoke(Row input, ResultFuture<Row> resultFuture) throws Except
         for (Integer conValIndex : sideInfo.getEqualValIndex()) {
             Object equalObj = input.getField(conValIndex);
             if (equalObj == null) {
-                resultFuture.complete(null);
+                dealMissKey(input, resultFuture);
                 return;
             }
             inputParams.add(equalObj);