Merge branch '1.8_v3.8.1_mysql_allcache' into '1.8_v3.8.1'

[mysql维表全量缓存报空指针异常错误][19145]



See merge request !78

Author: zoudaokoulife

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

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