You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by oh...@nttdata-bizsys.co.jp on 2025/07/11 04:26:30 UTC

ClassNotFoundException with sql-client

I need help to figure out the problem with sql-client.



With postgres-cdc jar copied to lib and execute the following sql statements, got ClassNotFoundException.



Error:

Flink SQL> SELECT * FROM shipments;

[ERROR] Could not execute SQL statement. Reason:

java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction





Sql statements executed:

Flink SQL> CREATE TABLE shipments (

>   shipment_id INT,

>   order_id INT,

>   origin STRING,

>   destination STRING,

>   is_arrived BOOLEAN

> ) WITH (

>   'connector' = 'postgres-cdc',

>   'hostname' = 'localhost',

>   'port' = '5432',

>   'username' = 'postgres',

>   'password' = 'postgres',

>   'database-name' = 'postgres',

>   'schema-name' = 'public',

>   'table-name' = 'shipments',

>   'slot.name' = 'flink',

>    -- experimental feature: incremental snapshot (default off)

>   'scan.incremental.snapshot.enabled' = 'true'

> );

[INFO] Execute statement succeeded.



Flink SQL> SELECT * FROM shipments;

[ERROR] Could not execute SQL statement. Reason:

java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction



flink/lib:

Re: ClassNotFoundException with sql-client

Posted by Nikola Milutinovic <n....@levi9.com>.

The error is clear, but the cause is not.

The class that is missing is a part of Kafka Java client. But you are not using Kafka in your example!

It looks like Oracle CDC has that class referenced: org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145)

Which might mean you’re out of luck. You could test with an older version of CDC library, but that will probably be incompatible with Flink 1.20.

I’d suggest opening a ticket. CDC driver should have no dependency on Kafka.

Nix,.

From: oh_sei@nttdata-bizsys.co.jp <oh...@nttdata-bizsys.co.jp>
Date: Tuesday, July 15, 2025 at 8:11 AM
To: user@flink.apache.org <us...@flink.apache.org>
Subject: ClassNotFoundException with sql-client
Hi there.

Any hints with following ClassNotFoundException while fetch oracle table records into postgresql with insert into sink_t1 from source table?

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

Flink: 1.20.1

Jar lib:
flink-cep-1.20.1.jar
flink-connector-files-1.20.1.jar
flink-connector-jdbc-3.2.0-1.19.jar
flink-connector-oracle-cdc-3.4.0.jar
flink-csv-1.20.1.jar
flink-dist-1.20.1.jar
flink-faker-0.5.3.jar
flink-json-1.20.1.jar
flink-scala_2.12-1.20.1.jar
flink-sql-connector-oracle-cdc-3.4.0.jar
flink-table-api-java-uber-1.20.1.jar
flink-table-planner-loader-1.20.1.jar
flink-table-runtime-1.20.1.jar
log4j-1.2-api-2.17.1.jar
log4j-api-2.17.1.jar
log4j-core-2.17.1.jar
log4j-slf4j-impl-2.17.1.jar
ojdbc8-19.3.0.0.jar
postgresql-42.7.7.jar

executed sql:
SET execution.checkpointing.interval = 3s;

CREATE TABLE SOURCE_T1 (
     SID DECIMAL(20, 0) NOT NULL,
     NAME STRING NOT NULL,
     RATE DECIMAL(12, 6),
     POST_DATE TIMESTAMP,
     CREATE_DATE TIMESTAMP,
     PRIMARY KEY(SID) NOT ENFORCED
     ) WITH (
     'connector' = 'oracle-cdc',
     'hostname' = '192.168.241.230',
     'port' = '1521',
     'username' = 'flinkuser',
     'password' = 'flinkpw',
     'database-name' = 'IMFDB',
     'schema-name' = 'IAP_TENANT_R01_DEFAULT',
     'table-name' = 'ORACLE_T1',
     'debezium.log.mining.strategy' = 'online_catalog',
     'debezium.log.mining.continuous.mine' = 'true'     );

