wangkang created FLINK-27994:
--------------------------------
Summary: ERROR
org.apache.flink.runtime.source.coordinator.SourceCoordinator
Key: FLINK-27994
URL: https://issues.apache.org/jira/browse/FLINK-27994
Project: Flink
Issue Type: Bug
Components: Runtime / Coordination
Affects Versions: 1.14.4, 1.14.3, 1.14.2
Environment:
{color:#0e4a8e}<{color}{color:#458588}properties{color}{color:#0e4a8e}>
{color}{color:#0e4a8e}
{color}{color:#bcbf01}<{color}{color:#458588}flink.version{color}{color:#bcbf01}>{color}1.14.4{color:#bcbf01}</{color}{color:#458588}flink.version{color}{color:#bcbf01}>
{color}{color:#bcbf01}
<{color}{color:#458588}scala.binary.version{color}{color:#bcbf01}>{color}2.12{color:#bcbf01}</{color}{color:#458588}scala.binary.version{color}{color:#bcbf01}>
{color}{color:#bcbf01}
<{color}{color:#458588}hadoop.version{color}{color:#bcbf01}>{color}3.2.1{color:#bcbf01}</{color}{color:#458588}hadoop.version{color}{color:#bcbf01}>
{color}{color:#bcbf01}
<{color}{color:#458588}slf4j.version{color}{color:#bcbf01}>{color}1.7.36{color:#bcbf01}</{color}{color:#458588}slf4j.version{color}{color:#bcbf01}>
{color}{color:#bcbf01}
<{color}{color:#458588}project.build.sourceEncoding{color}{color:#bcbf01}>{color}UTF-8{color:#bcbf01}</{color}{color:#458588}project.build.sourceEncoding{color}{color:#bcbf01}>
{color}{color:#0e4a8e}</{color}{color:#458588}properties{color}{color:#0e4a8e}>{color}
{color:#bcbf01}<{color}{color:#458588}dependency{color}{color:#bcbf01}>
{color}{color:#bcbf01}
{color}{color:#bc0ba2}<{color}{color:#458588}groupId{color}{color:#bc0ba2}>{color}com.alibaba{color:#bc0ba2}</{color}{color:#458588}groupId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}artifactId{color}{color:#bc0ba2}>{color}fastjson{color:#bc0ba2}</{color}{color:#458588}artifactId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}version{color}{color:#bc0ba2}>{color}1.2.83{color:#bc0ba2}</{color}{color:#458588}version{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}scope{color}{color:#bc0ba2}>{color}provided{color:#bc0ba2}</{color}{color:#458588}scope{color}{color:#bc0ba2}>
{color}{color:#bcbf01}</{color}{color:#458588}dependency{color}{color:#bcbf01}>
{color}{color:#bcbf01}
{color}{color:#bcbf01}<{color}{color:#458588}dependency{color}{color:#bcbf01}>
{color}{color:#bcbf01}
{color}{color:#bc0ba2}<{color}{color:#458588}groupId{color}{color:#bc0ba2}>{color}mysql{color:#bc0ba2}</{color}{color:#458588}groupId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}artifactId{color}{color:#bc0ba2}>{color}mysql-connector-java{color:#bc0ba2}</{color}{color:#458588}artifactId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}version{color}{color:#bc0ba2}>{color}8.0.21{color:#bc0ba2}</{color}{color:#458588}version{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}scope{color}{color:#bc0ba2}>{color}provided{color:#bc0ba2}</{color}{color:#458588}scope{color}{color:#bc0ba2}>
{color}{color:#bc0ba2} <{color}{color:#458588}exclusions{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
{color}{color:#61aa0d}<{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}protobuf-java{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}com.google.protobuf{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#bc0ba2}</{color}{color:#458588}exclusions{color}{color:#bc0ba2}>
{color}{color:#bcbf01}</{color}{color:#458588}dependency{color}{color:#bcbf01}>{color}
{color:#bcbf01}<{color}{color:#458588}dependency{color}{color:#bcbf01}>
{color}{color:#bcbf01}
{color}{color:#bc0ba2}<{color}{color:#458588}groupId{color}{color:#bc0ba2}>{color}com.ververica{color:#bc0ba2}</{color}{color:#458588}groupId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}artifactId{color}{color:#bc0ba2}>{color}flink-connector-mysql-cdc{color:#bc0ba2}</{color}{color:#458588}artifactId{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}version{color}{color:#bc0ba2}>{color}2.2.1{color:#bc0ba2}</{color}{color:#458588}version{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
<{color}{color:#458588}scope{color}{color:#bc0ba2}>{color}provided{color:#bc0ba2}</{color}{color:#458588}scope{color}{color:#bc0ba2}>
{color}{color:#bc0ba2} <{color}{color:#458588}exclusions{color}{color:#bc0ba2}>
{color}{color:#bc0ba2}
{color}{color:#61aa0d}<{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}guava{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}com.google.guava{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jackson-core{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}com.fasterxml.jackson.core{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jackson-databind{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}com.fasterxml.jackson.core{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}slf4j-api{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.slf4j{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}kafka-clients{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.apache.kafka{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jackson-jaxrs-json-provider{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}com.fasterxml.jackson.jaxrs{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jaxb-api{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}javax.xml.bind{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}javassist{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.javassist{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jetty-util{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.eclipse.jetty{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}jetty-servlet{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.eclipse.jetty{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}commons-lang3{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.apache.commons{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d} <{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#3f9101}<{color}{color:#458588}artifactId{color}{color:#3f9101}>{color}flink-shaded-guava{color:#3f9101}</{color}{color:#458588}artifactId{color}{color:#3f9101}>
{color}{color:#3f9101}
<{color}{color:#458588}groupId{color}{color:#3f9101}>{color}org.apache.flink{color:#3f9101}</{color}{color:#458588}groupId{color}{color:#3f9101}>
{color}{color:#3f9101}
{color}{color:#61aa0d}</{color}{color:#458588}exclusion{color}{color:#61aa0d}>
{color}{color:#61aa0d}
{color}{color:#bc0ba2}</{color}{color:#458588}exclusions{color}{color:#bc0ba2}>
{color}{color:#bcbf01}</{color}{color:#458588}dependency{color}{color:#bcbf01}>
{color}
Reporter: wangkang
Attachments: image-2022-06-10-14-41-41-651.png
使用flink cdc 2.2.0报错
2661 [jobmanager-io-thread-1] WARN org.apache.flink.runtime.util.HadoopUtils
- Could not find Hadoop configuration via any of the supported methods (Flink
configuration, environment variables).
6604 [SourceCoordinator-Source: MySQL Source] ERROR
org.apache.flink.runtime.source.coordinator.SourceCoordinator - Uncaught
exception in the SplitEnumerator for Source Source: MySQL Source while starting
the SplitEnumerator.. Triggering job failover.
java.lang.NoClassDefFoundError:
org/apache/flink/shaded/guava18/com/google/common/util/concurrent/ThreadFactoryBuilder
at
com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner.startAsynchronouslySplit(MySqlSnapshotSplitAssigner.java:195)
at
com.ververica.cdc.connectors.mysql.source.assigners.MySqlSnapshotSplitAssigner.open(MySqlSnapshotSplitAssigner.java:163)
at
com.ververica.cdc.connectors.mysql.source.assigners.MySqlHybridSplitAssigner.open(MySqlHybridSplitAssigner.java:95)
at
com.ververica.cdc.connectors.mysql.source.enumerator.MySqlSourceEnumerator.start(MySqlSourceEnumerator.java:101)
at
org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$start$0(SourceCoordinator.java:136)
at
org.apache.flink.runtime.source.coordinator.SourceCoordinator.lambda$runInEventLoop$8(SourceCoordinator.java:329)
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
at java.util.concurrent.FutureTask.run(FutureTask.java:266)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
at
java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
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.flink.shaded.guava18.com.google.common.util.concurrent.ThreadFactoryBuilder
at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:349)
at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
... 13 more !image-2022-06-10-14-41-41-651.png|width=1589,height=802!
--
This message was sent by Atlassian Jira
(v8.20.7#820007)
