补充维表超时输出left join

dapeng · dapeng · commit a78738963037 · 2020-03-24T15:51:38.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
@@ -145,11 +145,15 @@ public void timeout(CRow input, ResultFuture<CRow> resultFuture) throws Exceptio
             LOG.info("Async function call has timed out. input:{}, timeOutNum:{}",input.toString(), timeOutNum);
         }
         timeOutNum ++;
-        if(timeOutNum > sideInfo.getSideTableInfo().getAsyncTimeoutNumLimit()){
-            resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));
-        } else {
+        if(sideInfo.getJoinType() == JoinType.LEFT){
             resultFuture.complete(null);
+            return;
+        }
+        if(timeOutNum > sideInfo.getSideTableInfo().getAsyncFailMaxNum(Integer.MAX_VALUE)){
+            resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));
+            return;
         }
+        resultFuture.complete(null);
     }
 
     protected void preInvoke(CRow input, ResultFuture<CRow> resultFuture){

Original file line number	Diff line number	Diff line change
`@@ -145,11 +145,15 @@ public void timeout(CRow input, ResultFuture<CRow> resultFuture) throws Exceptio`
`145`	`145`	`LOG.info("Async function call has timed out. input:{}, timeOutNum:{}",input.toString(), timeOutNum);`
`146`	`146`	`}`
`147`	`147`	`timeOutNum ++;`
`148`		`- if(timeOutNum > sideInfo.getSideTableInfo().getAsyncTimeoutNumLimit()){`
`149`		`- resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));`
`150`		`- } else {`
	`148`	`+ if(sideInfo.getJoinType() == JoinType.LEFT){`
`151`	`149`	`resultFuture.complete(null);`
	`150`	`+ return;`
	`151`	`+ }`
	`152`	`+ if(timeOutNum > sideInfo.getSideTableInfo().getAsyncFailMaxNum(Integer.MAX_VALUE)){`
	`153`	`+ resultFuture.completeExceptionally(new Exception("Async function call timedoutNum beyond limit."));`
	`154`	`+ return;`
`152`	`155`	`}`
	`156`	`+ resultFuture.complete(null);`
`153`	`157`	`}`
`154`	`158`
`155`	`159`	`protected void preInvoke(CRow input, ResultFuture<CRow> resultFuture){`