CREATE TABLE sink_t1 (
    sid DECIMAL(20, 0) NOT NULL,
    name STRING,
    rate DECIMAL(12,6),
    post_date TIMESTAMP,
    create_date TIMESTAMP,
    PRIMARY KEY (sid) NOT ENFORCED
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:postgresql://192.168.241.39:5432/target_db',
    'table-name' = 'test_flink',
    'username' = 'target_db',
    'password' = 'password',
    'sink.buffer-flush.interval' = '1s',
    'sink.buffer-flush.max-rows' = '100',
    'sink.max-retries' = '3'
);


INSERT INTO sink_t1
SELECT
    SID,
    NAME,
    RATE,
    POST_DATE,
    CREATE_DATE
FROM SOURCE_T1;

Exception:

2025-07-15 14:58:26,458 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.connect.source.SourceRecord
              at jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641) ~[?:?]
              at jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188) ~[?:?]
              at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?]
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:26,477 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:26,480 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#0) of source Source: SOURCE_T1[1].
2025-07-15 14:58:26,481 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0.
2025-07-15 14:58:26,482 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:27,492 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:27,494 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from CREATED to SCHEDULED.
2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #1) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:27,510 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#1) @ localhost
2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#1)
2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,527 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:27,534 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:27,591 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1.
2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:27,594 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:27,595 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#1) of source Source: SOURCE_T1[1].
2025-07-15 14:58:29,089 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:29,090 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:29,091 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from CREATED to SCHEDULED.
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #2) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:29,093 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,104 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:29,118 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#2) @ localhost
2025-07-15 14:58:29,119 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#2)
2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,120 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:29,123 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:29,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2.
2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:29,210 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:29,211 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#2) of source Source: SOURCE_T1[1].
2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from CREATED to SCHEDULED.
2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #3) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:31,488 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#3) @ localhost
2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#3)
2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,502 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:31,503 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:31,579 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:31,580 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3.
2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:31,582 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#3) of source Source: SOURCE_T1[1].
2025-07-15 14:58:35,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from CREATED to SCHEDULED.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #4) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:35,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:35,233 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#4) @ localhost
2025-07-15 14:58:35,234 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#4)
2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,235 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:35,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:35,310 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more

Re:ClassNotFoundException with sql-client

Posted by Chenyang Tang <gt...@163.com>.



Actually Flink CDC connectors does need the Kafka dependency: 

https://github.com/apache/flink-cdc/blob/13c2456da46bf1795e1b053a8d3bf8adaea099d7/flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oracle-cdc/src/main/java/org/apache/flink/cdc/connectors/oracle/source/reader/fetch/OracleSourceFetchTaskContext.java#L63C8-L63C44

Add kafka connect api dependency (https://mvnrepository.com/artifact/org.apache.kafka/connect-api) to your class path, it should resolve your problem. 










At 2025-07-15 14:09:43, oh_sei@nttdata-bizsys.co.jp wrote:

Hi there.

 

Any hints with following ClassNotFoundException while fetch oracle table records into postgresql with insert into sink_t1 from source table?

 

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

 

Flink: 1.20.1

 

Jar lib:

flink-cep-1.20.1.jar

flink-connector-files-1.20.1.jar

flink-connector-jdbc-3.2.0-1.19.jar

flink-connector-oracle-cdc-3.4.0.jar

flink-csv-1.20.1.jar

flink-dist-1.20.1.jar

flink-faker-0.5.3.jar

flink-json-1.20.1.jar

flink-scala_2.12-1.20.1.jar

flink-sql-connector-oracle-cdc-3.4.0.jar

flink-table-api-java-uber-1.20.1.jar

flink-table-planner-loader-1.20.1.jar

flink-table-runtime-1.20.1.jar

log4j-1.2-api-2.17.1.jar

log4j-api-2.17.1.jar

log4j-core-2.17.1.jar

log4j-slf4j-impl-2.17.1.jar

ojdbc8-19.3.0.0.jar

postgresql-42.7.7.jar

 

executed sql:

SET execution.checkpointing.interval = 3s;

 

CREATE TABLE SOURCE_T1 (

     SID DECIMAL(20, 0) NOT NULL,

     NAME STRING NOT NULL,

     RATE DECIMAL(12, 6),

     POST_DATE TIMESTAMP,

     CREATE_DATE TIMESTAMP,

     PRIMARY KEY(SID) NOT ENFORCED

     ) WITH (

     'connector' = 'oracle-cdc',

     'hostname' = '192.168.241.230',

     'port' = '1521',

     'username' = 'flinkuser',

     'password' = 'flinkpw',

     'database-name' = 'IMFDB',

     'schema-name' = 'IAP_TENANT_R01_DEFAULT',

     'table-name' = 'ORACLE_T1',

     'debezium.log.mining.strategy' = 'online_catalog',

     'debezium.log.mining.continuous.mine' = 'true'     );

 

CREATE TABLE sink_t1 (

    sid DECIMAL(20, 0) NOT NULL,

    name STRING,

    rate DECIMAL(12,6),

    post_date TIMESTAMP,

    create_date TIMESTAMP,

    PRIMARY KEY (sid) NOT ENFORCED

) WITH (

    'connector' = 'jdbc',

    'url' = 'jdbc:postgresql://192.168.241.39:5432/target_db',

    'table-name' = 'test_flink',

    'username' = 'target_db',

    'password' = 'password',

    'sink.buffer-flush.interval' = '1s',

    'sink.buffer-flush.max-rows' = '100',

    'sink.max-retries' = '3'

);

 

 

INSERT INTO sink_t1

SELECT

    SID,

    NAME,

    RATE,

    POST_DATE,

    CREATE_DATE

FROM SOURCE_T1;

 

Exception:

 

2025-07-15 14:58:26,458 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).

