Hi ,
I am facing the below issue while processing streaming events. In what
scenarios hit with java.lang.Exception: Could not complete the stream
element. can please help me here . The job fails after this exception is hit
2021-07-13 13:24:58,781 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph
[] - ExtractTransformProcess -> AsyncFetch (9/60)
(3809c73da162e9ab3b7b131077aff105) switched from RUNNING to FAILED on
container_e3767_1626191679189_5049_01 _000003 @ brdn6162.target.com
(dataPort=41107).
java.lang.Exception: Could not complete the stream element: Record @
1626200691540 : ({<it displays the record>})
at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator$ResultHandler.completeExceptionally(AsyncWaitOperator.java:363)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.api.functions.async.AsyncFunction.timeout(AsyncFunction.java:97)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.api.operators.async.AsyncWaitOperator.lambda$processElement$0(AsyncWaitOperator.java:190)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invokeProcessingTimeCallback(StreamTask.java:1223)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$null$16(StreamTask.java:1214)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:47)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:78)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:301)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:183)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:569)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:534)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:721)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:546)
~[appspayload-decoupleHbaseWrite-1.0-SNAPSHOT-all.jar:?]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_252]
Caused by: java.util.concurrent.TimeoutException: Async function call has
timed out.
Thanks & regards
