读取 postgres 数据库的时候，读着读着就开始 Attempting to cancel task Source

[guziwen-lab]

我该如何排查问题？

这是日志

2023-06-01 17:24:36,321 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Snapshot step 6 - Persisting schema history
2023-06-01 17:24:36,337 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Snapshot step 7 - Snapshotting data
2023-06-01 17:24:36,338 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Snapshotting contents of 3225 tables while still in transaction
2023-06-01 17:24:36,338 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110000' (1 of 3225 tables)
2023-06-01 17:24:36,338 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110000' using select statement: 'SELECT * FROM "public"."cxsy_part_110000"'
2023-06-01 17:24:36,479 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 1 records for table 'public.cxsy_part_110000'; total duration '00:00:00.138'
2023-06-01 17:24:36,479 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110101' (2 of 3225 tables)
2023-06-01 17:24:36,479 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110101' using select statement: 'SELECT * FROM "public"."cxsy_part_110101"'
2023-06-01 17:24:37,400 INFO io.debezium.connector.common.BaseSourceTask [] - 873 records sent during previous 00:21:32.166, last recorded offset: {last_snapshot_record=false, lsn=62713233408, txId=26140, ts_usec=1685611477398000, snapshot=true}
2023-06-01 17:24:37,406 INFO com.ververica.cdc.debezium.internal.DebeziumChangeFetcher [] - Database snapshot phase can't perform checkpoint, acquired Checkpoint lock.
2023-06-01 17:24:37,419 INFO com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.json.JsonConverterConfig [] - JsonConverterConfig values:
converter.type = value
decimal.format = BASE64
schemas.cache.size = 1000
schemas.enable = false