java.lang.RuntimeException: One or more fetchers have encountered exception

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]

              at java.lang.Thread.run(Thread.java:840) ~[?:?]

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.connect.source.SourceRecord

              at jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641) ~[?:?]

              at jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188) ~[?:?]

              at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?]

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

2025-07-15 14:58:26,477 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6

2025-07-15 14:58:26,480 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#0) of source Source: SOURCE_T1[1].

2025-07-15 14:58:26,481 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0.

2025-07-15 14:58:26,482 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.

2025-07-15 14:58:27,492 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.

2025-07-15 14:58:27,494 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.

2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.

2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from CREATED to SCHEDULED.

2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from SCHEDULED to DEPLOYING.

2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #1) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086

2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]

2025-07-15 14:58:27,510 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from DEPLOYING to INITIALIZING.

2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#1) @ localhost

2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#1)

2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:27,527 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0

2025-07-15 14:58:27,534 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from INITIALIZING to RUNNING.

2025-07-15 14:58:27,591 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).

java.lang.RuntimeException: One or more fetchers have encountered exception

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]

              at java.lang.Thread.run(Thread.java:840) ~[?:?]

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1.

2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.

2025-07-15 14:58:27,594 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6

2025-07-15 14:58:27,595 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#1) of source Source: SOURCE_T1[1].

2025-07-15 14:58:29,089 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.

2025-07-15 14:58:29,090 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.

2025-07-15 14:58:29,091 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from CREATED to SCHEDULED.

2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from SCHEDULED to DEPLOYING.

2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #2) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086

2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]

2025-07-15 14:58:29,093 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.

2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:29,104 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from DEPLOYING to INITIALIZING.

2025-07-15 14:58:29,118 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#2) @ localhost

2025-07-15 14:58:29,119 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#2)

2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:29,120 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0

2025-07-15 14:58:29,123 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from INITIALIZING to RUNNING.

2025-07-15 14:58:29,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).

java.lang.RuntimeException: One or more fetchers have encountered exception

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]

              at java.lang.Thread.run(Thread.java:840) ~[?:?]

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2.

2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.

2025-07-15 14:58:29,210 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6

2025-07-15 14:58:29,211 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#2) of source Source: SOURCE_T1[1].

2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.

2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.

2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.

2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from CREATED to SCHEDULED.

2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]

2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from SCHEDULED to DEPLOYING.

2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #3) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086

2025-07-15 14:58:31,488 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from DEPLOYING to INITIALIZING.

2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#3) @ localhost

2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#3)

2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:31,502 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from INITIALIZING to RUNNING.

2025-07-15 14:58:31,503 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0

2025-07-15 14:58:31,579 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).

