Aload commented on issue #5720:
URL: https://github.com/apache/hudi/issues/5720#issuecomment-1141724366
java.io.IOException: Could not perform checkpoint 1 for operator
stream_write (3/12)#0.
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1274)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:147)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierTracker.triggerCheckpointOnAligned(CheckpointBarrierTracker.java:301)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierTracker.processBarrier(CheckpointBarrierTracker.java:141)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.handleEvent(CheckpointedInputGate.java:181)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:159)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:110)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
~[anso-process-0.0.1.jar:?]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
~[anso-process-0.0.1.jar:?]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
~[anso-process-0.0.1.jar:?]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Could
not complete snapshot 1 for operator stream_write (3/12)#0. Failure reason:
Checkpoint was declined.
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:265)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
... 16 more
Caused by: org.apache.hudi.exception.HoodieRemoteException: 10.0.20.53:46302
failed to respond
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.refresh(RemoteHoodieTableFileSystemView.java:420)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.sync(RemoteHoodieTableFileSystemView.java:484)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.PriorityBasedFileSystemView.sync(PriorityBasedFileSystemView.java:257)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1470)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1496)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.HoodieFlinkWriteClient.upsert(HoodieFlinkWriteClient.java:140)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$initWriteFunction$1(StreamWriteFunction.java:184)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$flushRemaining$7(StreamWriteFunction.java:461)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608)
~[?:1.8.0_181]
at
org.apache.hudi.sink.StreamWriteFunction.flushRemaining(StreamWriteFunction.java:454)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.snapshotState(StreamWriteFunction.java:131)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.common.AbstractStreamWriteFunction.snapshotState(AbstractStreamWriteFunction.java:157)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.trySnapshotFunctionState(StreamingFunctionUtils.java:118)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.snapshotFunctionState(StreamingFunctionUtils.java:99)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.snapshotState(AbstractUdfStreamOperator.java:87)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:219)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
... 16 more
Caused by: org.apache.http.NoHttpResponseException: 10.0.20.53:46302 failed
to respond
at
org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:143)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:57)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:261)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:165)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:167)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:272)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:124)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:271)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:184)
~[anso-process-0.0.1.jar:?]
at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:55)
~[anso-process-0.0.1.jar:?]
at org.apache.http.client.fluent.Request.execute(Request.java:151)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.executeRequest(RemoteHoodieTableFileSystemView.java:176)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.refresh(RemoteHoodieTableFileSystemView.java:418)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.sync(RemoteHoodieTableFileSystemView.java:484)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.PriorityBasedFileSystemView.sync(PriorityBasedFileSystemView.java:257)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1470)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1496)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.HoodieFlinkWriteClient.upsert(HoodieFlinkWriteClient.java:140)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$initWriteFunction$1(StreamWriteFunction.java:184)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$flushRemaining$7(StreamWriteFunction.java:461)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608)
~[?:1.8.0_181]
at
org.apache.hudi.sink.StreamWriteFunction.flushRemaining(StreamWriteFunction.java:454)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.snapshotState(StreamWriteFunction.java:131)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.common.AbstractStreamWriteFunction.snapshotState(AbstractStreamWriteFunction.java:157)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.trySnapshotFunctionState(StreamingFunctionUtils.java:118)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.snapshotFunctionState(StreamingFunctionUtils.java:99)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.snapshotState(AbstractUdfStreamOperator.java:87)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:219)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
... 16 more
2022-05-31 14:03:23,689 WARN
org.apache.hudi.sink.StreamWriteOperatorCoordinator [] - Reset the
event for task [2]
java.io.IOException: Could not perform checkpoint 1 for operator
stream_write (3/12)#0.
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1274)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierHandler.notifyCheckpoint(CheckpointBarrierHandler.java:147)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierTracker.triggerCheckpointOnAligned(CheckpointBarrierTracker.java:301)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointBarrierTracker.processBarrier(CheckpointBarrierTracker.java:141)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.handleEvent(CheckpointedInputGate.java:181)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.checkpointing.CheckpointedInputGate.pollNext(CheckpointedInputGate.java:159)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.AbstractStreamTaskNetworkInput.emitNext(AbstractStreamTaskNetworkInput.java:110)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:496)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:203)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:809)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:761)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:958)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:937)
~[anso-process-0.0.1.jar:?]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:766)
~[anso-process-0.0.1.jar:?]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575)
~[anso-process-0.0.1.jar:?]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_181]
Caused by: org.apache.flink.runtime.checkpoint.CheckpointException: Could
not complete snapshot 1 for operator stream_write (3/12)#0. Failure reason:
Checkpoint was declined.
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:265)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
... 16 more
Caused by: org.apache.hudi.exception.HoodieRemoteException: 10.0.20.53:46302
failed to respond
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.refresh(RemoteHoodieTableFileSystemView.java:420)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.sync(RemoteHoodieTableFileSystemView.java:484)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.PriorityBasedFileSystemView.sync(PriorityBasedFileSystemView.java:257)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1470)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1496)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.HoodieFlinkWriteClient.upsert(HoodieFlinkWriteClient.java:140)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$initWriteFunction$1(StreamWriteFunction.java:184)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$flushRemaining$7(StreamWriteFunction.java:461)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608)
~[?:1.8.0_181]
at
org.apache.hudi.sink.StreamWriteFunction.flushRemaining(StreamWriteFunction.java:454)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.snapshotState(StreamWriteFunction.java:131)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.common.AbstractStreamWriteFunction.snapshotState(AbstractStreamWriteFunction.java:157)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.trySnapshotFunctionState(StreamingFunctionUtils.java:118)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.snapshotFunctionState(StreamingFunctionUtils.java:99)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.snapshotState(AbstractUdfStreamOperator.java:87)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:219)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
... 16 more
Caused by: org.apache.http.NoHttpResponseException: 10.0.20.53:46302 failed
to respond
at
org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:143)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.conn.DefaultHttpResponseParser.parseHead(DefaultHttpResponseParser.java:57)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.io.AbstractMessageParser.parse(AbstractMessageParser.java:261)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.DefaultBHttpClientConnection.receiveResponseHeader(DefaultBHttpClientConnection.java:165)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.conn.CPoolProxy.receiveResponseHeader(CPoolProxy.java:167)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.protocol.HttpRequestExecutor.doReceiveResponse(HttpRequestExecutor.java:272)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.protocol.HttpRequestExecutor.execute(HttpRequestExecutor.java:124)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.MainClientExec.execute(MainClientExec.java:271)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.ProtocolExec.execute(ProtocolExec.java:184)
~[anso-process-0.0.1.jar:?]
at org.apache.http.impl.execchain.RetryExec.execute(RetryExec.java:88)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.execchain.RedirectExec.execute(RedirectExec.java:110)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.InternalHttpClient.doExecute(InternalHttpClient.java:184)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:82)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:107)
~[anso-process-0.0.1.jar:?]
at
org.apache.http.impl.client.CloseableHttpClient.execute(CloseableHttpClient.java:55)
~[anso-process-0.0.1.jar:?]
at org.apache.http.client.fluent.Request.execute(Request.java:151)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.executeRequest(RemoteHoodieTableFileSystemView.java:176)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.refresh(RemoteHoodieTableFileSystemView.java:418)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.RemoteHoodieTableFileSystemView.sync(RemoteHoodieTableFileSystemView.java:484)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.common.table.view.PriorityBasedFileSystemView.sync(PriorityBasedFileSystemView.java:257)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1470)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.BaseHoodieWriteClient.initTable(BaseHoodieWriteClient.java:1496)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.client.HoodieFlinkWriteClient.upsert(HoodieFlinkWriteClient.java:140)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$initWriteFunction$1(StreamWriteFunction.java:184)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.lambda$flushRemaining$7(StreamWriteFunction.java:461)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at java.util.LinkedHashMap$LinkedValues.forEach(LinkedHashMap.java:608)
~[?:1.8.0_181]
at
org.apache.hudi.sink.StreamWriteFunction.flushRemaining(StreamWriteFunction.java:454)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.StreamWriteFunction.snapshotState(StreamWriteFunction.java:131)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.hudi.sink.common.AbstractStreamWriteFunction.snapshotState(AbstractStreamWriteFunction.java:157)
~[hudi-flink1.14-bundle_2.12-0.11.0.jar:0.11.0]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.trySnapshotFunctionState(StreamingFunctionUtils.java:118)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.util.functions.StreamingFunctionUtils.snapshotFunctionState(StreamingFunctionUtils.java:99)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.snapshotState(AbstractUdfStreamOperator.java:87)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:219)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.StreamOperatorStateHandler.snapshotState(StreamOperatorStateHandler.java:170)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.api.operators.AbstractStreamOperator.snapshotState(AbstractStreamOperator.java:348)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.checkpointStreamOperator(RegularOperatorChain.java:233)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.buildOperatorSnapshotFutures(RegularOperatorChain.java:206)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.snapshotState(RegularOperatorChain.java:186)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.takeSnapshotSync(SubtaskCheckpointCoordinatorImpl.java:605)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.checkpointState(SubtaskCheckpointCoordinatorImpl.java:315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$performCheckpoint$14(StreamTask.java:1329)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.performCheckpoint(StreamTask.java:1315)
~[anso-process-0.0.1.jar:?]
at
org.apache.flink.streaming.runtime.tasks.StreamTask.triggerCheckpointOnBarrier(StreamTask.java:1258)
~[anso-process-0.0.1.jar:?]
--
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]