2023-06-01 17:24:47,633 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 71680 records for table 'public.cxsy_part_110101' after 00:00:11.154
2023-06-01 17:24:57,634 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 141747 records for table 'public.cxsy_part_110101' after 00:00:21.155
2023-06-01 17:25:07,635 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 222182 records for table 'public.cxsy_part_110101' after 00:00:31.156
2023-06-01 17:25:17,636 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 306252 records for table 'public.cxsy_part_110101' after 00:00:41.157
2023-06-01 17:25:27,637 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 381758 records for table 'public.cxsy_part_110101' after 00:00:51.158
2023-06-01 17:25:37,638 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 459639 records for table 'public.cxsy_part_110101' after 00:01:01.159
2023-06-01 17:25:47,639 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 526457 records for table 'public.cxsy_part_110101' after 00:01:11.16
2023-06-01 17:25:57,640 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 584711 records for table 'public.cxsy_part_110101' after 00:01:21.161
2023-06-01 17:26:07,641 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 650044 records for table 'public.cxsy_part_110101' after 00:01:31.162
2023-06-01 17:26:17,642 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 715238 records for table 'public.cxsy_part_110101' after 00:01:41.163
2023-06-01 17:26:27,643 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 775801 records for table 'public.cxsy_part_110101' after 00:01:51.164
2023-06-01 17:26:37,644 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 832623 records for table 'public.cxsy_part_110101' after 00:02:01.165
2023-06-01 17:26:47,648 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 899093 records for table 'public.cxsy_part_110101' after 00:02:11.167
2023-06-01 17:26:58,252 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 962560 records for table 'public.cxsy_part_110101' after 00:02:21.773
2023-06-01 17:27:08,256 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1031048 records for table 'public.cxsy_part_110101' after 00:02:31.775
2023-06-01 17:27:18,402 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1095680 records for table 'public.cxsy_part_110101' after 00:02:41.922
2023-06-01 17:27:28,403 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1162113 records for table 'public.cxsy_part_110101' after 00:02:51.924
2023-06-01 17:27:38,965 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1228800 records for table 'public.cxsy_part_110101' after 00:03:02.485
2023-06-01 17:27:48,966 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1291188 records for table 'public.cxsy_part_110101' after 00:03:12.487
2023-06-01 17:27:59,468 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1361920 records for table 'public.cxsy_part_110101' after 00:03:22.988
2023-06-01 17:28:09,469 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1431302 records for table 'public.cxsy_part_110101' after 00:03:32.99
2023-06-01 17:28:19,470 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1500963 records for table 'public.cxsy_part_110101' after 00:03:42.991
2023-06-01 17:28:29,471 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1569766 records for table 'public.cxsy_part_110101' after 00:03:52.992
2023-06-01 17:28:39,472 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1640681 records for table 'public.cxsy_part_110101' after 00:04:02.993
2023-06-01 17:28:49,473 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1707357 records for table 'public.cxsy_part_110101' after 00:04:12.994
2023-06-01 17:28:59,994 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1771520 records for table 'public.cxsy_part_110101' after 00:04:23.515
2023-06-01 17:29:05,690 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 1812292 records for table 'public.cxsy_part_110101'; total duration '00:04:29.21'
2023-06-01 17:29:05,690 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110102' (3 of 3225 tables)
2023-06-01 17:29:05,691 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110102' using select statement: 'SELECT * FROM "public"."cxsy_part_110102"'
2023-06-01 17:29:16,822 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 71680 records for table 'public.cxsy_part_110102' after 00:00:11.131
2023-06-01 17:29:27,421 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 133120 records for table 'public.cxsy_part_110102' after 00:00:21.731
2023-06-01 17:29:37,600 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 194560 records for table 'public.cxsy_part_110102' after 00:00:31.909
2023-06-01 17:29:47,812 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 256000 records for table 'public.cxsy_part_110102' after 00:00:42.122
2023-06-01 17:29:57,994 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 317440 records for table 'public.cxsy_part_110102' after 00:00:52.304
2023-06-01 17:30:07,996 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 381294 records for table 'public.cxsy_part_110102' after 00:01:02.306
2023-06-01 17:30:17,997 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 446175 records for table 'public.cxsy_part_110102' after 00:01:12.307
2023-06-01 17:30:28,530 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 512000 records for table 'public.cxsy_part_110102' after 00:01:22.84
2023-06-01 17:30:38,531 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 581213 records for table 'public.cxsy_part_110102' after 00:01:32.841
2023-06-01 17:30:48,532 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 645112 records for table 'public.cxsy_part_110102' after 00:01:42.842
2023-06-01 17:30:58,791 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 706560 records for table 'public.cxsy_part_110102' after 00:01:53.1
2023-06-01 17:31:08,792 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 773531 records for table 'public.cxsy_part_110102' after 00:02:03.102
2023-06-01 17:31:18,793 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 840044 records for table 'public.cxsy_part_110102' after 00:02:13.103
2023-06-01 17:31:28,794 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 908064 records for table 'public.cxsy_part_110102' after 00:02:23.104
2023-06-01 17:31:38,821 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 972800 records for table 'public.cxsy_part_110102' after 00:02:33.13
2023-06-01 17:31:48,822 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1043866 records for table 'public.cxsy_part_110102' after 00:02:43.132
2023-06-01 17:31:59,031 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1105920 records for table 'public.cxsy_part_110102' after 00:02:53.341
2023-06-01 17:32:09,519 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1177600 records for table 'public.cxsy_part_110102' after 00:03:03.829
2023-06-01 17:32:19,714 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1249280 records for table 'public.cxsy_part_110102' after 00:03:14.024
2023-06-01 17:32:30,266 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1320960 records for table 'public.cxsy_part_110102' after 00:03:24.576
2023-06-01 17:32:40,268 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1393906 records for table 'public.cxsy_part_110102' after 00:03:34.578
2023-06-01 17:32:50,269 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1460079 records for table 'public.cxsy_part_110102' after 00:03:44.579
2023-06-01 17:33:00,892 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1525760 records for table 'public.cxsy_part_110102' after 00:03:55.201
2023-06-01 17:33:10,893 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1590088 records for table 'public.cxsy_part_110102' after 00:04:05.203
2023-06-01 17:33:20,894 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1655430 records for table 'public.cxsy_part_110102' after 00:04:15.204
2023-06-01 17:33:31,113 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1720320 records for table 'public.cxsy_part_110102' after 00:04:25.423
2023-06-01 17:33:41,115 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1787449 records for table 'public.cxsy_part_110102' after 00:04:35.425
2023-06-01 17:33:51,169 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 1853440 records for table 'public.cxsy_part_110102' after 00:04:45.479
2023-06-01 17:33:56,151 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 1899508 records for table 'public.cxsy_part_110102'; total duration '00:04:50.461'
2023-06-01 17:33:56,152 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110105' (4 of 3225 tables)
2023-06-01 17:33:56,152 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110105' using select statement: 'SELECT * FROM "public"."cxsy_part_110105"'
2023-06-01 17:33:59,075 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 0 records for table 'public.cxsy_part_110105'; total duration '00:00:02.923'
2023-06-01 17:33:59,075 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110106' (5 of 3225 tables)
2023-06-01 17:33:59,075 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110106' using select statement: 'SELECT * FROM "public"."cxsy_part_110106"'
2023-06-01 17:33:59,079 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 0 records for table 'public.cxsy_part_110106'; total duration '00:00:00.004'
2023-06-01 17:33:59,079 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110107' (6 of 3225 tables)
2023-06-01 17:33:59,079 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110107' using select statement: 'SELECT * FROM "public"."cxsy_part_110107"'
2023-06-01 17:33:59,083 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 0 records for table 'public.cxsy_part_110107'; total duration '00:00:00.004'
2023-06-01 17:33:59,083 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110108' (7 of 3225 tables)
2023-06-01 17:33:59,083 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110108' using select statement: 'SELECT * FROM "public"."cxsy_part_110108"'
2023-06-01 17:33:59,087 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Finished exporting 0 records for table 'public.cxsy_part_110108'; total duration '00:00:00.003'
2023-06-01 17:33:59,087 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exporting data from table 'public.cxsy_part_110111' (8 of 3225 tables)
2023-06-01 17:33:59,087 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - For table 'public.cxsy_part_110111' using select statement: 'SELECT * FROM "public"."cxsy_part_110111"'
2023-06-01 17:34:09,859 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 64277 records for table 'public.cxsy_part_110111' after 00:00:10.772
2023-06-01 17:34:19,860 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 133085 records for table 'public.cxsy_part_110111' after 00:00:20.773
2023-06-01 17:34:30,584 INFO io.debezium.relational.RelationalSnapshotChangeEventSource [] - Exported 194560 records for table 'public.cxsy_part_110111' after 00:00:31.496
2023-06-01 17:34:37,449 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Source: Custom Source (1/1)#0 (2c4c551d79bd6901d7b34a5830e6cb88).
2023-06-01 17:34:37,450 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: Custom Source (1/1)#0 (2c4c551d79bd6901d7b34a5830e6cb88) switched from RUNNING to CANCELING.
2023-06-01 17:34:37,450 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Source: Custom Source (1/1)#0 (2c4c551d79bd6901d7b34a5830e6cb88).
2023-06-01 17:34:37,451 INFO io.debezium.embedded.EmbeddedEngine [] - Stopping the embedded engine
2023-06-01 17:34:37,452 INFO io.debezium.embedded.EmbeddedEngine [] - Waiting for PT5M for connector to stop
2023-06-01 17:34:37,458 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Flat Map (4/5)#0 (451401d18b17ed79a7da36b6cdf45cd5).
2023-06-01 17:34:37,458 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (4/5)#0 (451401d18b17ed79a7da36b6cdf45cd5) switched from RUNNING to CANCELING.
2023-06-01 17:34:37,458 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Flat Map (4/5)#0 (451401d18b17ed79a7da36b6cdf45cd5).
2023-06-01 17:34:37,459 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Sink: Print to Std. Out (1/1)#0 (4bd779438700feaa3c50bc632372730f).
2023-06-01 17:34:37,460 INFO org.apache.flink.runtime.taskmanager.Task [] - Sink: Print to Std. Out (1/1)#0 (4bd779438700feaa3c50bc632372730f) switched from RUNNING to CANCELING.
2023-06-01 17:34:37,460 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Sink: Print to Std. Out (1/1)#0 (4bd779438700feaa3c50bc632372730f).
2023-06-01 17:34:37,461 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Flat Map (1/5)#0 (fa8f8b0f99d81118247d6addbab61213).
2023-06-01 17:34:37,461 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (1/5)#0 (fa8f8b0f99d81118247d6addbab61213) switched from RUNNING to CANCELING.
2023-06-01 17:34:37,461 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Flat Map (1/5)#0 (fa8f8b0f99d81118247d6addbab61213).
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (1/5)#0 (fa8f8b0f99d81118247d6addbab61213) switched from CANCELING to CANCELED.
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Sink: Print to Std. Out (1/1)#0 (4bd779438700feaa3c50bc632372730f) switched from CANCELING to CANCELED.
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (4/5)#0 (451401d18b17ed79a7da36b6cdf45cd5) switched from CANCELING to CANCELED.
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Flat Map (1/5)#0 (fa8f8b0f99d81118247d6addbab61213).
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Sink: Print to Std. Out (1/1)#0 (4bd779438700feaa3c50bc632372730f).
2023-06-01 17:34:37,472 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Flat Map (4/5)#0 (451401d18b17ed79a7da36b6cdf45cd5).
2023-06-01 17:34:37,475 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Flat Map (4/5)#0 451401d18b17ed79a7da36b6cdf45cd5.
2023-06-01 17:34:37,482 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Flat Map (1/5)#0 fa8f8b0f99d81118247d6addbab61213.
2023-06-01 17:34:37,483 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Sink: Print to Std. Out (1/1)#0 4bd779438700feaa3c50bc632372730f.
2023-06-01 17:35:07,470 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:35:34,980 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot TaskSlot(index:1, state:ACTIVE, resource profile: ResourceProfile{cpuCores=1.0000000000000000, taskHeapMemory=4.000gb (4294967296 bytes), taskOffHeapMemory=0 bytes, managedMemory=512.000mb (536870912 bytes), networkMemory=512.000mb (536870912 bytes)}, allocationId: 41b33ce55fb8b7745632605079b156ca, jobId: c78ced164d6905125485a36a81deb648).
2023-06-01 17:35:37,471 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:36:07,472 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:36:37,473 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:37:07,474 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:37:37,474 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:38:07,475 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:38:37,476 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:39:07,477 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:39:37,478 WARN org.apache.flink.runtime.taskmanager.Task [] - Task 'Source: Custom Source (1/1)#0' did not react to cancelling signal - interrupting; it is stuck for 30 seconds in method:
org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:92)
org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsWhenDefaultActionUnavailable(MailboxProcessor.java:344)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:330)
org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:202)
org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:684)
org.apache.flink.streaming.runtime.tasks.StreamTask.executeInvoke(StreamTask.java:639)
org.apache.flink.streaming.runtime.tasks.StreamTask$$Lambda$391/1354351184.run(Unknown Source)
org.apache.flink.streaming.runtime.tasks.StreamTask.runWithCleanUpOnFail(StreamTask.java:650)
org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:623)
org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:779)
org.apache.flink.runtime.taskmanager.Task.run(Task.java:566)
java.lang.Thread.run(Thread.java:748)