java.lang.RuntimeException: One or more fetchers have encountered exception

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]

              at java.lang.Thread.run(Thread.java:840) ~[?:?]

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

2025-07-15 14:58:31,580 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6

2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3.

2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.

2025-07-15 14:58:31,582 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#3) of source Source: SOURCE_T1[1].

2025-07-15 14:58:35,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.

2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.

2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from CREATED to SCHEDULED.

2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.

2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from SCHEDULED to DEPLOYING.

2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #4) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086

2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]

2025-07-15 14:58:35,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from DEPLOYING to INITIALIZING.

2025-07-15 14:58:35,233 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#4) @ localhost

2025-07-15 14:58:35,234 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#4)

2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0

2025-07-15 14:58:35,235 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0

2025-07-15 14:58:35,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from INITIALIZING to RUNNING.

2025-07-15 14:58:35,310 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).

java.lang.RuntimeException: One or more fetchers have encountered exception

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]

              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]

              at java.lang.Thread.run(Thread.java:840) ~[?:?]

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]

              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]

              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]

              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]

              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]

              ... 1 more

ClassNotFoundException with sql-client

Posted by oh...@nttdata-bizsys.co.jp.

Hi there.

Any hints with following ClassNotFoundException while fetch oracle table records into postgresql with insert into sink_t1 from source table?

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord

Flink: 1.20.1

Jar lib:
flink-cep-1.20.1.jar
flink-connector-files-1.20.1.jar
flink-connector-jdbc-3.2.0-1.19.jar
flink-connector-oracle-cdc-3.4.0.jar
flink-csv-1.20.1.jar
flink-dist-1.20.1.jar
flink-faker-0.5.3.jar
flink-json-1.20.1.jar
flink-scala_2.12-1.20.1.jar
flink-sql-connector-oracle-cdc-3.4.0.jar
flink-table-api-java-uber-1.20.1.jar
flink-table-planner-loader-1.20.1.jar
flink-table-runtime-1.20.1.jar
log4j-1.2-api-2.17.1.jar
log4j-api-2.17.1.jar
log4j-core-2.17.1.jar
log4j-slf4j-impl-2.17.1.jar
ojdbc8-19.3.0.0.jar
postgresql-42.7.7.jar

executed sql:
SET execution.checkpointing.interval = 3s;

CREATE TABLE SOURCE_T1 (
     SID DECIMAL(20, 0) NOT NULL,
     NAME STRING NOT NULL,
     RATE DECIMAL(12, 6),
     POST_DATE TIMESTAMP,
     CREATE_DATE TIMESTAMP,
     PRIMARY KEY(SID) NOT ENFORCED
     ) WITH (
     'connector' = 'oracle-cdc',
     'hostname' = '192.168.241.230',
     'port' = '1521',
     'username' = 'flinkuser',
     'password' = 'flinkpw',
     'database-name' = 'IMFDB',
     'schema-name' = 'IAP_TENANT_R01_DEFAULT',
     'table-name' = 'ORACLE_T1',
     'debezium.log.mining.strategy' = 'online_catalog',
     'debezium.log.mining.continuous.mine' = 'true'     );

CREATE TABLE sink_t1 (
    sid DECIMAL(20, 0) NOT NULL,
    name STRING,
    rate DECIMAL(12,6),
    post_date TIMESTAMP,
    create_date TIMESTAMP,
    PRIMARY KEY (sid) NOT ENFORCED
) WITH (
    'connector' = 'jdbc',
    'url' = 'jdbc:postgresql://192.168.241.39:5432/target_db',
    'table-name' = 'test_flink',
    'username' = 'target_db',
    'password' = 'password',
    'sink.buffer-flush.interval' = '1s',
    'sink.buffer-flush.max-rows' = '100',
    'sink.max-retries' = '3'
);


INSERT INTO sink_t1
SELECT
    SID,
    NAME,
    RATE,
    POST_DATE,
    CREATE_DATE
FROM SOURCE_T1;

Exception:

