解析columnName error

dapeng · dapeng · commit 95e7eaa84f55 · 2020-05-12T18:00:10.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
@@ -182,7 +182,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
`@@ -182,7 +182,7 @@ private Map<String, Object> parseInputParam(CRow input){`
`182`	`182`	`if(equalObj == null){`
`183`	`183`	`return inputParams;`
`184`	`184`	`}`
`185`		`- String columnName = sideInfo.getEqualFieldList().get(conValIndex);`
	`185`	`+ String columnName = sideInfo.getEqualFieldList().get(i);`
`186`	`186`	`inputParams.put(columnName, equalObj);`
`187`	`187`	`}`
`188`	`188`	`return inputParams;`