flink-jobmanager | 2024-09-13 17:00:00,907 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: t_f_unnested_sales[36] to checkpoint. flink-jobmanager | 2024-09-13 17:00:00,907 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from CREATED to SCHEDULED. flink-jobmanager | 2024-09-13 17:00:00,907 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from CREATED to SCHEDULED. flink-jobmanager | 2024-09-13 17:00:00,908 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:00,908 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Source: t_f_unnested_sales[36] (1/1) (attempt #395) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395 and vertex id bc764cd8ddf7a0cff126f51c16239658_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-taskmanager-2 | 2024-09-13 17:00:00,910 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-jobmanager | 2024-09-13 17:00:00,909 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:00,909 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Writer : t_unnested_sales (1/1) (attempt #395) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395 and vertex id ddb598ad156ed281023ba4eebbe487e3_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-jobmanager | 2024-09-13 17:00:00,909 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:00,909 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Global Committer : t_unnested_sales (1/1) (attempt #395) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395 and vertex id 46f8730428df9ecd6d7318a02bdc405e_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-taskmanager-2 | 2024-09-13 17:00:00,910 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:00,910 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) [DEPLOYING]. flink-taskmanager-2 | 2024-09-13 17:00:00,912 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:00,913 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:00,914 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: t_f_unnested_sales[36] registering reader for parallel task 0 (#395) @ 172.19.0.17 flink-jobmanager | 2024-09-13 17:00:00,915 INFO org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator [] - Assigning splits to readers {0=[[Partition: t_f_unnested_sales-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]]} flink-taskmanager-2 | 2024-09-13 17:00:00,915 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:00,915 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-jobmanager | 2024-09-13 17:00:00,916 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:00,917 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:00,918 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-taskmanager-2 | 2024-09-13 17:00:00,918 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) [DEPLOYING]. flink-taskmanager-2 | 2024-09-13 17:00:00,920 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:00,920 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) [DEPLOYING]. flink-taskmanager-2 | 2024-09-13 17:00:00,921 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:00,922 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from DEPLOYING to INITIALIZING. flink-taskmanager-2 | 2024-09-13 17:00:00,924 INFO org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Adding split(s) to reader: [[Partition: t_f_unnested_sales-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]] flink-taskmanager-2 | 2024-09-13 17:00:00,924 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:00,925 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from DEPLOYING to INITIALIZING. flink-taskmanager-2 | 2024-09-13 17:00:00,928 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.KafkaConsumer [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Assigned to partition(s): t_f_unnested_sales-0 flink-taskmanager-2 | 2024-09-13 17:00:00,928 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.SubscriptionState [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Seeking to earliest offset of partition t_f_unnested_sales-0 flink-taskmanager-2 | 2024-09-13 17:00:00,928 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from INITIALIZING to RUNNING. flink-jobmanager | 2024-09-13 17:00:00,930 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:00,930 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.Metadata [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Resetting the last seen epoch of partition t_f_unnested_sales-0 to 0 since the associated topicId changed from null to H-rFaNXTQH2om8AK9srIVw flink-taskmanager-2 | 2024-09-13 17:00:00,932 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.SubscriptionState [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Resetting offset for partition t_f_unnested_sales-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker:29092 (id: 1 rack: null)], epoch=0}}. flink-taskmanager-2 | 2024-09-13 17:00:00,932 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from INITIALIZING to RUNNING. flink-jobmanager | 2024-09-13 17:00:00,932 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:01,026 WARN org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from RUNNING to FAILED with failure cause: flink-taskmanager-2 | 2024-09-13 17:00:01,026 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Writer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,027 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state FAILED to JobManager for task Writer : t_unnested_sales (1/1)#395 a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395. flink-jobmanager | 2024-09-13 17:00:01,028 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_395) switched from RUNNING to FAILED on 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579). flink-jobmanager | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from RUNNING to CANCELING. flink-jobmanager | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#395) of source Source: t_f_unnested_sales[36]. flink-jobmanager | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:01,029 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,030 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,030 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:01,030 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,030 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from CANCELING to CANCELED. flink-taskmanager-2 | 2024-09-13 17:00:01,030 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Global Committer : t_unnested_sales (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,031 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from CANCELING to CANCELED. flink-taskmanager-2 | 2024-09-13 17:00:01,031 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: t_f_unnested_sales[36] (1/1)#395 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395). flink-taskmanager-2 | 2024-09-13 17:00:01,032 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Global Committer : t_unnested_sales (1/1)#395 a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395. flink-taskmanager-2 | 2024-09-13 17:00:01,033 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Source: t_f_unnested_sales[36] (1/1)#395 a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395. flink-jobmanager | 2024-09-13 17:00:01,033 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_395) switched from CANCELING to CANCELED. flink-jobmanager | 2024-09-13 17:00:01,034 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_395) switched from CANCELING to CANCELED. flink-jobmanager | 2024-09-13 17:00:02,032 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: t_f_unnested_sales[36] to checkpoint. flink-jobmanager | 2024-09-13 17:00:02,032 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from CREATED to SCHEDULED. flink-jobmanager | 2024-09-13 17:00:02,032 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from CREATED to SCHEDULED. flink-jobmanager | 2024-09-13 17:00:02,032 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from CREATED to SCHEDULED. flink-jobmanager | 2024-09-13 17:00:02,033 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:02,033 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Source: t_f_unnested_sales[36] (1/1) (attempt #396) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396 and vertex id bc764cd8ddf7a0cff126f51c16239658_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-jobmanager | 2024-09-13 17:00:02,034 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:02,034 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Writer : t_unnested_sales (1/1) (attempt #396) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396 and vertex id ddb598ad156ed281023ba4eebbe487e3_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-jobmanager | 2024-09-13 17:00:02,035 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from SCHEDULED to DEPLOYING. flink-jobmanager | 2024-09-13 17:00:02,035 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Deploying Global Committer : t_unnested_sales (1/1) (attempt #396) with attempt id a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396 and vertex id 46f8730428df9ecd6d7318a02bdc405e_0 to 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579) with allocation id 383e3fa04b1c26922c70cd1faab75cc9 flink-taskmanager-2 | 2024-09-13 17:00:02,037 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-taskmanager-2 | 2024-09-13 17:00:02,038 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:02,038 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) [DEPLOYING]. flink-taskmanager-2 | 2024-09-13 17:00:02,039 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:02,041 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:02,042 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: t_f_unnested_sales[36] registering reader for parallel task 0 (#396) @ 172.19.0.17 flink-jobmanager | 2024-09-13 17:00:02,043 INFO org.apache.flink.connector.kafka.source.enumerator.KafkaSourceEnumerator [] - Assigning splits to readers {0=[[Partition: t_f_unnested_sales-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]]} flink-taskmanager-2 | 2024-09-13 17:00:02,042 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:02,043 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-jobmanager | 2024-09-13 17:00:02,044 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:02,044 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:02,044 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) [DEPLOYING]. flink-taskmanager-2 | 2024-09-13 17:00:02,045 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from DEPLOYING to INITIALIZING. flink-taskmanager-2 | 2024-09-13 17:00:02,045 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396), deploy into slot with allocation id 383e3fa04b1c26922c70cd1faab75cc9. flink-taskmanager-2 | 2024-09-13 17:00:02,045 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from CREATED to DEPLOYING. flink-taskmanager-2 | 2024-09-13 17:00:02,045 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) [DEPLOYING]. flink-jobmanager | 2024-09-13 17:00:02,045 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from DEPLOYING to INITIALIZING. flink-taskmanager-2 | 2024-09-13 17:00:02,046 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from DEPLOYING to INITIALIZING. flink-jobmanager | 2024-09-13 17:00:02,047 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from DEPLOYING to INITIALIZING. flink-taskmanager-2 | 2024-09-13 17:00:02,048 INFO org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from INITIALIZING to RUNNING. flink-jobmanager | 2024-09-13 17:00:02,048 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:02,050 INFO org.apache.flink.connector.base.source.reader.SourceReaderBase [] - Adding split(s) to reader: [[Partition: t_f_unnested_sales-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]] flink-taskmanager-2 | 2024-09-13 17:00:02,052 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.KafkaConsumer [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Assigned to partition(s): t_f_unnested_sales-0 flink-taskmanager-2 | 2024-09-13 17:00:02,053 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.SubscriptionState [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Seeking to earliest offset of partition t_f_unnested_sales-0 flink-taskmanager-2 | 2024-09-13 17:00:02,054 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.Metadata [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Resetting the last seen epoch of partition t_f_unnested_sales-0 to 0 since the associated topicId changed from null to H-rFaNXTQH2om8AK9srIVw flink-taskmanager-2 | 2024-09-13 17:00:02,056 INFO org.apache.flink.kafka.shaded.org.apache.kafka.clients.consumer.internals.SubscriptionState [] - [Consumer clientId=mysqlcdcsourced-0, groupId=mysqlcdcsourced] Resetting offset for partition t_f_unnested_sales-0 to position FetchPosition{offset=0, offsetEpoch=Optional.empty, currentLeader=LeaderAndEpoch{leader=Optional[broker:29092 (id: 1 rack: null)], epoch=0}}. flink-taskmanager-2 | 2024-09-13 17:00:02,056 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from INITIALIZING to RUNNING. flink-jobmanager | 2024-09-13 17:00:02,057 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from INITIALIZING to RUNNING. flink-taskmanager-2 | 2024-09-13 17:00:02,118 WARN org.apache.flink.runtime.taskmanager.Task [] - Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from RUNNING to FAILED with failure cause: flink-taskmanager-2 | 2024-09-13 17:00:02,118 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Writer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,118 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state FAILED to JobManager for task Writer : t_unnested_sales (1/1)#396 a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396. flink-jobmanager | 2024-09-13 17:00:02,119 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Writer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_ddb598ad156ed281023ba4eebbe487e3_0_396) switched from RUNNING to FAILED on 172.19.0.17:35723-c7a555 @ devlab-flink-taskmanager-2.devlab (dataPort=37579). flink-jobmanager | 2024-09-13 17:00:02,120 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from RUNNING to CANCELING. flink-jobmanager | 2024-09-13 17:00:02,120 INFO org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#396) of source Source: t_f_unnested_sales[36]. flink-jobmanager | 2024-09-13 17:00:02,120 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from RUNNING to CANCELING. flink-taskmanager-2 | 2024-09-13 17:00:02,121 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,122 INFO org.apache.flink.runtime.taskmanager.Task [] - Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from CANCELING to CANCELED. flink-taskmanager-2 | 2024-09-13 17:00:02,122 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Global Committer : t_unnested_sales (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,122 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from CANCELING to CANCELED. flink-taskmanager-2 | 2024-09-13 17:00:02,122 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: t_f_unnested_sales[36] (1/1)#396 (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396). flink-taskmanager-2 | 2024-09-13 17:00:02,124 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Global Committer : t_unnested_sales (1/1)#396 a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396. flink-taskmanager-2 | 2024-09-13 17:00:02,124 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Source: t_f_unnested_sales[36] (1/1)#396 a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396. flink-jobmanager | 2024-09-13 17:00:02,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Global Committer : t_unnested_sales (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_46f8730428df9ecd6d7318a02bdc405e_0_396) switched from CANCELING to CANCELED. flink-jobmanager | 2024-09-13 17:00:02,125 INFO org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Source: t_f_unnested_sales[36] (1/1) (a01dd1a3fa5c383a60b51b2eaebd1012_bc764cd8ddf7a0cff126f51c16239658_0_396) switched from CANCELING to CANCELED.