Merge branch 'feat_1.8_asyncException_mergeTest' into 1.8_release_3.10.x_mergedTest_new

dapeng · dapeng · commit 2fac3694206f · 2020-05-12T18:01:48.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/BaseAsyncReqRow.java b/core/src/main/java/com/dtstack/flink/sql/side/BaseAsyncReqRow.java
@@ -183,7 +183,7 @@ private Map<String, Object> parseInputParam(CRow input){
             if(equalObj == null){
                 return inputParams;
             }
-            String columnName = sideInfo.getEqualFieldList().get(conValIndex);
+            String columnName = sideInfo.getEqualFieldList().get(i);
             inputParams.put(columnName, equalObj);
         }
         return inputParams;

Original file line number	Diff line number	Diff line change
`@@ -183,7 +183,7 @@ private Map<String, Object> parseInputParam(CRow input){`
`183`	`183`	`if(equalObj == null){`
`184`	`184`	`return inputParams;`
`185`	`185`	`}`
`186`		`- String columnName = sideInfo.getEqualFieldList().get(conValIndex);`
	`186`	`+ String columnName = sideInfo.getEqualFieldList().get(i);`
`187`	`187`	`inputParams.put(columnName, equalObj);`
`188`	`188`	`}`
`189`	`189`	`return inputParams;`