Skip to content

Commit bdaecef

Browse files
committed
fix async timeout 问题
1 parent 7dbad64 commit bdaecef

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

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

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -119,14 +119,7 @@ protected void dealCacheData(String key, CacheObj missKeyObj) {
119119

120120
@Override
121121
public void timeout(Row input, ResultFuture<Row> resultFuture) throws Exception {
122-
StreamRecordQueueEntry<Row> future = (StreamRecordQueueEntry<Row>)resultFuture;
123-
try {
124-
if (null == future.get()) {
125-
resultFuture.completeExceptionally(new TimeoutException("Async function call has timed out."));
126-
}
127-
} catch (Exception e) {
128-
resultFuture.completeExceptionally(new Exception(e));
129-
}
122+
resultFuture.completeExceptionally(new TimeoutException("Async function call has timed out. input:" + input.toString()));
130123
}
131124

132125

0 commit comments

Comments
 (0)