search

apache / flink-cdc

Flink CDC is a streaming data integration tool
https://nightlies.apache.org/flink/flink-cdc-docs-stable
Apache License 2.0
5.63k stars 1.91k forks source link

ERROR (com.ververica.cdc.debezium.internal.Handover:reportError) Reporting error: java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/ThreadUtils #1753

Closed JasonFang1993 closed 8 months ago

JasonFang1993 commented 1 year ago

Describe the bug(Please use English) A clear and concise description of what the bug is.

Environment :

To Reproduce Steps to reproduce the behavior:

  1. The test data : create table if not exists public.stu ( id integer not null constraint stu_pk primary key, name varchar(25) );

  2. The test code : ` SourceFunction sourceFunction = PostgreSQLSource.builder() .hostname("192.168.10.112") .port(5432) .database("db_testl") // monitor postgres database .schemaList("public") // monitor inventory schema .username("user") .password("passwd") .decodingPluginName("pgoutput") .deserializer(new JsonDebeziumDeserializationSchema()) // converts SourceRecord to JSON String .debeziumProperties(debeziumProperties) .build();

    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

env
        .addSource(sourceFunction)
        .print().setParallelism(1); // use parallelism 1 for sink to keep message ordering

env.execute();`
  3. The error : `D:\developer_tools\jdk1.8.0_144\bin\java.exe -javaagent:D:\developer_tools\ideaIU_2021.2.3_Portable\ideaIU_2021.2.3_Portable\lib\idea_rt.jar=12607:D:\developer_tools\ideaIU_2021.2.3_Portable\ideaIU_2021.2.3_Portable\bin -Dfile.encoding=UTF-8 -classpath D:\developer_tools\jdk1.8.0_144\jre\lib\charsets.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\deploy.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\access-bridge-64.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\cldrdata.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\dnsns.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\jaccess.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\jfxrt.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\localedata.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\nashorn.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\sunec.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\sunjce_provider.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\sunmscapi.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\sunpkcs11.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\ext\zipfs.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\javaws.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\jce.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\jfr.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\jfxswt.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\jsse.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\management-agent.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\plugin.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\resources.jar;D:\developer_tools\jdk1.8.0_144\jre\lib\rt.jar;E:\code\java\gmall-realtime-clickhouse\gmall-realtime\target\test-classes;E:\code\java\gmall-realtime-clickhouse\gmall-realtime\target\classes;E:\JAVA\Maven\org\apache\flink\flink-java\1.13.6\flink-java-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-core\1.13.6\flink-core-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-annotations\1.13.6\flink-annotations-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-metrics-core\1.13.6\flink-metrics-core-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-shaded-asm-7\7.1-13.0\flink-shaded-asm-7-7.1-13.0.jar;E:\JAVA\Maven\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;E:\JAVA\Maven\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;E:\JAVA\Maven\org\objenesis\objenesis\2.1\objenesis-2.1.jar;E:\JAVA\Maven\org\apache\commons\commons-compress\1.21\commons-compress-1.21.jar;E:\JAVA\Maven\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;E:\JAVA\Maven\org\apache\commons\commons-math3\3.5\commons-math3-3.5.jar;E:\JAVA\Maven\com\google\code\findbugs\jsr305\1.3.9\jsr305-1.3.9.jar;E:\JAVA\Maven\org\apache\flink\force-shading\1.13.6\force-shading-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-streaming-java_2.11\1.13.6\flink-streaming-java_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-file-sink-common\1.13.6\flink-file-sink-common-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-runtime_2.11\1.13.6\flink-runtime_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-queryable-state-client-java\1.13.6\flink-queryable-state-client-java-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-hadoop-fs\1.13.6\flink-hadoop-fs-1.13.6.jar;E:\JAVA\Maven\commons-io\commons-io\2.8.0\commons-io-2.8.0.jar;E:\JAVA\Maven\org\apache\flink\flink-shaded-zookeeper-3\3.4.14-13.0\flink-shaded-zookeeper-3-3.4.14-13.0.jar;E:\JAVA\Maven\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;E:\JAVA\Maven\org\scala-lang\scala-library\2.11.12\scala-library-2.11.12.jar;E:\JAVA\Maven\com\typesafe\akka\akka-actor_2.11\2.5.21\akka-actor_2.11-2.5.21.jar;E:\JAVA\Maven\com\typesafe\config\1.3.3\config-1.3.3.jar;E:\JAVA\Maven\org\scala-lang\modules\scala-java8-compat_2.11\0.7.0\scala-java8-compat_2.11-0.7.0.jar;E:\JAVA\Maven\com\typesafe\akka\akka-stream_2.11\2.5.21\akka-stream_2.11-2.5.21.jar;E:\JAVA\Maven\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;E:\JAVA\Maven\com\typesafe\ssl-config-core_2.11\0.3.7\ssl-config-core_2.11-0.3.7.jar;E:\JAVA\Maven\com\typesafe\akka\akka-protobuf_2.11\2.5.21\akka-protobuf_2.11-2.5.21.jar;E:\JAVA\Maven\com\typesafe\akka\akka-slf4j_2.11\2.5.21\akka-slf4j_2.11-2.5.21.jar;E:\JAVA\Maven\org\clapper\grizzled-slf4j_2.11\1.3.2\grizzled-slf4j_2.11-1.3.2.jar;E:\JAVA\Maven\com\github\scopt\scopt_2.11\3.5.0\scopt_2.11-3.5.0.jar;E:\JAVA\Maven\org\xerial\snappy\snappy-java\1.1.8.3\snappy-java-1.1.8.3.jar;E:\JAVA\Maven\com\twitter\chill_2.11\0.7.6\chill_2.11-0.7.6.jar;E:\JAVA\Maven\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;E:\JAVA\Maven\org\lz4\lz4-java\1.6.0\lz4-java-1.6.0.jar;E:\JAVA\Maven\org\apache\flink\flink-shaded-guava\18.0-13.0\flink-shaded-guava-18.0-13.0.jar;E:\JAVA\Maven\org\apache\flink\flink-runtime-web_2.11\1.13.6\flink-runtime-web_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-shaded-netty\4.1.49.Final-13.0\flink-shaded-netty-4.1.49.Final-13.0.jar;E:\JAVA\Maven\org\apache\flink\flink-shaded-jackson\2.12.1-13.0\flink-shaded-jackson-2.12.1-13.0.jar;E:\JAVA\Maven\org\apache\flink\flink-connector-kafka_2.11\1.13.6\flink-connector-kafka_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\kafka\kafka-clients\2.4.1\kafka-clients-2.4.1.jar;E:\JAVA\Maven\com\github\luben\zstd-jni\1.4.3-1\zstd-jni-1.4.3-1.jar;E:\JAVA\Maven\org\apache\flink\flink-connector-base\1.13.6\flink-connector-base-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-clients_2.11\1.13.6\flink-clients_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-optimizer_2.11\1.13.6\flink-optimizer_2.11-1.13.6.jar;E:\JAVA\Maven\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;E:\JAVA\Maven\org\apache\flink\flink-json\1.13.6\flink-json-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-csv\1.13.6\flink-csv-1.13.6.jar;E:\JAVA\Maven\com\alibaba\fastjson\1.2.68\fastjson-1.2.68.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-client\3.1.3\hadoop-client-3.1.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-common\3.1.3\hadoop-common-3.1.3.jar;E:\JAVA\Maven\commons-net\commons-net\3.6\commons-net-3.6.jar;E:\JAVA\Maven\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar;E:\JAVA\Maven\com\sun\jersey\jersey-servlet\1.19\jersey-servlet-1.19.jar;E:\JAVA\Maven\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;E:\JAVA\Maven\org\apache\commons\commons-configuration2\2.1.1\commons-configuration2-2.1.1.jar;E:\JAVA\Maven\org\apache\avro\avro\1.7.7\avro-1.7.7.jar;E:\JAVA\Maven\com\thoughtworks\paranamer\paranamer\2.3\paranamer-2.3.jar;E:\JAVA\Maven\com\google\re2j\re2j\1.1\re2j-1.1.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-auth\3.1.3\hadoop-auth-3.1.3.jar;E:\JAVA\Maven\com\nimbusds\nimbus-jose-jwt\4.41.1\nimbus-jose-jwt-4.41.1.jar;E:\JAVA\Maven\net\minidev\json-smart\2.3\json-smart-2.3.jar;E:\JAVA\Maven\net\minidev\accessors-smart\1.2\accessors-smart-1.2.jar;E:\JAVA\Maven\org\ow2\asm\asm\5.0.4\asm-5.0.4.jar;E:\JAVA\Maven\org\apache\curator\curator-framework\2.13.0\curator-framework-2.13.0.jar;E:\JAVA\Maven\org\apache\curator\curator-client\2.13.0\curator-client-2.13.0.jar;E:\JAVA\Maven\org\apache\curator\curator-recipes\2.13.0\curator-recipes-2.13.0.jar;E:\JAVA\Maven\org\apache\htrace\htrace-core4\4.1.0-incubating\htrace-core4-4.1.0-incubating.jar;E:\JAVA\Maven\org\apache\kerby\kerb-simplekdc\1.0.1\kerb-simplekdc-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-client\1.0.1\kerb-client-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerby-config\1.0.1\kerby-config-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-core\1.0.1\kerb-core-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerby-pkix\1.0.1\kerby-pkix-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerby-asn1\1.0.1\kerby-asn1-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerby-util\1.0.1\kerby-util-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-common\1.0.1\kerb-common-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-crypto\1.0.1\kerb-crypto-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-util\1.0.1\kerb-util-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\token-provider\1.0.1\token-provider-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-admin\1.0.1\kerb-admin-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-server\1.0.1\kerb-server-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerb-identity\1.0.1\kerb-identity-1.0.1.jar;E:\JAVA\Maven\org\apache\kerby\kerby-xdr\1.0.1\kerby-xdr-1.0.1.jar;E:\JAVA\Maven\com\fasterxml\jackson\core\jackson-databind\2.7.8\jackson-databind-2.7.8.jar;E:\JAVA\Maven\com\fasterxml\jackson\core\jackson-core\2.7.8\jackson-core-2.7.8.jar;E:\JAVA\Maven\org\codehaus\woodstox\stax2-api\3.1.4\stax2-api-3.1.4.jar;E:\JAVA\Maven\com\fasterxml\woodstox\woodstox-core\5.0.3\woodstox-core-5.0.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-hdfs-client\3.1.3\hadoop-hdfs-client-3.1.3.jar;E:\JAVA\Maven\com\squareup\okhttp\okhttp\2.7.5\okhttp-2.7.5.jar;E:\JAVA\Maven\com\squareup\okio\okio\1.6.0\okio-1.6.0.jar;E:\JAVA\Maven\com\fasterxml\jackson\core\jackson-annotations\2.7.8\jackson-annotations-2.7.8.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-yarn-api\3.1.3\hadoop-yarn-api-3.1.3.jar;E:\JAVA\Maven\javax\xml\bind\jaxb-api\2.2.11\jaxb-api-2.2.11.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-yarn-client\3.1.3\hadoop-yarn-client-3.1.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-mapreduce-client-core\3.1.3\hadoop-mapreduce-client-core-3.1.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-yarn-common\3.1.3\hadoop-yarn-common-3.1.3.jar;E:\JAVA\Maven\com\sun\jersey\jersey-core\1.19\jersey-core-1.19.jar;E:\JAVA\Maven\javax\ws\rs\jsr311-api\1.1.1\jsr311-api-1.1.1.jar;E:\JAVA\Maven\com\sun\jersey\jersey-client\1.19\jersey-client-1.19.jar;E:\JAVA\Maven\com\fasterxml\jackson\module\jackson-module-jaxb-annotations\2.7.8\jackson-module-jaxb-annotations-2.7.8.jar;E:\JAVA\Maven\com\fasterxml\jackson\jaxrs\jackson-jaxrs-json-provider\2.7.8\jackson-jaxrs-json-provider-2.7.8.jar;E:\JAVA\Maven\com\fasterxml\jackson\jaxrs\jackson-jaxrs-base\2.7.8\jackson-jaxrs-base-2.7.8.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-mapreduce-client-jobclient\3.1.3\hadoop-mapreduce-client-jobclient-3.1.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-mapreduce-client-common\3.1.3\hadoop-mapreduce-client-common-3.1.3.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-annotations\3.1.3\hadoop-annotations-3.1.3.jar;E:\JAVA\Maven\org\projectlombok\lombok\1.18.20\lombok-1.18.20.jar;E:\JAVA\Maven\org\slf4j\slf4j-api\1.7.25\slf4j-api-1.7.25.jar;E:\JAVA\Maven\org\slf4j\slf4j-log4j12\1.7.25\slf4j-log4j12-1.7.25.jar;E:\JAVA\Maven\log4j\log4j\1.2.17\log4j-1.2.17.jar;E:\JAVA\Maven\org\apache\logging\log4j\log4j-to-slf4j\2.14.0\log4j-to-slf4j-2.14.0.jar;E:\JAVA\Maven\org\apache\logging\log4j\log4j-api\2.14.0\log4j-api-2.14.0.jar;E:\JAVA\Maven\org\apache\flink\flink-table-planner-blink_2.11\1.13.6\flink-table-planner-blink_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-table-common\1.13.6\flink-table-common-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-connector-files\1.13.6\flink-connector-files-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-table-api-java\1.13.6\flink-table-api-java-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-table-api-scala_2.11\1.13.6\flink-table-api-scala_2.11-1.13.6.jar;E:\JAVA\Maven\org\scala-lang\scala-reflect\2.11.12\scala-reflect-2.11.12.jar;E:\JAVA\Maven\org\scala-lang\scala-compiler\2.11.12\scala-compiler-2.11.12.jar;E:\JAVA\Maven\org\scala-lang\modules\scala-xml_2.11\1.0.5\scala-xml_2.11-1.0.5.jar;E:\JAVA\Maven\org\scala-lang\modules\scala-parser-combinators_2.11\1.0.4\scala-parser-combinators_2.11-1.0.4.jar;E:\JAVA\Maven\org\apache\flink\flink-table-api-java-bridge_2.11\1.13.6\flink-table-api-java-bridge_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-table-api-scala-bridge_2.11\1.13.6\flink-table-api-scala-bridge_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-scala_2.11\1.13.6\flink-scala_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-streaming-scala_2.11\1.13.6\flink-streaming-scala_2.11-1.13.6.jar;E:\JAVA\Maven\org\apache\flink\flink-table-runtime-blink_2.11\1.13.6\flink-table-runtime-blink_2.11-1.13.6.jar;E:\JAVA\Maven\org\codehaus\janino\janino\3.0.11\janino-3.0.11.jar;E:\JAVA\Maven\org\codehaus\janino\commons-compiler\3.0.11\commons-compiler-3.0.11.jar;E:\JAVA\Maven\org\apache\calcite\avatica\avatica-core\1.17.0\avatica-core-1.17.0.jar;E:\JAVA\Maven\com\ververica\flink-connector-mysql-cdc\2.2.1\flink-connector-mysql-cdc-2.2.1.jar;E:\JAVA\Maven\com\ververica\flink-connector-debezium\2.2.1\flink-connector-debezium-2.2.1.jar;E:\JAVA\Maven\io\debezium\debezium-api\1.5.4.Final\debezium-api-1.5.4.Final.jar;E:\JAVA\Maven\io\debezium\debezium-embedded\1.5.4.Final\debezium-embedded-1.5.4.Final.jar;E:\JAVA\Maven\org\apache\kafka\connect-api\2.7.0\connect-api-2.7.0.jar;E:\JAVA\Maven\org\apache\kafka\connect-runtime\2.7.0\connect-runtime-2.7.0.jar;E:\JAVA\Maven\org\apache\kafka\kafka-tools\2.7.0\kafka-tools-2.7.0.jar;E:\JAVA\Maven\net\sourceforge\argparse4j\argparse4j\0.7.0\argparse4j-0.7.0.jar;E:\JAVA\Maven\org\apache\kafka\connect-transforms\2.7.0\connect-transforms-2.7.0.jar;E:\JAVA\Maven\org\glassfish\jersey\containers\jersey-container-servlet\2.31\jersey-container-servlet-2.31.jar;E:\JAVA\Maven\jakarta\ws\rs\jakarta.ws.rs-api\2.1.6\jakarta.ws.rs-api-2.1.6.jar;E:\JAVA\Maven\org\glassfish\jersey\inject\jersey-hk2\2.31\jersey-hk2-2.31.jar;E:\JAVA\Maven\javax\activation\activation\1.1.1\activation-1.1.1.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-servlets\9.4.33.v20201020\jetty-servlets-9.4.33.v20201020.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-continuation\9.4.33.v20201020\jetty-continuation-9.4.33.v20201020.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-client\9.4.33.v20201020\jetty-client-9.4.33.v20201020.jar;E:\JAVA\Maven\org\reflections\reflections\0.9.12\reflections-0.9.12.jar;E:\JAVA\Maven\org\apache\maven\maven-artifact\3.6.3\maven-artifact-3.6.3.jar;E:\JAVA\Maven\org\codehaus\plexus\plexus-utils\3.2.1\plexus-utils-3.2.1.jar;E:\JAVA\Maven\org\apache\kafka\connect-json\2.7.0\connect-json-2.7.0.jar;E:\JAVA\Maven\com\fasterxml\jackson\datatype\jackson-datatype-jdk8\2.10.5\jackson-datatype-jdk8-2.10.5.jar;E:\JAVA\Maven\org\apache\kafka\connect-file\2.7.0\connect-file-2.7.0.jar;E:\JAVA\Maven\io\debezium\debezium-connector-mysql\1.5.4.Final\debezium-connector-mysql-1.5.4.Final.jar;E:\JAVA\Maven\io\debezium\debezium-core\1.5.4.Final\debezium-core-1.5.4.Final.jar;E:\JAVA\Maven\com\fasterxml\jackson\datatype\jackson-datatype-jsr310\2.10.5\jackson-datatype-jsr310-2.10.5.jar;E:\JAVA\Maven\io\debezium\debezium-ddl-parser\1.5.4.Final\debezium-ddl-parser-1.5.4.Final.jar;E:\JAVA\Maven\org\antlr\antlr4-runtime\4.7.2\antlr4-runtime-4.7.2.jar;E:\JAVA\Maven\com\zendesk\mysql-binlog-connector-java\0.25.1\mysql-binlog-connector-java-0.25.1.jar;E:\JAVA\Maven\mysql\mysql-connector-java\8.0.21\mysql-connector-java-8.0.21.jar;E:\JAVA\Maven\com\esri\geometry\esri-geometry-api\2.2.0\esri-geometry-api-2.2.0.jar;E:\JAVA\Maven\com\zaxxer\HikariCP\4.0.3\HikariCP-4.0.3.jar;E:\JAVA\Maven\org\awaitility\awaitility\4.0.1\awaitility-4.0.1.jar;E:\JAVA\Maven\org\hamcrest\hamcrest\2.1\hamcrest-2.1.jar;E:\JAVA\Maven\com\ververica\flink-connector-postgres-cdc\2.2.1\flink-connector-postgres-cdc-2.2.1.jar;E:\JAVA\Maven\io\debezium\debezium-connector-postgres\1.5.4.Final\debezium-connector-postgres-1.5.4.Final.jar;E:\JAVA\Maven\org\postgresql\postgresql\42.2.14\postgresql-42.2.14.jar;E:\JAVA\Maven\org\apache\phoenix\phoenix-core\5.0.0-HBase-2.0\phoenix-core-5.0.0-HBase-2.0.jar;E:\JAVA\Maven\org\apache\tephra\tephra-api\0.14.0-incubating\tephra-api-0.14.0-incubating.jar;E:\JAVA\Maven\org\apache\tephra\tephra-core\0.14.0-incubating\tephra-core-0.14.0-incubating.jar;E:\JAVA\Maven\com\google\inject\guice\3.0\guice-3.0.jar;E:\JAVA\Maven\javax\inject\javax.inject\1\javax.inject-1.jar;E:\JAVA\Maven\aopalliance\aopalliance\1.0\aopalliance-1.0.jar;E:\JAVA\Maven\com\google\inject\extensions\guice-assistedinject\3.0\guice-assistedinject-3.0.jar;E:\JAVA\Maven\org\apache\thrift\libthrift\0.9.0\libthrift-0.9.0.jar;E:\JAVA\Maven\it\unimi\dsi\fastutil\6.5.6\fastutil-6.5.6.jar;E:\JAVA\Maven\org\apache\twill\twill-common\0.8.0\twill-common-0.8.0.jar;E:\JAVA\Maven\org\apache\twill\twill-core\0.8.0\twill-core-0.8.0.jar;E:\JAVA\Maven\org\apache\twill\twill-api\0.8.0\twill-api-0.8.0.jar;E:\JAVA\Maven\org\ow2\asm\asm-all\5.0.2\asm-all-5.0.2.jar;E:\JAVA\Maven\org\apache\twill\twill-discovery-api\0.8.0\twill-discovery-api-0.8.0.jar;E:\JAVA\Maven\org\apache\twill\twill-discovery-core\0.8.0\twill-discovery-core-0.8.0.jar;E:\JAVA\Maven\org\apache\twill\twill-zookeeper\0.8.0\twill-zookeeper-0.8.0.jar;E:\JAVA\Maven\io\dropwizard\metrics\metrics-core\3.1.0\metrics-core-3.1.0.jar;E:\JAVA\Maven\org\apache\tephra\tephra-hbase-compat-2.0\0.14.0-incubating\tephra-hbase-compat-2.0-0.14.0-incubating.jar;E:\JAVA\Maven\org\antlr\antlr-runtime\3.5.2\antlr-runtime-3.5.2.jar;E:\JAVA\Maven\jline\jline\2.11\jline-2.11.jar;E:\JAVA\Maven\sqlline\sqlline\1.2.0\sqlline-1.2.0.jar;E:\JAVA\Maven\joda-time\joda-time\1.6\joda-time-1.6.jar;E:\JAVA\Maven\com\github\stephenc\findbugs\findbugs-annotations\1.3.9-1\findbugs-annotations-1.3.9-1.jar;E:\JAVA\Maven\com\github\stephenc\jcip\jcip-annotations\1.0-1\jcip-annotations-1.0-1.jar;E:\JAVA\Maven\org\codehaus\jackson\jackson-core-asl\1.9.2\jackson-core-asl-1.9.2.jar;E:\JAVA\Maven\org\codehaus\jackson\jackson-mapper-asl\1.9.2\jackson-mapper-asl-1.9.2.jar;E:\JAVA\Maven\junit\junit\4.12\junit-4.12.jar;E:\JAVA\Maven\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\JAVA\Maven\org\apache\httpcomponents\httpclient\4.0.1\httpclient-4.0.1.jar;E:\JAVA\Maven\org\iq80\snappy\snappy\0.3\snappy-0.3.jar;E:\JAVA\Maven\org\apache\htrace\htrace-core\3.1.0-incubating\htrace-core-3.1.0-incubating.jar;E:\JAVA\Maven\commons-codec\commons-codec\1.7\commons-codec-1.7.jar;E:\JAVA\Maven\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;E:\JAVA\Maven\org\apache\commons\commons-csv\1.0\commons-csv-1.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-annotations\2.0.0\hbase-annotations-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-mapreduce\2.0.0\hbase-mapreduce-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\thirdparty\hbase-shaded-miscellaneous\2.1.0\hbase-shaded-miscellaneous-2.1.0.jar;E:\JAVA\Maven\org\apache\hbase\thirdparty\hbase-shaded-netty\2.1.0\hbase-shaded-netty-2.1.0.jar;E:\JAVA\Maven\org\apache\hbase\thirdparty\hbase-shaded-protobuf\2.1.0\hbase-shaded-protobuf-2.1.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-zookeeper\2.0.0\hbase-zookeeper-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-protocol-shaded\2.0.0\hbase-protocol-shaded-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-metrics\2.0.0\hbase-metrics-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-metrics-api\2.0.0\hbase-metrics-api-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-replication\2.0.0\hbase-replication-2.0.0.jar;E:\JAVA\Maven\org\apache\zookeeper\zookeeper\3.4.10\zookeeper-3.4.10.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-hdfs\2.7.4\hadoop-hdfs-2.7.4.jar;E:\JAVA\Maven\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar;E:\JAVA\Maven\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;E:\JAVA\Maven\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;E:\JAVA\Maven\asm\asm\3.1\asm-3.1.jar;E:\JAVA\Maven\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;E:\JAVA\Maven\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;E:\JAVA\Maven\io\netty\netty-all\4.0.23.Final\netty-all-4.0.23.Final.jar;E:\JAVA\Maven\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar;E:\JAVA\Maven\org\apache\yetus\audience-annotations\0.5.0\audience-annotations-0.5.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-common\2.0.0\hbase-common-2.0.0.jar;E:\JAVA\Maven\org\apache\commons\commons-crypto\1.0.0\commons-crypto-1.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-protocol\2.0.0\hbase-protocol-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-client\2.0.0\hbase-client-2.0.0.jar;E:\JAVA\Maven\org\jruby\jcodings\jcodings\1.0.18\jcodings-1.0.18.jar;E:\JAVA\Maven\org\apache\hbase\hbase-server\2.0.0\hbase-server-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-http\2.0.0\hbase-http-2.0.0.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-util-ajax\9.3.19.v20170502\jetty-util-ajax-9.3.19.v20170502.jar;E:\JAVA\Maven\org\glassfish\jersey\core\jersey-server\2.25.1\jersey-server-2.25.1.jar;E:\JAVA\Maven\org\glassfish\jersey\core\jersey-common\2.25.1\jersey-common-2.25.1.jar;E:\JAVA\Maven\org\glassfish\jersey\bundles\repackaged\jersey-guava\2.25.1\jersey-guava-2.25.1.jar;E:\JAVA\Maven\org\glassfish\hk2\osgi-resource-locator\1.0.1\osgi-resource-locator-1.0.1.jar;E:\JAVA\Maven\org\glassfish\jersey\core\jersey-client\2.25.1\jersey-client-2.25.1.jar;E:\JAVA\Maven\org\glassfish\jersey\media\jersey-media-jaxb\2.25.1\jersey-media-jaxb-2.25.1.jar;E:\JAVA\Maven\javax\annotation\javax.annotation-api\1.2\javax.annotation-api-1.2.jar;E:\JAVA\Maven\org\glassfish\hk2\hk2-api\2.5.0-b32\hk2-api-2.5.0-b32.jar;E:\JAVA\Maven\org\glassfish\hk2\hk2-utils\2.5.0-b32\hk2-utils-2.5.0-b32.jar;E:\JAVA\Maven\org\glassfish\hk2\external\aopalliance-repackaged\2.5.0-b32\aopalliance-repackaged-2.5.0-b32.jar;E:\JAVA\Maven\org\glassfish\hk2\external\javax.inject\2.5.0-b32\javax.inject-2.5.0-b32.jar;E:\JAVA\Maven\org\glassfish\hk2\hk2-locator\2.5.0-b32\hk2-locator-2.5.0-b32.jar;E:\JAVA\Maven\javax\validation\validation-api\1.1.0.Final\validation-api-1.1.0.Final.jar;E:\JAVA\Maven\org\glassfish\jersey\containers\jersey-container-servlet-core\2.25.1\jersey-container-servlet-core-2.25.1.jar;E:\JAVA\Maven\org\apache\hbase\hbase-procedure\2.0.0\hbase-procedure-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-common\2.0.0\hbase-common-2.0.0-tests.jar;E:\JAVA\Maven\org\glassfish\web\javax.servlet.jsp\2.3.2\javax.servlet.jsp-2.3.2.jar;E:\JAVA\Maven\javax\servlet\jsp\javax.servlet.jsp-api\2.3.1\javax.servlet.jsp-api-2.3.1.jar;E:\JAVA\Maven\org\codehaus\jettison\jettison\1.3.8\jettison-1.3.8.jar;E:\JAVA\Maven\org\jamon\jamon-runtime\2.4.1\jamon-runtime-2.4.1.jar;E:\JAVA\Maven\javax\servlet\javax.servlet-api\3.1.0\javax.servlet-api-3.1.0.jar;E:\JAVA\Maven\javax\ws\rs\javax.ws.rs-api\2.0.1\javax.ws.rs-api-2.0.1.jar;E:\JAVA\Maven\org\apache\hadoop\hadoop-distcp\2.7.4\hadoop-distcp-2.7.4.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-http\9.3.19.v20170502\jetty-http-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-util\9.3.19.v20170502\jetty-util-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-security\9.3.19.v20170502\jetty-security-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-server\9.3.19.v20170502\jetty-server-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-io\9.3.19.v20170502\jetty-io-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-servlet\9.3.19.v20170502\jetty-servlet-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-webapp\9.3.19.v20170502\jetty-webapp-9.3.19.v20170502.jar;E:\JAVA\Maven\org\eclipse\jetty\jetty-xml\9.3.19.v20170502\jetty-xml-9.3.19.v20170502.jar;E:\JAVA\Maven\org\apache\hbase\hbase-hadoop-compat\2.0.0\hbase-hadoop-compat-2.0.0.jar;E:\JAVA\Maven\org\apache\hbase\hbase-hadoop2-compat\2.0.0\hbase-hadoop2-compat-2.0.0.jar;E:\JAVA\Maven\org\jruby\joni\joni\2.1.2\joni-2.1.2.jar;E:\JAVA\Maven\com\clearspring\analytics\stream\2.9.5\stream-2.9.5.jar;E:\JAVA\Maven\com\salesforce\i18n\i18n-util\1.0.4\i18n-util-1.0.4.jar;E:\JAVA\Maven\com\ibm\icu\icu4j\60.2\icu4j-60.2.jar;E:\JAVA\Maven\com\ibm\icu\icu4j-localespi\60.2\icu4j-localespi-60.2.jar;E:\JAVA\Maven\com\ibm\icu\icu4j-charset\60.2\icu4j-charset-60.2.jar;E:\JAVA\Maven\com\lmax\disruptor\3.3.6\disruptor-3.3.6.jar;E:\JAVA\Maven\com\google\guava\guava\30.1-jre\guava-30.1-jre.jar;E:\JAVA\Maven\com\google\guava\failureaccess\1.0.1\failureaccess-1.0.1.jar;E:\JAVA\Maven\com\google\guava\listenablefuture\9999.0-empty-to-avoid-conflict-with-guava\listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar;E:\JAVA\Maven\org\checkerframework\checker-qual\3.5.0\checker-qual-3.5.0.jar;E:\JAVA\Maven\com\google\errorprone\error_prone_annotations\2.3.4\error_prone_annotations-2.3.4.jar;E:\JAVA\Maven\com\google\j2objc\j2objc-annotations\1.3\j2objc-annotations-1.3.jar;E:\JAVA\Maven\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;E:\JAVA\Maven\com\alibaba\druid\1.1.16\druid-1.1.16.jar;E:\JAVA\Maven\commons-beanutils\commons-beanutils\1.9.3\commons-beanutils-1.9.3.jar;E:\JAVA\Maven\commons-logging\commons-logging\1.2\commons-logging-1.2.jar;E:\JAVA\Maven\org\apache\flink\flink-connector-jdbc_2.11\1.13.6\flink-connector-jdbc_2.11-1.13.6.jar;E:\JAVA\Maven\com\janeluo\ikanalyzer\2012_u6\ikanalyzer-2012_u6.jar;E:\JAVA\Maven\org\apache\lucene\lucene-core\4.7.2\lucene-core-4.7.2.jar;E:\JAVA\Maven\org\apache\lucene\lucene-queryparser\4.7.2\lucene-queryparser-4.7.2.jar;E:\JAVA\Maven\org\apache\lucene\lucene-queries\4.7.2\lucene-queries-4.7.2.jar;E:\JAVA\Maven\org\apache\lucene\lucene-sandbox\4.7.2\lucene-sandbox-4.7.2.jar;E:\JAVA\Maven\org\apache\lucene\lucene-analyzers-common\4.7.2\lucene-analyzers-common-4.7.2.jar;E:\JAVA\Maven\com\clickhouse\clickhouse-jdbc\0.3.2-patch11\clickhouse-jdbc-0.3.2-patch11.jar;E:\JAVA\Maven\com\clickhouse\clickhouse-cli-client\0.3.2-patch11\clickhouse-cli-client-0.3.2-patch11-shaded.jar;E:\JAVA\Maven\com\clickhouse\clickhouse-grpc-client\0.3.2-patch11\clickhouse-grpc-client-0.3.2-patch11-shaded.jar;E:\JAVA\Maven\com\clickhouse\clickhouse-http-client\0.3.2-patch11\clickhouse-http-client-0.3.2-patch11-shaded.jar;E:\JAVA\Maven\com\google\code\gson\gson\2.9.0\gson-2.9.0.jar;E:\JAVA\Maven\org\apache\httpcomponents\httpcore\4.4.13\httpcore-4.4.13.jar;E:\JAVA\Maven\org\apache\httpcomponents\httpmime\4.5.13\httpmime-4.5.13.jar;E:\JAVA\Maven\redis\clients\jedis\3.3.0\jedis-3.3.0.jar;E:\JAVA\Maven\org\apache\commons\commons-pool2\2.6.2\commons-pool2-2.6.2.jar FlinkCDC_PG 2022-11-17 09:37:52 WARN (org.apache.flink.runtime.webmonitor.WebMonitorUtils:find) Log file environment variable 'log.file' is not set. 2022-11-17 09:37:52 WARN (org.apache.flink.runtime.webmonitor.WebMonitorUtils:find) JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'web.log.path'. 2022-11-17 09:37:52 WARN (org.apache.kafka.connect.runtime.WorkerConfig:logPluginPathConfigProviderWarning) Variables cannot be used in the 'plugin.path' property, since the property is used by plugin scanning before the config providers that replace the variables are initialized. The raw value 'null' was used for plugin scanning, as opposed to the transformed value 'null', and this may cause unexpected results. 2022-11-17 09:37:52 ERROR (com.ververica.cdc.debezium.internal.Handover:reportError) Reporting error: java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/ThreadUtils at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.start(FlinkOffsetBackingStore.java:152) at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.configure(FlinkOffsetBackingStore.java:71) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:690) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.utils.ThreadUtils at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 7 more 2022-11-17 09:37:52 WARN (org.apache.flink.runtime.taskmanager.Task:transitionState) Source: Custom Source -> Sink: Print to Std. Out (1/1)#0 (21b186831bb8f0449eca33157a9951dd) switched from RUNNING to FAILED with failure cause: java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/ThreadUtils at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.start(FlinkOffsetBackingStore.java:152) at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.configure(FlinkOffsetBackingStore.java:71) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:690) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.utils.ThreadUtils at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 7 more

Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:144) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$3(MiniClusterJobClient.java:137) at java.util.concurrent.CompletableFuture.uniApply(CompletableFuture.java:602) at java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:577) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:237) at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760) at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736) at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) at java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:1962) at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:1081) at akka.dispatch.OnComplete.internal(Future.scala:264) at akka.dispatch.OnComplete.internal(Future.scala:261) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:191) at akka.dispatch.japi$CallbackBridge.apply(Future.scala:188) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:73) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:44) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:252) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:572) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:22) at akka.pattern.PipeToSupport$PipeableFuture$$anonfun$pipeTo$1.applyOrElse(PipeToSupport.scala:21) at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:436) at scala.concurrent.Future$$anonfun$andThen$1.apply(Future.scala:435) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:36) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply$mcV$sp(BatchingExecutor.scala:91) at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) at akka.dispatch.BatchingExecutor$BlockableBatch$$anonfun$run$1.apply(BatchingExecutor.scala:91) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:72) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:90) at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:216) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:206) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:197) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:682) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:79) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:435) at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.lang.reflect.Method.invoke(Method.java:498) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:305) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:212) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:77) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:158) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) at scala.PartialFunction$class.applyOrElse(PartialFunction.scala:123) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:170) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at akka.actor.Actor$class.aroundReceive(Actor.scala:517) at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:225) at akka.actor.ActorCell.receiveMessage(ActorCell.scala:592) at akka.actor.ActorCell.invoke(ActorCell.scala:561) at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:258) at akka.dispatch.Mailbox.run(Mailbox.scala:225) at akka.dispatch.Mailbox.exec(Mailbox.scala:235) ... 4 more Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/common/utils/ThreadUtils at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.start(FlinkOffsetBackingStore.java:152) at com.ververica.cdc.debezium.internal.FlinkOffsetBackingStore.configure(FlinkOffsetBackingStore.java:71) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:690) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:188) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) at java.lang.Thread.run(Thread.java:748) Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.utils.ThreadUtils at java.net.URLClassLoader.findClass(URLClassLoader.java:381) at java.lang.ClassLoader.loadClass(ClassLoader.java:424) at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:335) at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ... 7 more

Process finished with exit code 1 **Additional Description** If applicable, add screenshots to help explain your problem. this is pom.xml

1.8 ${java.version} ${java.version} 1.13.6 2.11 3.1.3 org.apache.flink flink-java ${flink.version} provided org.apache.flink flink-streaming-java_${scala.version} ${flink.version} provided org.apache.flink flink-runtime-web_${scala.version} ${flink.version} provided org.apache.flink flink-connector-kafka_${scala.version} ${flink.version} org.apache.flink flink-clients_${scala.version} ${flink.version} provided org.apache.flink flink-json ${flink.version} org.apache.flink flink-csv ${flink.version} com.alibaba fastjson 1.2.68 org.apache.hadoop hadoop-client ${hadoop.version} provided org.projectlombok lombok 1.18.20 provided org.slf4j slf4j-api 1.7.25 provided org.slf4j slf4j-log4j12 1.7.25 provided org.apache.logging.log4j log4j-to-slf4j 2.14.0 provided org.apache.flink flink-table-planner-blink_${scala.version} ${flink.version} provided com.ververica flink-connector-mysql-cdc 2.2.1 com.ververica flink-connector-postgres-cdc 2.2.1 org.apache.phoenix phoenix-core 5.0.0-HBase-2.0 org.glassfish javax.el com.google.guava guava 30.1-jre com.google.protobuf protobuf-java 2.5.0 com.alibaba druid 1.1.16 commons-beanutils commons-beanutils 1.9.3 org.apache.flink flink-connector-jdbc_${scala.version} ${flink.version} com.janeluo ikanalyzer 2012_u6 com.clickhouse clickhouse-jdbc 0.3.2-patch11 redis.clients jedis 3.3.0 org.apache.maven.plugins maven-shade-plugin 3.1.1 package shade com.google.code.findbugs:jsr305 org.slf4j:* log4j:* org.apache.hadoop:* *:* META-INF/*.SF META-INF/*.DSA META-INF/*.RSA `
ruanhang1993 commented 8 months ago

If the problem still exists, please re-create your issue in English on Apache Jira under project Flink with component tag Flink CDC. Thank you!