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

dapeng · dapeng · commit 7f544e382f9e · 2020-05-15T18:21:36.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
@@ -161,7 +161,8 @@ protected void preInvoke(CRow input, ResultFuture<CRow> resultFuture){
     }
 
     @Override
-    public void asyncInvoke(CRow input, ResultFuture<CRow> resultFuture) throws Exception {
+    public void asyncInvoke(CRow row, ResultFuture<CRow> resultFuture) throws Exception {
+        CRow input = new CRow(Row.copy(row.row()), row.change());
         preInvoke(input, resultFuture);
         Map<String, Object> inputParams = parseInputParam(input);
         if(MapUtils.isEmpty(inputParams)){

Original file line number	Diff line number	Diff line change
`@@ -161,7 +161,8 @@ protected void preInvoke(CRow input, ResultFuture<CRow> resultFuture){`
`161`	`161`	`}`
`162`	`162`
`163`	`163`	`@Override`
`164`		`- public void asyncInvoke(CRow input, ResultFuture<CRow> resultFuture) throws Exception {`
	`164`	`+ public void asyncInvoke(CRow row, ResultFuture<CRow> resultFuture) throws Exception {`
	`165`	`+ CRow input = new CRow(Row.copy(row.row()), row.change());`
`165`	`166`	`preInvoke(input, resultFuture);`
`166`	`167`	`Map<String, Object> inputParams = parseInputParam(input);`
`167`	`168`	`if(MapUtils.isEmpty(inputParams)){`