[
https://issues.apache.org/jira/browse/HUDI-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
gejin updated HUDI-9041:
------------------------
Summary: fix timeout while waiting for instant initialize exception while
flink job recovered from checkpoint (was: fix timeout while waiting for
instant initialize exception while flink job recovry from checkpoint )
> fix timeout while waiting for instant initialize exception while flink job
> recovered from checkpoint
> -----------------------------------------------------------------------------------------------------
>
> Key: HUDI-9041
> URL: https://issues.apache.org/jira/browse/HUDI-9041
> Project: Apache Hudi
> Issue Type: Bug
> Reporter: gejin
> Priority: Trivial
> Labels: flink
> Fix For: 0.15.1
>
>
>
> {code:java}
> //代码占位符#12820
> org.apache.hudi.exception.HoodieException: Timeout(121000ms) while waiting
> for instant initialize
> at org.apache.hudi.sink.utils.TimeWait.waitFor(TimeWait.java:57)
> at
> org.apache.hudi.sink.common.AbstractStreamWriteFunction.instantToWrite(AbstractStreamWriteFunction.java:269)
> at
> org.apache.hudi.sink.append.AppendWriteFunction.initWriterHelper(AppendWriteFunction.java:125)
> at
> org.apache.hudi.sink.append.AppendWriteFunction.processElement(AppendWriteFunction.java:84)
> at
> org.apache.flink.streaming.api.operators.ProcessOperator.processElement(ProcessOperator.java:66)
> at
> org.apache.flink.streaming.runtime.tasks.OneInputStreamTask$StreamTaskNetworkOutput.emitRecord(OneInputStreamTask.java:233)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.processElement(AbstractStreamTaskNetworkInput.java:134)
> at
> org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:105)
> at
> org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:546)
> at
> org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:837)
> at
> org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:786)
> at
> org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935)
> at
> org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:914)
> at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728)
> at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550)
> at java.lang.Thread.run(Thread.java:750) {code}
> Reusing the timeline recovered from the checkpoint did not unblock writing
> tasks, resulting in the Flink task getting stuck.
>
> detail: [issue#12820|https://github.com/apache/hudi/issues/12820]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
