Merge remote-tracking branch 'origin/feat_1.8_async' into feat_async_mergedDev

dapeng · dapeng · commit bd517df3f517 · 2020-03-01T20:16:59.000+08:00
diff --git a/core/src/main/java/com/dtstack/flink/sql/side/AsyncReqRow.java b/core/src/main/java/com/dtstack/flink/sql/side/AsyncReqRow.java
@@ -129,7 +129,7 @@ public void timeout(CRow input, ResultFuture<CRow> resultFuture) throws Exceptio
 
         timeOutNum ++;
         if(timeOutNum > sideInfo.getSideTableInfo().getAsyncTimeoutNumLimit()){
-            resultFuture.complete(null);
+            resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));
         }
     }
 

Original file line number	Diff line number	Diff line change
`@@ -129,7 +129,7 @@ public void timeout(CRow input, ResultFuture<CRow> resultFuture) throws Exceptio`
`129`	`129`
`130`	`130`	`timeOutNum ++;`
`131`	`131`	`if(timeOutNum > sideInfo.getSideTableInfo().getAsyncTimeoutNumLimit()){`
`132`		`- resultFuture.complete(null);`
	`132`	`+ resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));`
`133`	`133`	`}`
`134`	`134`	`}`
`135`	`135`