2025-07-15 14:58:26,458 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
Caused by: java.lang.ClassNotFoundException: org.apache.kafka.connect.source.SourceRecord
              at jdk.internal.loader.BuiltinClassLoader.loadClass(BuiltinClassLoader.java:641) ~[?:?]
              at jdk.internal.loader.ClassLoaders$AppClassLoader.loadClass(ClassLoaders.java:188) ~[?:?]
              at java.lang.ClassLoader.loadClass(ClassLoader.java:525) ~[?:?]
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:26,477 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:26,480 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#0) of source Source: SOURCE_T1[1].
2025-07-15 14:58:26,481 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_0.
2025-07-15 14:58:26,482 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:27,492 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:27,494 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:27,496 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from CREATED to SCHEDULED.
2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,497 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #1) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:27,498 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:27,510 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#1) @ localhost
2025-07-15 14:58:27,525 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#1)
2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,525 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:27,527 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:27,534 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:27,591 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_1.
2025-07-15 14:58:27,593 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:27,594 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:27,595 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#1) of source Source: SOURCE_T1[1].
2025-07-15 14:58:29,089 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:29,090 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:29,091 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from CREATED to SCHEDULED.
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #2) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:29,092 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:29,093 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,093 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,104 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:29,118 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#2) @ localhost
2025-07-15 14:58:29,119 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#2)
2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,119 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:29,120 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:29,123 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:29,207 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_2.
2025-07-15 14:58:29,209 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:29,210 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:29,211 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#2) of source Source: SOURCE_T1[1].
2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:31,473 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:31,474 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from CREATED to SCHEDULED.
2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,474 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:31,475 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #3) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:31,488 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#3) @ localhost
2025-07-15 14:58:31,501 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#3)
2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,501 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:31,502 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:31,503 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:31,579 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more
2025-07-15 14:58:31,580 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Clearing resource requirements of job ca80aecca83c67af8f14fdc8cb950fd6
2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.jobmaster.JobMaster                 [] - 1 tasks will be restarted to recover the failed task c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_3.
2025-07-15 14:58:31,581 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RUNNING to RESTARTING.
2025-07-15 14:58:31,582 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Removing registered reader after failure for subtask 0 (#3) of source Source: SOURCE_T1[1].
2025-07-15 14:58:35,195 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Job insert-into_default_catalog.default_database.sink_t1 (ca80aecca83c67af8f14fdc8cb950fd6) switched from state RESTARTING to RUNNING.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.checkpoint.CheckpointCoordinator    [] - No checkpoint found during restore.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from CREATED to SCHEDULED.
2025-07-15 14:58:35,196 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Recovering subtask 0 to checkpoint -1 for source Source: SOURCE_T1[1] to checkpoint.
2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,196 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from SCHEDULED to DEPLOYING.
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Deploying Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (attempt #4) with attempt id c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4 and vertex id cbc357ccb763df2852fee8c4fc7d55f2_0 to localhost:42947-347522 @ localhost (dataPort=38885) with allocation id 4d3fd83362489a25faf90f04810b5086
2025-07-15 14:58:35,197 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.FineGrainedSlotManager [] - Received resource requirements from job ca80aecca83c67af8f14fdc8cb950fd6: [ResourceRequirement{resourceProfile=ResourceProfile{UNKNOWN}, numberOfRequiredSlots=1}]
2025-07-15 14:58:35,228 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from DEPLOYING to INITIALIZING.
2025-07-15 14:58:35,233 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] registering reader for parallel task 0 (#4) @ localhost
2025-07-15 14:58:35,234 INFO  org.apache.flink.runtime.source.coordinator.SourceCoordinator [] - Source Source: SOURCE_T1[1] received split request from parallel task 0 (#4)
2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - add processed split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,234 INFO  org.apache.flink.cdc.connectors.base.source.metrics.SourceEnumeratorMetrics [] - remove remaining split: IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0
2025-07-15 14:58:35,235 INFO  org.apache.flink.cdc.connectors.base.source.enumerator.IncrementalSourceEnumerator [] - Assign split SnapshotSplit{tableId=IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1, splitId='IMFDB.IAP_TENANT_R01_DEFAULT.ORACLE_T1:0', splitKeyType=[`ROWID` STRING], splitStart=null, splitEnd=null, highWatermark=null} to subtask 0
2025-07-15 14:58:35,248 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from INITIALIZING to RUNNING.
2025-07-15 14:58:35,310 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: SOURCE_T1[1] -> DropUpdateBefore[2] -> ConstraintEnforcer[3] -> Sink: sink_t1[3] (1/1) (c4942592584b29a289dada2ee6b703c5_cbc357ccb763df2852fee8c4fc7d55f2_0_4) switched from RUNNING to FAILED on localhost:42947-347522 @ localhost (dataPort=38885).
java.lang.RuntimeException: One or more fetchers have encountered exception
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcherManager.checkErrors(SplitFetcherManager.java:333) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.getNextFetch(SourceReaderBase.java:228) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.SourceReaderBase.pollNext(SourceReaderBase.java:190) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.api.operators.SourceOperator.emitNext(SourceOperator.java:443) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamTaskSourceInput.emitNext(StreamTaskSourceInput.java:68) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.io.StreamOneInputProcessor.processInput(StreamOneInputProcessor.java:65) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.processInput(StreamTask.java:638) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:231) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:973) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:917) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:970) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:949) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:763) ~[flink-dist-1.20.1.jar:1.20.1]
              at org.apache.flink.runtime.taskmanager.Task.run(Task.java:575) ~[flink-dist-1.20.1.jar:1.20.1]
              at java.lang.Thread.run(Thread.java:840) ~[?:?]
Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/connect/source/SourceRecord
              at org.apache.flink.cdc.connectors.oracle.source.reader.fetch.OracleSourceFetchTaskContext.configure(OracleSourceFetchTaskContext.java:145) ~[flink-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.external.IncrementalSourceScanFetcher.submitTask(IncrementalSourceScanFetcher.java:92) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.submitSnapshotSplit(IncrementalSourceSplitReader.java:249) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.pollSplitRecords(IncrementalSourceSplitReader.java:155) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.cdc.connectors.base.source.reader.IncrementalSourceSplitReader.fetch(IncrementalSourceSplitReader.java:98) ~[flink-sql-connector-oracle-cdc-3.4.0.jar:3.4.0]
              at org.apache.flink.connector.base.source.reader.fetcher.FetchTask.run(FetchTask.java:58) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.runOnce(SplitFetcher.java:165) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at org.apache.flink.connector.base.source.reader.fetcher.SplitFetcher.run(SplitFetcher.java:117) ~[flink-connector-files-1.20.1.jar:1.20.1]
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:539) ~[?:?]
              at java.util.concurrent.FutureTask.run(FutureTask.java:264) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1136) ~[?:?]
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:635) ~[?:?]
              ... 1 more