2023-06-01 17:39:37,453 ERROR com.ververica.cdc.debezium.internal.Handover [] - Reporting error:
java.lang.InterruptedException: null
at java.lang.Object.wait(Native Method) ~[?:1.8.0_171]
at java.lang.Object.wait(Object.java:502) ~[?:1.8.0_171]
at com.ververica.cdc.debezium.internal.Handover.produce(Handover.java:112) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at com.ververica.cdc.debezium.internal.DebeziumChangeConsumer.handleBatch(DebeziumChangeConsumer.java:55) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.ConvertingEngineBuilder.lambda$notifying$2(ConvertingEngineBuilder.java:83) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:821) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_171]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_171]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]
2023-06-01 17:39:37,483 INFO io.debezium.connector.common.BaseSourceTask [] - Stopping down connector
2023-06-01 17:39:37,511 INFO io.debezium.embedded.EmbeddedEngine [] - Stopping the embedded engine
2023-06-01 17:39:37,511 ERROR io.debezium.connector.common.BaseSourceTask [] - Interrupted while stopping coordinator
java.lang.InterruptedException: null
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.reportInterruptAfterWait(AbstractQueuedSynchronizer.java:2014) ~[?:1.8.0_171]
at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(AbstractQueuedSynchronizer.java:2088) ~[?:1.8.0_171]
at java.util.concurrent.ThreadPoolExecutor.awaitTermination(ThreadPoolExecutor.java:1475) ~[?:1.8.0_171]
at java.util.concurrent.Executors$DelegatedExecutorService.awaitTermination(Executors.java:675) ~[?:1.8.0_171]
at io.debezium.pipeline.ChangeEventSourceCoordinator.stop(ChangeEventSourceCoordinator.java:180) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:243) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:222) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:847) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_171]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_171]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]
2023-06-01 17:39:37,513 ERROR com.ververica.cdc.debezium.internal.Handover [] - Reporting error:
com.ververica.cdc.connectors.shaded.org.apache.kafka.connect.errors.ConnectException: Interrupted while stopping coordinator, failing the task
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:249) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.connector.common.BaseSourceTask.stop(BaseSourceTask.java:222) ~[flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:847) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) [flink-sql-connector-postgres-cdc-2.3.0.jar:2.3.0]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_171]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_171]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_171]
2023-06-01 17:39:37,514 INFO org.apache.flink.runtime.taskmanager.Task [] - Source: Custom Source (1/1)#0 (2c4c551d79bd6901d7b34a5830e6cb88) switched from CANCELING to CANCELED.
2023-06-01 17:39:37,514 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Source: Custom Source (1/1)#0 (2c4c551d79bd6901d7b34a5830e6cb88).
2023-06-01 17:39:37,514 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Source: Custom Source (1/1)#0 2c4c551d79bd6901d7b34a5830e6cb88.
2023-06-01 17:39:37,595 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Receive slot request 0e135a9f2cd4cb5beea16c9e7ebf06eb for job c78ced164d6905125485a36a81deb648 from resource manager with leader id 00000000000000000000000000000000.
2023-06-01 17:39:37,596 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Allocated slot for 0e135a9f2cd4cb5beea16c9e7ebf06eb.
2023-06-01 17:39:37,597 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Offer reserved slots to the leader of job c78ced164d6905125485a36a81deb648.
2023-06-01 17:39:37,613 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 0e135a9f2cd4cb5beea16c9e7ebf06eb.
2023-06-01 17:39:37,629 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 23e939dcd4baf24b2f1f161768e49486.
2023-06-01 17:39:37,631 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b), deploy into slot with allocation id 23e939dcd4baf24b2f1f161768e49486.
2023-06-01 17:39:37,631 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) switched from CREATED to DEPLOYING.
2023-06-01 17:39:37,632 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) [DEPLOYING].
2023-06-01 17:39:37,633 INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@136261d1
2023-06-01 17:39:37,633 INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - Checkpoint storage is set to 'jobmanager'
2023-06-01 17:39:37,634 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) switched from DEPLOYING to INITIALIZING.
2023-06-01 17:39:37,634 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Activate slot 0e135a9f2cd4cb5beea16c9e7ebf06eb.
2023-06-01 17:39:37,636 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Received task Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b), deploy into slot with allocation id 0e135a9f2cd4cb5beea16c9e7ebf06eb.
2023-06-01 17:39:37,636 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) switched from CREATED to DEPLOYING.
2023-06-01 17:39:37,636 INFO org.apache.flink.runtime.taskmanager.Task [] - Loading JAR files for task Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) [DEPLOYING].
2023-06-01 17:39:37,638 INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@511f919d
2023-06-01 17:39:37,638 INFO org.apache.flink.streaming.runtime.tasks.StreamTask [] - Checkpoint storage is set to 'jobmanager'
2023-06-01 17:39:37,638 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) switched from DEPLOYING to INITIALIZING.
2023-06-01 17:39:37,640 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) switched from INITIALIZING to RUNNING.
2023-06-01 17:39:37,642 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) switched from INITIALIZING to RUNNING.
2023-06-01 17:56:41,166 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b).
2023-06-01 17:56:41,166 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) switched from RUNNING to CANCELING.
2023-06-01 17:56:41,166 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b).
2023-06-01 17:56:41,167 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b).
2023-06-01 17:56:41,167 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) switched from RUNNING to CANCELING.
2023-06-01 17:56:41,167 INFO org.apache.flink.runtime.taskmanager.Task [] - Triggering cancellation of task code Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b).
2023-06-01 17:56:41,169 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b) switched from CANCELING to CANCELED.
2023-06-01 17:56:41,169 INFO org.apache.flink.runtime.taskmanager.Task [] - Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b) switched from CANCELING to CANCELED.
2023-06-01 17:56:41,169 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Flat Map (5/5)#1 (b788761cf3983f811dec55e60a54926b).
2023-06-01 17:56:41,170 INFO org.apache.flink.runtime.taskmanager.Task [] - Freeing task resources for Flat Map (3/5)#1 (9291c0dab1302dfbe880793cde1b560b).
2023-06-01 17:56:41,171 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Flat Map (5/5)#1 b788761cf3983f811dec55e60a54926b.
2023-06-01 17:56:41,173 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Un-registering task and sending final execution state CANCELED to JobManager for task Flat Map (3/5)#1 9291c0dab1302dfbe880793cde1b560b.
2023-06-01 17:58:05,496 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot TaskSlot(index:1, state:ACTIVE, resource profile: ResourceProfile{cpuCores=1.0000000000000000, taskHeapMemory=4.000gb (4294967296 bytes), taskOffHeapMemory=0 bytes, managedMemory=512.000mb (536870912 bytes), networkMemory=512.000mb (536870912 bytes)}, allocationId: 0e135a9f2cd4cb5beea16c9e7ebf06eb, jobId: c78ced164d6905125485a36a81deb648).
2023-06-01 17:58:05,498 INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl [] - Free slot TaskSlot(index:0, state:ACTIVE, resource profile: ResourceProfile{cpuCores=1.0000000000000000, taskHeapMemory=4.000gb (4294967296 bytes), taskOffHeapMemory=0 bytes, managedMemory=512.000mb (536870912 bytes), networkMemory=512.000mb (536870912 bytes)}, allocationId: 23e939dcd4baf24b2f1f161768e49486, jobId: c78ced164d6905125485a36a81deb648).
2023-06-01 17:58:05,498 INFO org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Remove job c78ced164d6905125485a36a81deb648 from job leader monitoring.
2023-06-01 17:58:05,500 INFO org.apache.flink.runtime.taskexecutor.TaskExecutor [] - Close JobManager connection for job c78ced164d6905125485a36a81deb648.