超时数据处理==>返回null,并记录日志

Author: zoudaokoulife

core/src/main/java/com/dtstack/flink/sql/side/AsyncReqRow.java

@@ -128,6 +128,7 @@ public void timeout(Row input, ResultFuture<Row> resultFuture) throws Exception
             LOG.info("Async function call has timed out. input:" + input.toString());
         }
 
+        timeOutNum++;
         resultFuture.complete(null);
     }