11:40:15.548 INFO  [SourceCoordinator-Source: TransactionSource] org.apache.kafka.common.utils.AppInfoParser - Kafka version: 3.4.0
11:40:15.549 INFO  [SourceCoordinator-Source: TransactionSource] org.apache.kafka.common.utils.AppInfoParser - Kafka commitId: 2e1947d240607d53
11:40:15.549 INFO  [flink-akka.actor.default-dispatcher-9] org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job c7265fa27359645c4c764a7e5287dccb.
11:40:15.549 INFO  [SourceCoordinator-Source: TransactionSource] org.apache.kafka.common.utils.AppInfoParser - Kafka startTimeMs: 1721587215546
11:40:15.552 INFO  [flink-akka.actor.default-dispatcher-9] org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job c7265fa27359645c4c764a7e5287dccb.
11:40:15.554 INFO  [SourceCoordinator-Source: TransactionSource] o.a.f.c.k.source.enumerator.KafkaSourceEnumerator - Starting the KafkaSourceEnumerator for consumer group group.finance.transactions without periodic partition discovery.
11:40:15.561 INFO  [flink-akka.actor.default-dispatcher-7] o.a.flink.runtime.executiongraph.ExecutionGraph - Source: TransactionSource -> Sink: print (1/1) (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from SCHEDULED to DEPLOYING.
11:40:15.562 INFO  [flink-akka.actor.default-dispatcher-7] o.a.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: TransactionSource -> Sink: print (1/1) (attempt #0) with attempt id e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0 and vertex id dcb3325a77e8b5f4ed2d43255aaded7a_0 to 0131a390-79e2-4956-9d2d-c3398c7d93bf @ localhost (dataPort=-1) with allocation id 685fda137166e1897a411c815491df43
11:40:15.570 INFO  [flink-akka.actor.default-dispatcher-7] o.a.f.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot 685fda137166e1897a411c815491df43.
11:40:15.601 INFO  [flink-akka.actor.default-dispatcher-7] o.a.f.r.s.changelog.StateChangelogStorageLoader - StateChangelogStorageLoader initialized with shortcut names {memory}.
11:40:15.601 INFO  [flink-akka.actor.default-dispatcher-7] o.a.f.r.s.changelog.StateChangelogStorageLoader - Creating a changelog storage with name 'memory'.
11:40:15.617 INFO  [flink-akka.actor.default-dispatcher-7] o.a.f.r.s.TaskExecutorChannelStateExecutorFactoryManager - Creating the channel state executor factory for job id c7265fa27359645c4c764a7e5287dccb
11:40:15.630 INFO  [flink-akka.actor.default-dispatcher-7] org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: TransactionSource -> Sink: print (1/1)#0 (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0), deploy into slot with allocation id 685fda137166e1897a411c815491df43.
11:40:15.636 INFO  [flink-akka.actor.default-dispatcher-7] o.a.f.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot 685fda137166e1897a411c815491df43.
11:40:15.637 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.flink.runtime.taskmanager.Task - Source: TransactionSource -> Sink: print (1/1)#0 (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from CREATED to DEPLOYING.
11:40:15.642 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: TransactionSource -> Sink: print (1/1)#0 (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) [DEPLOYING].
11:40:15.683 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] o.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (HashMap) org.apache.flink.runtime.state.hashmap.HashMapStateBackend@4287c6e8
11:40:15.683 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.flink.runtime.state.StateBackendLoader - State backend loader loads the state backend as HashMapStateBackend
11:40:15.684 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] o.apache.flink.streaming.runtime.tasks.StreamTask - Checkpoint storage is set to 'jobmanager'
11:40:15.695 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.flink.runtime.taskmanager.Task - Source: TransactionSource -> Sink: print (1/1)#0 (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from DEPLOYING to INITIALIZING.
11:40:15.697 INFO  [flink-akka.actor.default-dispatcher-7] o.a.flink.runtime.executiongraph.ExecutionGraph - Source: TransactionSource -> Sink: print (1/1) (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from DEPLOYING to INITIALIZING.
11:40:16.139 INFO  [SourceCoordinator-Source: TransactionSource] o.a.f.runtime.source.coordinator.SourceCoordinator - Source Source: TransactionSource registering reader for parallel task 0 (#0) @ 
11:40:16.153 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] org.apache.flink.runtime.taskmanager.Task - Source: TransactionSource -> Sink: print (1/1)#0 (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from INITIALIZING to RUNNING.
11:40:16.155 INFO  [flink-akka.actor.default-dispatcher-9] o.a.flink.runtime.executiongraph.ExecutionGraph - Source: TransactionSource -> Sink: print (1/1) (e094637fd0cd86685529a0dcf1ce340c_dcb3325a77e8b5f4ed2d43255aaded7a_0_0) switched from INITIALIZING to RUNNING.
11:40:16.157 INFO  [SourceCoordinator-Source: TransactionSource] o.a.f.c.k.source.enumerator.KafkaSourceEnumerator - Discovered new partitions: [transactions-3, transactions-4, transactions-1, transactions-2, transactions-0]
11:40:16.163 INFO  [SourceCoordinator-Source: TransactionSource] o.a.f.c.k.source.enumerator.KafkaSourceEnumerator - Assigning splits to readers {0=[[Partition: transactions-1, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-2, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-4, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-3, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]]}
11:40:16.210 INFO  [Source: TransactionSource -> Sink: print (1/1)#0] o.a.f.c.base.source.reader.SourceReaderBase - Adding split(s) to reader: [[Partition: transactions-1, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-2, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-4, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-3, StartingOffset: -2, StoppingOffset: -9223372036854775808], [Partition: transactions-0, StartingOffset: -2, StoppingOffset: -9223372036854775808]]