Re:ClassNotFoundException with sql-client

Posted by Xuyang <xy...@163.com>.

Hi. Could you please share what version you're using for flink and postgres-cdc? 

I guess the two jar versions don't match. The source function has been (weakly) removed in flink 2.0.

--

    Best！
    Xuyang

At 2025-07-11 12:26:30, "" <oh...@nttdata-bizsys.co.jp> wrote:

I need help to figure out the problem with sql-client.

With postgres-cdc jar copied to lib and execute the following sql statements, got ClassNotFoundException.

Error:

Flink SQL> SELECT * FROM shipments;

[ERROR] Could not execute SQL statement. Reason:

java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction

Sql statements executed:

Flink SQL> CREATE TABLE shipments (

>   shipment_id INT,

>   order_id INT,

>   origin STRING,

>   destination STRING,

>   is_arrived BOOLEAN

> ) WITH (

>   'connector' = 'postgres-cdc',

>   'hostname' = 'localhost',

>   'port' = '5432',

>   'username' = 'postgres',

>   'password' = 'postgres',

>   'database-name' = 'postgres',

>   'schema-name' = 'public',

>   'table-name' = 'shipments',

>   'slot.name' = 'flink',

>    -- experimental feature: incremental snapshot (default off)

>   'scan.incremental.snapshot.enabled' = 'true'

> );

[INFO] Execute statement succeeded.

Flink SQL> SELECT * FROM shipments;

[ERROR] Could not execute SQL statement. Reason:

java.lang.ClassNotFoundException: org.apache.flink.streaming.api.functions.source.SourceFunction

flink/lib: