[
https://issues.apache.org/jira/browse/HUDI-9041?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
gejin updated HUDI-9041:
------------------------
Description:
{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: [[|https://github.com//apache/hudi/issues/12820]
[issue#12820|https://github.com//apache/hudi/issues/12820]
[|https://github.com/apache/hudi/issues/12820]|https://github.com//apache/hudi/issues/12820]
was:
{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]
> fix timeout while waiting for instant initialize exception while flink job
> recovry 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: [[|https://github.com//apache/hudi/issues/12820]
> [issue#12820|https://github.com//apache/hudi/issues/12820]
> [|https://github.com/apache/hudi/issues/12820]|https://github.com//apache/hudi/issues/12820]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
