YinChunGuang commented on issue #19301:
URL: https://github.com/apache/hudi/issues/19301#issuecomment-4987773864
hoodie.properties
2026-07-16 03:08:08,235 INFO
org.apache.hudi.common.table.view.FileSystemViewManager [] - Creating View
Manager with storage type MEMORY.
2026-07-16 03:08:08,235 INFO
org.apache.hudi.keygen.constant.KeyGeneratorType [] - No key
generator type is set properly
2026-07-16 03:08:08,236 INFO
org.apache.hudi.common.table.log.HoodieLogFormat$WriterBuilder [] - Building
HoodieLogFormat Writer
2026-07-16 03:08:08,237 INFO
org.apache.hudi.common.table.log.HoodieLogFormat$WriterBuilder [] - Computing
the next log version for files-0000-0 in
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/files
2026-07-16 03:08:08,237 INFO
org.apache.hudi.common.table.log.HoodieLogFormat$WriterBuilder [] - Computed
the next log version for files-0000-0 in
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/files
as 1 with write-token 0-1-0
2026-07-16 03:08:08,237 INFO
org.apache.hudi.common.table.log.HoodieLogFormat$WriterBuilder [] -
HoodieLogFile on path
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/files/.files-0000-0_20260716025337008.log.1_0-1-0
2026-07-16 03:08:08,245 INFO
org.apache.hudi.table.marker.DirectWriteMarkers [] - [direct]
Created marker file
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/.temp/20260716025337008/files/.files-0000-0_20260716025337008.log.1_0-1-0.marker.CREATE
in 2 ms
2026-07-16 03:08:08,247 INFO
org.apache.hudi.common.table.log.HoodieLogFormatWriter [] - Created a new
log file:
HoodieLogFile{pathStr='hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/files/.files-0000-0_20260716025337008.log.1_0-1-0',
fileLen=0}
2026-07-16 03:08:08,329 INFO org.apache.hudi.io.HoodieAppendHandle
[] - AppendHandle for partitionPath files filePath
files/.files-0000-0_20260716025337008.log.1_0-1-0, took 93 ms.
2026-07-16 03:08:08,364 INFO org.apache.hudi.common.table.HoodieTableConfig
[] - Loading table properties from
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/hoodie.properties
2026-07-16 03:08:08,365 INFO org.apache.hudi.client.BaseHoodieWriteClient
[] - Committing 20260716025337008 action deltacommit
2026-07-16 03:08:08,367 INFO org.apache.hudi.common.table.HoodieTableConfig
[] - Loading table properties from
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/hoodie.properties
2026-07-16 03:08:08,368 INFO
org.apache.hudi.common.table.view.FileSystemViewManager [] - Creating View
Manager with storage type MEMORY.
2026-07-16 03:08:08,368 INFO org.apache.hudi.common.util.CommitUtils
[] - Creating metadata for UPSERT_PREPPED numWriteStats:1
numReplaceFileIds:0
2026-07-16 03:08:08,369 INFO org.apache.hudi.common.table.HoodieTableConfig
[] - Loading table properties from
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/hoodie.properties
2026-07-16 03:08:08,370 INFO
org.apache.hudi.common.table.view.FileSystemViewManager [] - Creating View
Manager with storage type MEMORY.
2026-07-16 03:08:08,371 INFO org.apache.hudi.client.BaseHoodieWriteClient
[] - Committing 20260716025337008 action deltacommit
2026-07-16 03:08:08,381 INFO
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2 [] -
Marking instant complete [==>20260716025337008__deltacommit__INFLIGHT]
2026-07-16 03:08:08,443 INFO
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2 [] -
Created new file for toInstant:
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/timeline/20260716025337008_20260716030808382.deltacommit
2026-07-16 03:08:08,444 INFO
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2 [] -
Completed [==>20260716025337008__deltacommit__INFLIGHT]
2026-07-16 03:08:08,447 INFO org.apache.hudi.common.fs.FSUtils
[] - Removed directory at
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/metadata/.hoodie/.temp/20260716025337008
2026-07-16 03:08:08,448 INFO org.apache.hudi.client.BaseHoodieWriteClient
[] - Committed 20260716025337008
2026-07-16 03:08:08,454 INFO
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2 [] -
Marking instant complete [==>20260716025337008__deltacommit__INFLIGHT]
2026-07-16 03:08:08,454 INFO
org.apache.hudi.client.transaction.TransactionManager [] - State change
ending for action instant
Option{val=[==>20260716025337008__deltacommit__INFLIGHT]}
2026-07-16 03:08:08,455 INFO
org.apache.hudi.client.transaction.lock.InProcessLockProvider [] - Base Path
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock,
Lock Instance java.util.concurrent.locks.ReentrantReadWriteLock@1efbc60b[Write
locks = 1, Read locks = 0], Thread meta-event-handle, In-process lock state
RELEASING
2026-07-16 03:08:08,455 INFO
org.apache.hudi.client.transaction.lock.InProcessLockProvider [] - Base Path
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock,
Lock Instance java.util.concurrent.locks.ReentrantReadWriteLock@1efbc60b[Write
locks = 0, Read locks = 0], Thread meta-event-handle, In-process lock state
RELEASED
2026-07-16 03:08:08,456 INFO
org.apache.hudi.client.transaction.lock.InProcessLockProvider [] - Base Path
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock,
Lock Instance java.util.concurrent.locks.ReentrantReadWriteLock@1efbc60b[Write
locks = 0, Read locks = 0], Thread meta-event-handle, In-process lock state
ALREADY_RELEASED
2026-07-16 03:08:08,456 INFO
org.apache.hudi.client.transaction.lock.LockManager [] - Released
connection created for acquiring lock
2026-07-16 03:08:08,456 INFO
org.apache.hudi.client.transaction.TransactionManager [] - State change
ended for action instant
Option{val=[==>20260716025337008__deltacommit__INFLIGHT]}
2026-07-16 03:08:08,457 INFO
org.apache.hudi.client.heartbeat.HoodieHeartbeatClient [] - Stopping
heartbeat for instant 20260716025337008
2026-07-16 03:08:08,457 INFO
org.apache.hudi.client.heartbeat.HoodieHeartbeatClient [] - Stopped
heartbeat for instant 20260716025337008
2026-07-16 03:08:08,458 INFO
org.apache.hudi.client.heartbeat.HeartbeatUtils [] - Deleted the
heartbeat for instant 20260716025337008
2026-07-16 03:08:08,459 INFO
org.apache.hudi.client.heartbeat.HoodieHeartbeatClient [] - Deleted
heartbeat file for instant 20260716025337008
2026-07-16 03:08:08,459 ERROR
org.apache.hudi.sink.StreamWriteOperatorCoordinator [] - Executor
executes action [commits the instant 20260716030800298] error
java.lang.IllegalArgumentException: File
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/timeline/20260716025337008.deltacommit.inflight
does not exist!
at
org.apache.hudi.common.util.ValidationUtils.checkArgument(ValidationUtils.java:42)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.transitionStateToComplete(ActiveTimelineV2.java:563)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:171)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:162)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:178)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commit(BaseHoodieWriteClient.java:321)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commitStats(BaseHoodieWriteClient.java:276)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commitStats(BaseHoodieWriteClient.java:244)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.HoodieFlinkWriteClient.commit(HoodieFlinkWriteClient.java:107)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.HoodieFlinkWriteClient.commit(HoodieFlinkWriteClient.java:74)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commit(BaseHoodieWriteClient.java:226)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.doCommit(StreamWriteOperatorCoordinator.java:617)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.commitInstant(StreamWriteOperatorCoordinator.java:602)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$commitInstants$10(StreamWriteOperatorCoordinator.java:557)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
~[?:1.8.0_281]
at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
~[?:1.8.0_281]
at
java.util.concurrent.ConcurrentSkipListMap$EntrySpliterator.forEachRemaining(ConcurrentSkipListMap.java:3535)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
~[?:1.8.0_281]
at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
~[?:1.8.0_281]
at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
~[?:1.8.0_281]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.commitInstants(StreamWriteOperatorCoordinator.java:557)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$notifyCheckpointComplete$3(StreamWriteOperatorCoordinator.java:299)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.utils.NonThrownExecutor.lambda$wrapAction$0(NonThrownExecutor.java:131)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
[?:1.8.0_281]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
[?:1.8.0_281]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_281]
2026-07-16 03:08:08,462 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - Trying to recover from a global failure.
org.apache.flink.util.FlinkException: Global failure triggered by
OperatorCoordinator for 'bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock'
(operator b754eda8ef527d9494a0b43e9bf7abf3).
at
org.apache.flink.runtime.operators.coordination.OperatorCoordinatorHolder$LazyInitializedCoordinatorContext.failJob(OperatorCoordinatorHolder.java:624)
~[flink-dist-1.18.1.jar:1.18.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$start$0(StreamWriteOperatorCoordinator.java:230)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.utils.NonThrownExecutor.handleException(NonThrownExecutor.java:143)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.utils.NonThrownExecutor.lambda$wrapAction$0(NonThrownExecutor.java:134)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
~[?:1.8.0_281]
at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
~[?:1.8.0_281]
at java.lang.Thread.run(Thread.java:748) ~[?:1.8.0_281]
Caused by: org.apache.hudi.exception.HoodieException: Executor executes
action [commits the instant 20260716030800298] error
... 6 more
Caused by: java.lang.IllegalArgumentException: File
hdfs://bipcluster/user/hive/warehouse/yuqi_oldetl_test.db/t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock/.hoodie/timeline/20260716025337008.deltacommit.inflight
does not exist!
at
org.apache.hudi.common.util.ValidationUtils.checkArgument(ValidationUtils.java:42)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.transitionStateToComplete(ActiveTimelineV2.java:563)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:171)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:162)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.common.table.timeline.versioning.v2.ActiveTimelineV2.saveAsComplete(ActiveTimelineV2.java:178)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commit(BaseHoodieWriteClient.java:321)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commitStats(BaseHoodieWriteClient.java:276)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commitStats(BaseHoodieWriteClient.java:244)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.HoodieFlinkWriteClient.commit(HoodieFlinkWriteClient.java:107)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.HoodieFlinkWriteClient.commit(HoodieFlinkWriteClient.java:74)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.client.BaseHoodieWriteClient.commit(BaseHoodieWriteClient.java:226)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.doCommit(StreamWriteOperatorCoordinator.java:617)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.commitInstant(StreamWriteOperatorCoordinator.java:602)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$commitInstants$10(StreamWriteOperatorCoordinator.java:557)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)
~[?:1.8.0_281]
at
java.util.stream.ReferencePipeline$2$1.accept(ReferencePipeline.java:175)
~[?:1.8.0_281]
at
java.util.concurrent.ConcurrentSkipListMap$EntrySpliterator.forEachRemaining(ConcurrentSkipListMap.java:3535)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:482)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:472)
~[?:1.8.0_281]
at
java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)
~[?:1.8.0_281]
at
java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)
~[?:1.8.0_281]
at
java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)
~[?:1.8.0_281]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.commitInstants(StreamWriteOperatorCoordinator.java:557)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.StreamWriteOperatorCoordinator.lambda$notifyCheckpointComplete$3(StreamWriteOperatorCoordinator.java:299)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
at
org.apache.hudi.sink.utils.NonThrownExecutor.lambda$wrapAction$0(NonThrownExecutor.java:131)
~[hudi-flink1.18-bundle-1.1.1.jar:1.1.1]
... 3 more
2026-07-16 03:08:08,463 INFO org.apache.flink.runtime.jobmaster.JobMaster
[] - 4 tasks will be restarted to recover from a global failure.
2026-07-16 03:08:08,464 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job
insert-into_hoodie_catalog.yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(a9775e03fcf62008b13b248ee8693bb9) switched from state RUNNING to RESTARTING.
2026-07-16 03:08:08,464 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
compact_plan_generate (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_2c190601d2e331d8fbe808700bcf6c4e_0_4)
switched from RUNNING to CANCELING.
2026-07-16 03:08:08,465 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - compact_task
-> Sink: compact_commit (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_edd9ec76dbb7cd545d93de35f574c84e_0_4)
switched from RUNNING to CANCELING.
2026-07-16 03:08:08,465 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
source_kafka_01[1] -> Calc[2] -> ConstraintEnforcer[3] ->
row_data_to_hoodie_record (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_cbc357ccb763df2852fee8c4fc7d55f2_0_4)
switched from RUNNING to CANCELING.
2026-07-16 03:08:08,465 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing
registered reader after failure for subtask 0 (#4) of source Source:
source_kafka_01[1].
2026-07-16 03:08:08,466 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(1/1) (f49a8f6332f3f91794ef2cae46a713ef_b754eda8ef527d9494a0b43e9bf7abf3_0_4)
switched from RUNNING to CANCELING.
2026-07-16 03:08:08,482 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
compact_plan_generate (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_2c190601d2e331d8fbe808700bcf6c4e_0_4)
switched from CANCELING to CANCELED.
2026-07-16 03:08:08,483 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - compact_task
-> Sink: compact_commit (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_edd9ec76dbb7cd545d93de35f574c84e_0_4)
switched from CANCELING to CANCELED.
2026-07-16 03:08:08,485 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(1/1) (f49a8f6332f3f91794ef2cae46a713ef_b754eda8ef527d9494a0b43e9bf7abf3_0_4)
switched from CANCELING to CANCELED.
2026-07-16 03:08:08,491 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
source_kafka_01[1] -> Calc[2] -> ConstraintEnforcer[3] ->
row_data_to_hoodie_record (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_cbc357ccb763df2852fee8c4fc7d55f2_0_4)
switched from CANCELING to CANCELED.
2026-07-16 03:08:08,492 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Clearing resource requirements of job a9775e03fcf62008b13b248ee8693bb9
2026-07-16 03:08:08,492 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedTaskManagerTracker
[] - Clear all pending allocations for job a9775e03fcf62008b13b248ee8693bb9.
2026-07-16 03:09:08,467 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job
insert-into_hoodie_catalog.yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(a9775e03fcf62008b13b248ee8693bb9) switched from state RESTARTING to RUNNING.
2026-07-16 03:09:08,468 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - Restoring job
a9775e03fcf62008b13b248ee8693bb9 from Checkpoint 76 @ 1784142480275 for
a9775e03fcf62008b13b248ee8693bb9 located at
hdfs://rtcluster/user/flink/checkpoints/a9775e03fcf62008b13b248ee8693bb9/chk-76.
2026-07-16 03:09:08,469 INFO
org.apache.flink.runtime.checkpoint.CheckpointCoordinator [] - No master
state to restore
2026-07-16 03:09:08,470 INFO
org.apache.flink.runtime.operators.coordination.RecreateOnResetOperatorCoordinator
[] - Resetting coordinator to checkpoint.
2026-07-16 03:09:08,471 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Closing
SourceCoordinator for source Source: source_kafka_01[1].
2026-07-16 03:09:08,473 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
source_kafka_01[1] -> Calc[2] -> ConstraintEnforcer[3] ->
row_data_to_hoodie_record (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_cbc357ccb763df2852fee8c4fc7d55f2_0_5)
switched from CREATED to SCHEDULED.
2026-07-16 03:09:08,473 INFO
org.apache.flink.kafka.shaded.org.apache.kafka.common.utils.AppInfoParser [] -
App info kafka.admin.client for
hudi-11-test-1-ym3_11_mem94-enumerator-admin-client unregistered
2026-07-16 03:09:08,473 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(1/1) (f49a8f6332f3f91794ef2cae46a713ef_b754eda8ef527d9494a0b43e9bf7abf3_0_5)
switched from CREATED to SCHEDULED.
2026-07-16 03:09:08,474 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] -
compact_plan_generate (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_2c190601d2e331d8fbe808700bcf6c4e_0_5)
switched from CREATED to SCHEDULED.
2026-07-16 03:09:08,474 INFO
org.apache.flink.kafka.shaded.org.apache.kafka.common.metrics.Metrics [] -
Metrics scheduler closed
2026-07-16 03:09:08,474 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - compact_task
-> Sink: compact_commit (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_edd9ec76dbb7cd545d93de35f574c84e_0_5)
switched from CREATED to SCHEDULED.
2026-07-16 03:09:08,475 INFO
org.apache.flink.kafka.shaded.org.apache.kafka.common.metrics.Metrics [] -
Closing reporter
org.apache.flink.kafka.shaded.org.apache.kafka.common.metrics.JmxReporter
2026-07-16 03:09:08,475 INFO
org.apache.flink.kafka.shaded.org.apache.kafka.common.metrics.Metrics [] -
Metrics reporters closed
2026-07-16 03:09:08,475 INFO
org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager []
- Received resource requirements from job a9775e03fcf62008b13b248ee8693bb9:
[ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN},
numberOfRequiredSlots=1}]
2026-07-16 03:09:08,476 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source
coordinator for source Source: source_kafka_01[1] closed.
2026-07-16 03:09:08,476 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source:
source_kafka_01[1] -> Calc[2] -> ConstraintEnforcer[3] ->
row_data_to_hoodie_record (1/1)
(f49a8f6332f3f91794ef2cae46a713ef_cbc357ccb763df2852fee8c4fc7d55f2_0_5)
switched from SCHEDULED to DEPLOYING.
2026-07-16 03:09:08,477 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
Source: source_kafka_01[1] -> Calc[2] -> ConstraintEnforcer[3] ->
row_data_to_hoodie_record (1/1) (attempt #5) with attempt id
f49a8f6332f3f91794ef2cae46a713ef_cbc357ccb763df2852fee8c4fc7d55f2_0_5 and
vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to
container_e05_1732503259026_5944_01_000002 @ b30107u10-72-227.bestpay.bd
(dataPort=11906) with allocation id 90793836ff4440d5a292b4c81d20355f
2026-07-16 03:09:08,477 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Restoring
SplitEnumerator of source Source: source_kafka_01[1] from checkpoint.
2026-07-16 03:09:08,477 INFO
org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Starting
split enumerator for source Source: source_kafka_01[1].
2026-07-16 03:09:08,477 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(1/1) (f49a8f6332f3f91794ef2cae46a713ef_b754eda8ef527d9494a0b43e9bf7abf3_0_5)
switched from SCHEDULED to DEPLOYING.
2026-07-16 03:09:08,478 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying
bucket_write:
yuqi_oldetl_test.t_info_instl_reservation_order_rtm11_chunguang_11_9_memlock
(1/1) (attempt #5) with attempt id
f49a8f6332f3f91794ef2cae46a713ef_b754eda8ef527d9494a0b43e9bf7abf3_0_5 and
vertex id b754eda8ef527d9494a0b43e9bf7abf3_0 to
container_e05_1732503259026_5944_01_000002 @ b30107u10-72-227.bestpay.bd
(dataPort=11906) with allocation id 90793836ff4440d5a292b4c81d20355f
2026-07-16 03:09:08,479 INFO
org.apache.flink.kafka.shaded.org.apache.kafka.clients.admin.AdminClientConfig
[] - AdminClientConfig values:
--
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]
