pengxianzi commented on issue #12585:
URL: https://github.com/apache/hudi/issues/12585#issuecomment-2576671851
@danny0405 The error is as follows：
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - split_reader ->
Sink:Unnamed(1/1) switched from INITIALIZING to FAILED on container_e30_xxx
FAILED
Wicht Failure causes: org.apache.hudit.exception.HoodsException: Get
render error for path:
hdfs://node1/XXXXX.parquet
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.getBaseFileIteratorWithMetadata(MergeOnReadInputFormat.java:315)
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.initIterator(MergeOnReadInputFormat.java:230)
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.open(MergeOnReadInputFormat.java:189)
at
org.apache.hudi.source.StreamReadOperator.processSplit(StreamReadOperator.java:169)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailbox(MailboxProcessor.java:359)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:323)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeUserCode(StreamTask.java:565)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:587)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job switched
from state RUNNING to FAILED
Wicht Failure causes: org.apache.hudit.exception.HoodsException: Get
render error for path:
hdfs://node1/XXXXX.parquet
at
org.apache.hudit.table.format_nor.MergeOnNeedInputFormat.getBaseFileTerrorWithMetadata(MergeOnNeedInputFormat.java:315)
at
org.apache.hudit.table.format_nor.MergeOnNeedInputFormat.initTerror(WergeOnNeedInputFormat.java:230)
at
org.apache.hudit.table.format_nor.MergeOnNeedInputFormat.open(MergeOnNeedInputFormat.java:159)
at
org.apache.flink.source.StreamHeadOperator.procesSqlite(StreamHeadOperator.java:169)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50))
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:50)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.procesmMail&WhenDefaultActionNewsTable[MeilBoxProcessor.java:244]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.procesmMail(MailboxProcessor.java:330)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailDownload(pMailboxProcessor.java:202)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:65)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:456)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMtbtCleanUpOnFail(StreamTask.java:647)
at org.apache.flink.runtime.tasks.StreamTask.Invoke(StreamTask.java:620)
at org.apache.flink.runtime.taskmanager.Tab1.Column(Task.java:575)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
org.apache.flink.runtime.JobException: Recovery is suppressed by
FixedDelayRestartBackoffTimeStrategy(maxNumberRestartAttempts=3,
backoffTimeMs=60000)
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:216)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:206)
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:197)
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:682)
at
org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79)
at
org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435)
at sun.reflect.GeneratedMethodAccessor63.invoke(Unknown Source)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:492)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212)
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77)
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala)
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala)
at scala.PartialFunction.applyOrElse(PartialFunction.scala)
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala)
Caused by: org.apache.hudi.exception.HoodieException: Get reader error
for path:
hdfs://node1/XXXX.parquet
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.getBaseFileIteratorWithMetadata(MergeOnReadInputFormat.java:315)
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.initIterator(MergeOnReadInputFormat.java:230)
at
org.apache.hudi.table.format.mor.MergeOnReadInputFormat.open(MergeOnReadInputFormat.java:189)
at
org.apache.hudi.source.StreamReadOperator.processSplit(StreamReadOperator.java:169)
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
at
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailbox(MailboxProcessor.java:359)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:323)
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.executeUserCode(StreamTask.java:565)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:647)
at
org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:587)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:759)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
at java.lang.Thread.run(Thread.java:748)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
