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.62k stars 1.9k forks source link

mysql-cdc报错，麻烦看下如何解决啊，Caused by: java.lang.NoSuchMethodError: 'void sun.misc.Unsafe.monitorEnter(java.lang.Object)' #110

Closed gyp03 closed 3 years ago

gyp03 commented 3 years ago

"/Applications/IntelliJ IDEA.app/Contents/jbr/Contents/Home/bin/java" -javaagent:/Applications/IntelliJ IDEA.app/Contents/lib/idea_rt.jar=51940:/Applications/IntelliJ IDEA.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Users/apple/Documents/idea/bigdata_code_case/flink/target/classes:/Users/apple/.m2/repository/org/apache/flink/flink-java/1.12.0/flink-java-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-core/1.12.0/flink-core-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-annotations/1.12.0/flink-annotations-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-metrics-core/1.12.0/flink-metrics-core-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-asm-7/7.1-12.0/flink-shaded-asm-7-7.1-12.0.jar:/Users/apple/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/apple/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/apple/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/apple/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/apple/.m2/repository/org/apache/commons/commons-math3/3.5/commons-math3-3.5.jar:/Users/apple/.m2/repository/org/slf4j/slf4j-api/1.7.15/slf4j-api-1.7.15.jar:/Users/apple/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/apple/.m2/repository/org/apache/flink/force-shading/1.12.0/force-shading-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-streaming-java_2.12/1.12.0/flink-streaming-java_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-file-sink-common/1.12.0/flink-file-sink-common-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-runtime_2.12/1.12.0/flink-runtime_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-queryable-state-client-java/1.12.0/flink-queryable-state-client-java-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-hadoop-fs/1.12.0/flink-hadoop-fs-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.49.Final-12.0/flink-shaded-netty-4.1.49.Final-12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-jackson/2.10.1-12.0/flink-shaded-jackson-2.10.1-12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-zookeeper-3/3.4.14-12.0/flink-shaded-zookeeper-3-3.4.14-12.0.jar:/Users/apple/.m2/repository/org/javassist/javassist/3.24.0-GA/javassist-3.24.0-GA.jar:/Users/apple/.m2/repository/com/typesafe/akka/akka-actor_2.12/2.5.21/akka-actor_2.12-2.5.21.jar:/Users/apple/.m2/repository/com/typesafe/config/1.3.3/config-1.3.3.jar:/Users/apple/.m2/repository/org/scala-lang/modules/scala-java8-compat_2.12/0.8.0/scala-java8-compat_2.12-0.8.0.jar:/Users/apple/.m2/repository/com/typesafe/akka/akka-stream_2.12/2.5.21/akka-stream_2.12-2.5.21.jar:/Users/apple/.m2/repository/org/reactivestreams/reactive-streams/1.0.2/reactive-streams-1.0.2.jar:/Users/apple/.m2/repository/com/typesafe/ssl-config-core_2.12/0.3.7/ssl-config-core_2.12-0.3.7.jar:/Users/apple/.m2/repository/org/scala-lang/modules/scala-parser-combinators_2.12/1.1.1/scala-parser-combinators_2.12-1.1.1.jar:/Users/apple/.m2/repository/com/typesafe/akka/akka-protobuf_2.12/2.5.21/akka-protobuf_2.12-2.5.21.jar:/Users/apple/.m2/repository/com/typesafe/akka/akka-slf4j_2.12/2.5.21/akka-slf4j_2.12-2.5.21.jar:/Users/apple/.m2/repository/org/clapper/grizzled-slf4j_2.12/1.3.2/grizzled-slf4j_2.12-1.3.2.jar:/Users/apple/.m2/repository/com/github/scopt/scopt_2.12/3.5.0/scopt_2.12-3.5.0.jar:/Users/apple/.m2/repository/com/twitter/chill_2.12/0.7.6/chill_2.12-0.7.6.jar:/Users/apple/.m2/repository/com/twitter/chill-java/0.7.6/chill-java-0.7.6.jar:/Users/apple/.m2/repository/org/lz4/lz4-java/1.6.0/lz4-java-1.6.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-guava/18.0-12.0/flink-shaded-guava-18.0-12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-clients_2.12/1.12.0/flink-clients_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-optimizer_2.12/1.12.0/flink-optimizer_2.12-1.12.0.jar:/Users/apple/.m2/repository/commons-cli/commons-cli/1.3.1/commons-cli-1.3.1.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-kafka_2.12/1.12.0/flink-connector-kafka_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/kafka/kafka-clients/2.4.1/kafka-clients-2.4.1.jar:/Users/apple/.m2/repository/com/github/luben/zstd-jni/1.4.3-1/zstd-jni-1.4.3-1.jar:/Users/apple/.m2/repository/org/apache/flink/flink-sql-connector-kafka_2.12/1.12.0/flink-sql-connector-kafka_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-json/1.12.0/flink-json-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-api-java-bridge_2.12/1.12.0/flink-table-api-java-bridge_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-api-java/1.12.0/flink-table-api-java-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-planner_2.12/1.12.0/flink-table-planner_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-common/1.12.0/flink-table-common-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-api-scala-bridge_2.12/1.12.0/flink-table-api-scala-bridge_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-planner-blink_2.12/1.12.0/flink-table-planner-blink_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-api-scala_2.12/1.12.0/flink-table-api-scala_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-table-runtime-blink_2.12/1.12.0/flink-table-runtime-blink_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/codehaus/janino/janino/3.0.11/janino-3.0.11.jar:/Users/apple/.m2/repository/org/apache/calcite/avatica/avatica-core/1.17.0/avatica-core-1.17.0.jar:/Users/apple/.m2/repository/org/reflections/reflections/0.9.10/reflections-0.9.10.jar:/Users/apple/.m2/repository/org/apache/flink/flink-streaming-scala_2.12/1.12.0/flink-streaming-scala_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-scala_2.12/1.12.0/flink-scala_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/scala-lang/scala-reflect/2.12.7/scala-reflect-2.12.7.jar:/Users/apple/.m2/repository/org/scala-lang/scala-library/2.12.7/scala-library-2.12.7.jar:/Users/apple/.m2/repository/org/scala-lang/scala-compiler/2.12.7/scala-compiler-2.12.7.jar:/Users/apple/.m2/repository/org/scala-lang/modules/scala-xml_2.12/1.0.6/scala-xml_2.12-1.0.6.jar:/Users/apple/.m2/repository/org/apache/flink/flink-shaded-hadoop2/2.8.3-1.8.3/flink-shaded-hadoop2-2.8.3-1.8.3.jar:/Users/apple/.m2/repository/org/apache/commons/commons-compress/1.18/commons-compress-1.18.jar:/Users/apple/.m2/repository/org/apache/avro/avro/1.8.2/avro-1.8.2.jar:/Users/apple/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/apple/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/apple/.m2/repository/com/thoughtworks/paranamer/paranamer/2.7/paranamer-2.7.jar:/Users/apple/.m2/repository/org/xerial/snappy/snappy-java/1.1.4/snappy-java-1.1.4.jar:/Users/apple/.m2/repository/org/tukaani/xz/1.5/xz-1.5.jar:/Users/apple/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/Users/apple/.m2/repository/commons-codec/commons-codec/1.10/commons-codec-1.10.jar:/Users/apple/.m2/repository/commons-io/commons-io/2.4/commons-io-2.4.jar:/Users/apple/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/Users/apple/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/apple/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/Users/apple/.m2/repository/org/mortbay/jetty/jetty-sslengine/6.1.26/jetty-sslengine-6.1.26.jar:/Users/apple/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/Users/apple/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/Users/apple/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/apple/.m2/repository/commons-configuration/commons-configuration/1.7/commons-configuration-1.7.jar:/Users/apple/.m2/repository/commons-digester/commons-digester/1.8.1/commons-digester-1.8.1.jar:/Users/apple/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/apple/.m2/repository/com/nimbusds/nimbus-jose-jwt/3.9/nimbus-jose-jwt-3.9.jar:/Users/apple/.m2/repository/net/jcip/jcip-annotations/1.0/jcip-annotations-1.0.jar:/Users/apple/.m2/repository/net/minidev/json-smart/1.1.1/json-smart-1.1.1.jar:/Users/apple/.m2/repository/org/apache/directory/server/apacheds-kerberos-codec/2.0.0-M15/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/apple/.m2/repository/org/apache/directory/server/apacheds-i18n/2.0.0-M15/apacheds-i18n-2.0.0-M15.jar:/Users/apple/.m2/repository/org/apache/directory/api/api-asn1-api/1.0.0-M20/api-asn1-api-1.0.0-M20.jar:/Users/apple/.m2/repository/org/apache/directory/api/api-util/1.0.0-M20/api-util-1.0.0-M20.jar:/Users/apple/.m2/repository/com/jcraft/jsch/0.1.54/jsch-0.1.54.jar:/Users/apple/.m2/repository/org/apache/htrace/htrace-core4/4.0.1-incubating/htrace-core4-4.0.1-incubating.jar:/Users/apple/.m2/repository/org/apache/zookeeper/zookeeper/3.4.10/zookeeper-3.4.10.jar:/Users/apple/.m2/repository/commons-beanutils/commons-beanutils/1.9.3/commons-beanutils-1.9.3.jar:/Users/apple/.m2/repository/com/squareup/okhttp/okhttp/2.4.0/okhttp-2.4.0.jar:/Users/apple/.m2/repository/com/squareup/okio/okio/1.4.0/okio-1.4.0.jar:/Users/apple/.m2/repository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/Users/apple/.m2/repository/xerces/xercesImpl/2.9.1/xercesImpl-2.9.1.jar:/Users/apple/.m2/repository/xml-apis/xml-apis/1.3.04/xml-apis-1.3.04.jar:/Users/apple/.m2/repository/org/fusesource/leveldbjni/leveldbjni-all/1.8/leveldbjni-all-1.8.jar:/Users/apple/.m2/repository/javax/xml/bind/jaxb-api/2.2.2/jaxb-api-2.2.2.jar:/Users/apple/.m2/repository/javax/xml/stream/stax-api/1.0-2/stax-api-1.0-2.jar:/Users/apple/.m2/repository/javax/activation/activation/1.1/activation-1.1.jar:/Users/apple/.m2/repository/com/sun/jersey/jersey-client/1.9/jersey-client-1.9.jar:/Users/apple/.m2/repository/org/apache/flink/flink-hadoop-compatibility_2.12/1.12.0/flink-hadoop-compatibility_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-hbase_2.12/1.10.2/flink-hbase_2.12-1.10.2.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-server/1.4.3/hbase-server-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-common/1.4.3/hbase-common-1.4.3.jar:/Users/apple/.m2/repository/com/github/stephenc/findbugs/findbugs-annotations/1.3.9-1/findbugs-annotations-1.3.9-1.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-protocol/1.4.3/hbase-protocol-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-procedure/1.4.3/hbase-procedure-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-common/1.4.3/hbase-common-1.4.3-tests.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-client/1.4.3/hbase-client-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-prefix-tree/1.4.3/hbase-prefix-tree-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-metrics-api/1.4.3/hbase-metrics-api-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-metrics/1.4.3/hbase-metrics-1.4.3.jar:/Users/apple/.m2/repository/io/dropwizard/metrics/metrics-core/3.1.2/metrics-core-3.1.2.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-hadoop-compat/1.4.3/hbase-hadoop-compat-1.4.3.jar:/Users/apple/.m2/repository/org/apache/hbase/hbase-hadoop2-compat/1.4.3/hbase-hadoop2-compat-1.4.3.jar:/Users/apple/.m2/repository/com/yammer/metrics/metrics-core/2.2.0/metrics-core-2.2.0.jar:/Users/apple/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/Users/apple/.m2/repository/org/apache/commons/commons-math/2.2/commons-math-2.2.jar:/Users/apple/.m2/repository/log4j/log4j/1.2.17/log4j-1.2.17.jar:/Users/apple/.m2/repository/org/codehaus/jackson/jackson-jaxrs/1.9.13/jackson-jaxrs-1.9.13.jar:/Users/apple/.m2/repository/io/netty/netty-all/4.1.8.Final/netty-all-4.1.8.Final.jar:/Users/apple/.m2/repository/org/apache/htrace/htrace-core/3.1.0-incubating/htrace-core-3.1.0-incubating.jar:/Users/apple/.m2/repository/com/lmax/disruptor/3.3.0/disruptor-3.3.0.jar:/Users/apple/.m2/repository/org/apache/httpcomponents/httpcore/4.4.4/httpcore-4.4.4.jar:/Users/apple/.m2/repository/junit/junit/4.12/junit-4.12.jar:/Users/apple/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-hive_2.12/1.12.0/flink-connector-hive_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-files/1.12.0/flink-connector-files-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-base/1.12.0/flink-connector-base-1.12.0.jar:/Users/apple/.m2/repository/org/apache/hive/hive-exec/2.3.4/hive-exec-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-vector-code-gen/2.3.4/hive-vector-code-gen-2.3.4.jar:/Users/apple/.m2/repository/org/apache/velocity/velocity/1.5/velocity-1.5.jar:/Users/apple/.m2/repository/oro/oro/2.0.8/oro-2.0.8.jar:/Users/apple/.m2/repository/org/apache/hive/hive-llap-tez/2.3.4/hive-llap-tez-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-common/2.3.4/hive-common-2.3.4.jar:/Users/apple/.m2/repository/jline/jline/2.12/jline-2.12.jar:/Users/apple/.m2/repository/org/eclipse/jetty/aggregate/jetty-all/7.6.0.v20120127/jetty-all-7.6.0.v20120127.jar:/Users/apple/.m2/repository/org/apache/geronimo/specs/geronimo-jta_1.1_spec/1.1.1/geronimo-jta_1.1_spec-1.1.1.jar:/Users/apple/.m2/repository/javax/mail/mail/1.4.1/mail-1.4.1.jar:/Users/apple/.m2/repository/org/apache/geronimo/specs/geronimo-jaspic_1.0_spec/1.0/geronimo-jaspic_1.0_spec-1.0.jar:/Users/apple/.m2/repository/org/apache/geronimo/specs/geronimo-annotation_1.0_spec/1.1.1/geronimo-annotation_1.0_spec-1.1.1.jar:/Users/apple/.m2/repository/asm/asm-commons/3.1/asm-commons-3.1.jar:/Users/apple/.m2/repository/asm/asm-tree/3.1/asm-tree-3.1.jar:/Users/apple/.m2/repository/asm/asm/3.1/asm-3.1.jar:/Users/apple/.m2/repository/org/eclipse/jetty/orbit/javax.servlet/3.0.0.v201112011016/javax.servlet-3.0.0.v201112011016.jar:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-web/2.6.2/log4j-web-2.6.2.jar:/Users/apple/.m2/repository/com/tdunning/json/1.8/json-1.8.jar:/Users/apple/.m2/repository/io/dropwizard/metrics/metrics-jvm/3.1.0/metrics-jvm-3.1.0.jar:/Users/apple/.m2/repository/io/dropwizard/metrics/metrics-json/3.1.0/metrics-json-3.1.0.jar:/Users/apple/.m2/repository/com/github/joshelser/dropwizard-metrics-hadoop-metrics2-reporter/0.1.2/dropwizard-metrics-hadoop-metrics2-reporter-0.1.2.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-common/2.6.0/hadoop-common-2.6.0.jar:/Users/apple/.m2/repository/org/mortbay/jetty/jetty/6.1.26/jetty-6.1.26.jar:/Users/apple/.m2/repository/com/sun/jersey/jersey-server/1.9/jersey-server-1.9.jar:/Users/apple/.m2/repository/tomcat/jasper-compiler/5.5.23/jasper-compiler-5.5.23.jar:/Users/apple/.m2/repository/tomcat/jasper-runtime/5.5.23/jasper-runtime-5.5.23.jar:/Users/apple/.m2/repository/javax/servlet/jsp/jsp-api/2.1/jsp-api-2.1.jar:/Users/apple/.m2/repository/commons-el/commons-el/1.0/commons-el-1.0.jar:/Users/apple/.m2/repository/net/java/dev/jets3t/jets3t/0.9.0/jets3t-0.9.0.jar:/Users/apple/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-auth/2.6.0/hadoop-auth-2.6.0.jar:/Users/apple/.m2/repository/org/apache/curator/curator-recipes/2.6.0/curator-recipes-2.6.0.jar:/Users/apple/.m2/repository/org/htrace/htrace-core/3.0.4/htrace-core-3.0.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-llap-client/2.3.4/hive-llap-client-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-llap-common/2.3.4/hive-llap-common-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-serde/2.3.4/hive-serde-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/hive-service-rpc/2.3.4/hive-service-rpc-2.3.4.jar:/Users/apple/.m2/repository/org/apache/thrift/libfb303/0.9.3/libfb303-0.9.3.jar:/Users/apple/.m2/repository/net/sf/opencsv/opencsv/2.3/opencsv-2.3.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-hadoop-bundle/1.8.1/parquet-hadoop-bundle-1.8.1.jar:/Users/apple/.m2/repository/org/apache/hive/hive-shims/2.3.4/hive-shims-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hive/shims/hive-shims-common/2.3.4/hive-shims-common-2.3.4.jar:/Users/apple/.m2/repository/org/apache/thrift/libthrift/0.9.3/libthrift-0.9.3.jar:/Users/apple/.m2/repository/org/apache/hive/shims/hive-shims-0.23/2.3.4/hive-shims-0.23-2.3.4.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-server-resourcemanager/2.7.2/hadoop-yarn-server-resourcemanager-2.7.2.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-annotations/2.7.2/hadoop-annotations-2.7.2.jar:/Users/apple/.m2/repository/com/google/inject/extensions/guice-servlet/3.0/guice-servlet-3.0.jar:/Users/apple/.m2/repository/com/google/inject/guice/3.0/guice-3.0.jar:/Users/apple/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/Users/apple/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/Users/apple/.m2/repository/com/sun/jersey/jersey-json/1.9/jersey-json-1.9.jar:/Users/apple/.m2/repository/com/sun/xml/bind/jaxb-impl/2.2.3-1/jaxb-impl-2.2.3-1.jar:/Users/apple/.m2/repository/org/codehaus/jackson/jackson-xc/1.8.3/jackson-xc-1.8.3.jar:/Users/apple/.m2/repository/com/sun/jersey/contribs/jersey-guice/1.9/jersey-guice-1.9.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-common/2.7.2/hadoop-yarn-common-2.7.2.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-api/2.7.2/hadoop-yarn-api-2.7.2.jar:/Users/apple/.m2/repository/org/codehaus/jettison/jettison/1.1/jettison-1.1.jar:/Users/apple/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/Users/apple/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-server-common/2.7.2/hadoop-yarn-server-common-2.7.2.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-server-applicationhistoryservice/2.7.2/hadoop-yarn-server-applicationhistoryservice-2.7.2.jar:/Users/apple/.m2/repository/org/apache/hadoop/hadoop-yarn-server-web-proxy/2.7.2/hadoop-yarn-server-web-proxy-2.7.2.jar:/Users/apple/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6-tests.jar:/Users/apple/.m2/repository/io/netty/netty/3.7.0.Final/netty-3.7.0.Final.jar:/Users/apple/.m2/repository/org/apache/hive/shims/hive-shims-scheduler/2.3.4/hive-shims-scheduler-2.3.4.jar:/Users/apple/.m2/repository/commons-httpclient/commons-httpclient/3.0.1/commons-httpclient-3.0.1.jar:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.6.2/log4j-1.2-api-2.6.2.jar:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-api/2.6.2/log4j-api-2.6.2.jar:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-core/2.6.2/log4j-core-2.6.2.jar:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.6.2/log4j-slf4j-impl-2.6.2.jar:/Users/apple/.m2/repository/org/antlr/antlr-runtime/3.5.2/antlr-runtime-3.5.2.jar:/Users/apple/.m2/repository/org/antlr/ST4/4.0.4/ST4-4.0.4.jar:/Users/apple/.m2/repository/org/apache/ant/ant/1.9.1/ant-1.9.1.jar:/Users/apple/.m2/repository/org/apache/ant/ant-launcher/1.9.1/ant-launcher-1.9.1.jar:/Users/apple/.m2/repository/org/apache/ivy/ivy/2.4.0/ivy-2.4.0.jar:/Users/apple/.m2/repository/org/apache/curator/curator-framework/2.7.1/curator-framework-2.7.1.jar:/Users/apple/.m2/repository/org/apache/curator/curator-client/2.7.1/curator-client-2.7.1.jar:/Users/apple/.m2/repository/org/codehaus/groovy/groovy-all/2.4.4/groovy-all-2.4.4.jar:/Users/apple/.m2/repository/org/datanucleus/datanucleus-core/4.1.17/datanucleus-core-4.1.17.jar:/Users/apple/.m2/repository/org/apache/calcite/calcite-core/1.10.0/calcite-core-1.10.0.jar:/Users/apple/.m2/repository/org/apache/calcite/calcite-linq4j/1.10.0/calcite-linq4j-1.10.0.jar:/Users/apple/.m2/repository/commons-dbcp/commons-dbcp/1.4/commons-dbcp-1.4.jar:/Users/apple/.m2/repository/net/hydromatic/eigenbase-properties/1.1.5/eigenbase-properties-1.1.5.jar:/Users/apple/.m2/repository/org/codehaus/janino/commons-compiler/2.7.6/commons-compiler-2.7.6.jar:/Users/apple/.m2/repository/org/pentaho/pentaho-aggdesigner-algorithm/5.1.5-jhyde/pentaho-aggdesigner-algorithm-5.1.5-jhyde.jar:/Users/apple/.m2/repository/org/apache/calcite/calcite-druid/1.10.0/calcite-druid-1.10.0.jar:/Users/apple/.m2/repository/joda-time/joda-time/2.8.1/joda-time-2.8.1.jar:/Users/apple/.m2/repository/org/apache/calcite/avatica/avatica/1.8.0/avatica-1.8.0.jar:/Users/apple/.m2/repository/org/apache/calcite/avatica/avatica-metrics/1.8.0/avatica-metrics-1.8.0.jar:/Users/apple/.m2/repository/stax/stax-api/1.0.1/stax-api-1.0.1.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-elasticsearch6_2.12/1.12.0/flink-connector-elasticsearch6_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-connector-elasticsearch-base_2.12/1.12.0/flink-connector-elasticsearch-base_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/elasticsearch/client/elasticsearch-rest-high-level-client/6.3.1/elasticsearch-rest-high-level-client-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/elasticsearch/6.3.1/elasticsearch-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/elasticsearch-core/6.3.1/elasticsearch-core-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/elasticsearch-secure-sm/6.3.1/elasticsearch-secure-sm-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/elasticsearch-x-content/6.3.1/elasticsearch-x-content-6.3.1.jar:/Users/apple/.m2/repository/org/yaml/snakeyaml/1.17/snakeyaml-1.17.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-smile/2.8.10/jackson-dataformat-smile-2.8.10.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.8.10/jackson-dataformat-yaml-2.8.10.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-cbor/2.8.10/jackson-dataformat-cbor-2.8.10.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-core/7.3.1/lucene-core-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-analyzers-common/7.3.1/lucene-analyzers-common-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-backward-codecs/7.3.1/lucene-backward-codecs-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-grouping/7.3.1/lucene-grouping-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-highlighter/7.3.1/lucene-highlighter-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-join/7.3.1/lucene-join-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-memory/7.3.1/lucene-memory-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-misc/7.3.1/lucene-misc-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-queries/7.3.1/lucene-queries-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-queryparser/7.3.1/lucene-queryparser-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-sandbox/7.3.1/lucene-sandbox-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-spatial/7.3.1/lucene-spatial-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-spatial-extras/7.3.1/lucene-spatial-extras-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-spatial3d/7.3.1/lucene-spatial3d-7.3.1.jar:/Users/apple/.m2/repository/org/apache/lucene/lucene-suggest/7.3.1/lucene-suggest-7.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/elasticsearch-cli/6.3.1/elasticsearch-cli-6.3.1.jar:/Users/apple/.m2/repository/net/sf/jopt-simple/jopt-simple/5.0.2/jopt-simple-5.0.2.jar:/Users/apple/.m2/repository/com/carrotsearch/hppc/0.7.1/hppc-0.7.1.jar:/Users/apple/.m2/repository/com/tdunning/t-digest/3.2/t-digest-3.2.jar:/Users/apple/.m2/repository/org/hdrhistogram/HdrHistogram/2.1.9/HdrHistogram-2.1.9.jar:/Users/apple/.m2/repository/org/elasticsearch/jna/4.5.1/jna-4.5.1.jar:/Users/apple/.m2/repository/org/elasticsearch/client/elasticsearch-rest-client/6.3.1/elasticsearch-rest-client-6.3.1.jar:/Users/apple/.m2/repository/org/apache/httpcomponents/httpasyncclient/4.1.2/httpasyncclient-4.1.2.jar:/Users/apple/.m2/repository/org/apache/httpcomponents/httpcore-nio/4.4.5/httpcore-nio-4.4.5.jar:/Users/apple/.m2/repository/org/elasticsearch/plugin/parent-join-client/6.3.1/parent-join-client-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/plugin/aggs-matrix-stats-client/6.3.1/aggs-matrix-stats-client-6.3.1.jar:/Users/apple/.m2/repository/org/elasticsearch/plugin/rank-eval-client/6.3.1/rank-eval-client-6.3.1.jar:/Users/apple/.m2/repository/org/projectlombok/lombok/1.18.16/lombok-1.18.16.jar:/Users/apple/.m2/repository/com/alibaba/fastjson/1.2.75/fastjson-1.2.75.jar:/Users/apple/.m2/repository/org/apache/flink/flink-parquet_2.12/1.12.0/flink-parquet_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-hadoop/1.11.1/parquet-hadoop-1.11.1.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-column/1.11.1/parquet-column-1.11.1.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-common/1.11.1/parquet-common-1.11.1.jar:/Users/apple/.m2/repository/org/apache/yetus/audience-annotations/0.11.0/audience-annotations-0.11.0.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-encoding/1.11.1/parquet-encoding-1.11.1.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-format-structures/1.11.1/parquet-format-structures-1.11.1.jar:/Users/apple/.m2/repository/javax/annotation/javax.annotation-api/1.3.2/javax.annotation-api-1.3.2.jar:/Users/apple/.m2/repository/org/apache/parquet/parquet-jackson/1.11.1/parquet-jackson-1.11.1.jar:/Users/apple/.m2/repository/commons-pool/commons-pool/1.6/commons-pool-1.6.jar:/Users/apple/.m2/repository/org/apache/flink/flink-avro/1.12.0/flink-avro-1.12.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-orc_2.12/1.12.0/flink-orc_2.12-1.12.0.jar:/Users/apple/.m2/repository/org/apache/orc/orc-core/1.5.6/orc-core-1.5.6.jar:/Users/apple/.m2/repository/org/apache/orc/orc-shims/1.5.6/orc-shims-1.5.6.jar:/Users/apple/.m2/repository/io/airlift/aircompressor/0.10/aircompressor-0.10.jar:/Users/apple/.m2/repository/org/apache/hive/hive-storage-api/2.6.0/hive-storage-api-2.6.0.jar:/Users/apple/.m2/repository/org/apache/flink/flink-sequence-file/1.12.0/flink-sequence-file-1.12.0.jar:/Users/apple/.m2/repository/ru/yandex/clickhouse/clickhouse-jdbc/0.2.4/clickhouse-jdbc-0.2.4.jar:/Users/apple/.m2/repository/org/apache/httpcomponents/httpclient/4.5.2/httpclient-4.5.2.jar:/Users/apple/.m2/repository/org/apache/httpcomponents/httpmime/4.5.2/httpmime-4.5.2.jar:/Users/apple/.m2/repository/net/jpountz/lz4/lz4/1.3.0/lz4-1.3.0.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/core/jackson-databind/2.7.3/jackson-databind-2.7.3.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.7.0/jackson-annotations-2.7.0.jar:/Users/apple/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.7.3/jackson-core-2.7.3.jar:/Users/apple/.m2/repository/com/google/guava/guava/19.0/guava-19.0.jar:/Users/apple/.m2/repository/com/alibaba/ververica/flink-connector-mysql-cdc/1.1.0/flink-connector-mysql-cdc-1.1.0.jar:/Users/apple/.m2/repository/cn/hutool/hutool-all/5.5.8/hutool-all-5.5.8.jar fny.dwh.ods.business.cdc.Ts SLF4J: Class path contains multiple SLF4J bindings. SLF4J: Found binding in [jar:file:/Users/apple/.m2/repository/org/slf4j/slf4j-log4j12/1.7.5/slf4j-log4j12-1.7.5.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: Found binding in [jar:file:/Users/apple/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.6.2/log4j-slf4j-impl-2.6.2.jar!/org/slf4j/impl/StaticLoggerBinder.class] SLF4J: See http://www.slf4j.org/codes.html#multiple_bindings for an explanation. SLF4J: Actual binding is of type [org.slf4j.impl.Log4jLoggerFactory] WARNING: An illegal reflective access operation has occurred WARNING: Illegal reflective access by org.apache.flink.api.java.ClosureCleaner (file:/Users/apple/.m2/repository/org/apache/flink/flink-core/1.12.0/flink-core-1.12.0.jar) to field java.util.Properties.serialVersionUID WARNING: Please consider reporting this to the maintainers of org.apache.flink.api.java.ClosureCleaner WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations WARNING: All illegal access operations will be denied in a future release 15:13:21,688 ERROR com.alibaba.ververica.cdc.debezium.DebeziumSourceFunction - Reporting error: java.lang.NoSuchMethodError: 'void sun.misc.Unsafe.monitorEnter(java.lang.Object)' at com.alibaba.ververica.cdc.debezium.internal.DebeziumChangeConsumer.handleBatch(DebeziumChangeConsumer.java:101) at io.debezium.embedded.ConvertingEngineBuilder.lambda$notifying$2(ConvertingEngineBuilder.java:81) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:812) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:170) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) 15:13:21,858 ERROR io.debezium.connector.mysql.SnapshotReader - Failed due to error: Aborting snapshot due to error when last running 'SELECT * FROM ttjb-test.cms_article': Can''t call rollback when autocommit=true org.apache.kafka.connect.errors.ConnectException: Can''t call rollback when autocommit=true Error code: 0; SQLSTATE: 08003. at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230) at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:207) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:831) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Caused by: java.sql.SQLNonTransientConnectionException: Can''t call rollback when autocommit=true at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63) at com.mysql.cj.jdbc.ConnectionImpl.rollback(ConnectionImpl.java:1851) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:740) ... 3 more 15:13:21,893 ERROR io.debezium.connector.mysql.SnapshotReader - Execption while rollback is executed java.sql.SQLNonTransientConnectionException: Can''t call rollback when autocommit=true at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:110) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:97) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:89) at com.mysql.cj.jdbc.exceptions.SQLError.createSQLException(SQLError.java:63) at com.mysql.cj.jdbc.ConnectionImpl.rollback(ConnectionImpl.java:1851) at io.debezium.connector.mysql.SnapshotReader.execute(SnapshotReader.java:841) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834) Exception in thread "main" org.apache.flink.runtime.client.JobExecutionException: Job execution failed. at org.apache.flink.runtime.jobmaster.JobResult.toJobExecutionResult(JobResult.java:147) at org.apache.flink.runtime.minicluster.MiniClusterJobClient.lambda$getJobExecutionResult$2(MiniClusterJobClient.java:119) at java.base/java.util.concurrent.CompletableFuture$UniApply.tryFire(CompletableFuture.java:642) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.runtime.rpc.akka.AkkaInvocationHandler.lambda$invokeRpc$0(AkkaInvocationHandler.java:229) at java.base/java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:859) at java.base/java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:837) at java.base/java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:506) at java.base/java.util.concurrent.CompletableFuture.complete(CompletableFuture.java:2073) at org.apache.flink.runtime.concurrent.FutureUtils$1.onComplete(FutureUtils.java:996) 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:60) at org.apache.flink.runtime.concurrent.Executors$DirectExecutionContext.execute(Executors.java:74) at scala.concurrent.impl.CallbackRunnable.executeWithValue(Promise.scala:68) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1(Promise.scala:284) at scala.concurrent.impl.Promise$DefaultPromise.$anonfun$tryComplete$1$adapted(Promise.scala:284) at scala.concurrent.impl.Promise$DefaultPromise.tryComplete(Promise.scala:284) at akka.pattern.PromiseActorRef.$bang(AskSupport.scala:573) 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(Future.scala:532) at scala.concurrent.impl.Promise.liftedTree1$1(Promise.scala:29) at scala.concurrent.impl.Promise.$anonfun$transform$1(Promise.scala:29) at scala.concurrent.impl.CallbackRunnable.run(Promise.scala:60) at akka.dispatch.BatchingExecutor$AbstractBatch.processBatch(BatchingExecutor.scala:55) at akka.dispatch.BatchingExecutor$BlockableBatch.$anonfun$run$1(BatchingExecutor.scala:91) at scala.runtime.java8.JFunction0$mcV$sp.apply(JFunction0$mcV$sp.java:12) at scala.concurrent.BlockContext$.withBlockContext(BlockContext.scala:81) at akka.dispatch.BatchingExecutor$BlockableBatch.run(BatchingExecutor.scala:91) 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:116) at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:78) at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:224) at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:217) at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:208) at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:610) at org.apache.flink.runtime.scheduler.SchedulerNG.updateTaskExecutionState(SchedulerNG.java:89) at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:419) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method) at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) at java.base/java.lang.reflect.Method.invoke(Method.java:566) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:286) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:201) at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74) at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:154) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:26) at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:21) at scala.PartialFunction.applyOrElse(PartialFunction.scala:123) at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122) at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:21) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172) at akka.actor.Actor.aroundReceive(Actor.scala:517) at akka.actor.Actor.aroundReceive$(Actor.scala:515) 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.NoSuchMethodError: 'void sun.misc.Unsafe.monitorEnter(java.lang.Object)' at com.alibaba.ververica.cdc.debezium.internal.DebeziumChangeConsumer.handleBatch(DebeziumChangeConsumer.java:101) at io.debezium.embedded.ConvertingEngineBuilder.lambda$notifying$2(ConvertingEngineBuilder.java:81) at io.debezium.embedded.EmbeddedEngine.run(EmbeddedEngine.java:812) at io.debezium.embedded.ConvertingEngineBuilder$2.run(ConvertingEngineBuilder.java:170) at java.base/java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1128) at java.base/java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:628) at java.base/java.lang.Thread.run(Thread.java:834)

Process finished with exit code 1

gyp03 commented 3 years ago

已解决，是jdk版本问题，运行版本选择了11，应选择8