fix completeExceptionally desc

dapeng · dapeng · commit 48dd0c0fc268 · 2020-03-01T14:07:32.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,9 +129,8 @@ public void timeout(Row input, ResultFuture<Row> resultFuture) throws Exception
         }
         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,9 +129,8 @@ public void timeout(Row input, ResultFuture<Row> resultFuture) throws Exception`
`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`		`-`
`135`	`134`	`}`
`136`	`135`
`137`	`136`