search

DTStack / chunjun

A data integration framework
https://dtstack.github.io/chunjun/
Apache License 2.0
3.99k stars 1.69k forks source link

mysql bin log报错Caused by: java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps #297

Closed xunchangguo closed 3 years ago

xunchangguo commented 3 years ago

error log

C:\Java\jdk1.8.0_202\bin\java.exe "-javaagent:C:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2020.2.3\lib\idea_rt.jar=59768:C:\Program Files\JetBrains\IntelliJ IDEA Community Edition 2020.2.3\bin" -Dfile.encoding=UTF-8 -classpath C:\Java\jdk1.8.0_202\jre\lib\charsets.jar;C:\Java\jdk1.8.0_202\jre\lib\deploy.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\access-bridge-64.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\cldrdata.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\dnsns.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\jaccess.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\jfxrt.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\localedata.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\nashorn.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\sunec.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\sunjce_provider.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\sunmscapi.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\sunpkcs11.jar;C:\Java\jdk1.8.0_202\jre\lib\ext\zipfs.jar;C:\Java\jdk1.8.0_202\jre\lib\javaws.jar;C:\Java\jdk1.8.0_202\jre\lib\jce.jar;C:\Java\jdk1.8.0_202\jre\lib\jfr.jar;C:\Java\jdk1.8.0_202\jre\lib\jfxswt.jar;C:\Java\jdk1.8.0_202\jre\lib\jsse.jar;C:\Java\jdk1.8.0_202\jre\lib\management-agent.jar;C:\Java\jdk1.8.0_202\jre\lib\plugin.jar;C:\Java\jdk1.8.0_202\jre\lib\resources.jar;C:\Java\jdk1.8.0_202\jre\lib\rt.jar;C:\opensource\flinkx\flinkx-1.10.1\flinkx-launcher\target\classes;C:\opensource\flinkx\flinkx-1.10.1\flinkx-core\target\classes;C:\Users\13552\.m2\repository\org\slf4j\slf4j-api\1.7.20\slf4j-api-1.7.20.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-core\1.10.0\flink-core-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-annotations\1.10.0\flink-annotations-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-metrics-core\1.10.0\flink-metrics-core-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-shaded-asm-7\7.1-9.0\flink-shaded-asm-7-7.1-9.0.jar;C:\Users\13552\.m2\repository\org\apache\commons\commons-lang3\3.3.2\commons-lang3-3.3.2.jar;C:\Users\13552\.m2\repository\com\esotericsoftware\kryo\kryo\2.24.0\kryo-2.24.0.jar;C:\Users\13552\.m2\repository\com\esotericsoftware\minlog\minlog\1.2\minlog-1.2.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-shaded-guava\18.0-9.0\flink-shaded-guava-18.0-9.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\force-shading\1.10.0\force-shading-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-runtime-web_2.11\1.10.0\flink-runtime-web_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-runtime_2.11\1.10.0\flink-runtime_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-queryable-state-client-java\1.10.0\flink-queryable-state-client-java-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-hadoop-fs\1.10.0\flink-hadoop-fs-1.10.0.jar;C:\Users\13552\.m2\repository\org\scala-lang\scala-library\2.11.12\scala-library-2.11.12.jar;C:\Users\13552\.m2\repository\com\typesafe\akka\akka-actor_2.11\2.5.21\akka-actor_2.11-2.5.21.jar;C:\Users\13552\.m2\repository\com\typesafe\config\1.3.3\config-1.3.3.jar;C:\Users\13552\.m2\repository\org\scala-lang\modules\scala-java8-compat_2.11\0.7.0\scala-java8-compat_2.11-0.7.0.jar;C:\Users\13552\.m2\repository\com\typesafe\akka\akka-stream_2.11\2.5.21\akka-stream_2.11-2.5.21.jar;C:\Users\13552\.m2\repository\org\reactivestreams\reactive-streams\1.0.2\reactive-streams-1.0.2.jar;C:\Users\13552\.m2\repository\com\typesafe\ssl-config-core_2.11\0.3.7\ssl-config-core_2.11-0.3.7.jar;C:\Users\13552\.m2\repository\org\scala-lang\modules\scala-parser-combinators_2.11\1.1.1\scala-parser-combinators_2.11-1.1.1.jar;C:\Users\13552\.m2\repository\com\typesafe\akka\akka-protobuf_2.11\2.5.21\akka-protobuf_2.11-2.5.21.jar;C:\Users\13552\.m2\repository\com\typesafe\akka\akka-slf4j_2.11\2.5.21\akka-slf4j_2.11-2.5.21.jar;C:\Users\13552\.m2\repository\org\clapper\grizzled-slf4j_2.11\1.3.2\grizzled-slf4j_2.11-1.3.2.jar;C:\Users\13552\.m2\repository\com\github\scopt\scopt_2.11\3.5.0\scopt_2.11-3.5.0.jar;C:\Users\13552\.m2\repository\com\twitter\chill_2.11\0.7.6\chill_2.11-0.7.6.jar;C:\Users\13552\.m2\repository\com\twitter\chill-java\0.7.6\chill-java-0.7.6.jar;C:\Users\13552\.m2\repository\org\lz4\lz4-java\1.5.0\lz4-java-1.5.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-shaded-netty\4.1.39.Final-9.0\flink-shaded-netty-4.1.39.Final-9.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-shaded-jackson\2.10.1-9.0\flink-shaded-jackson-2.10.1-9.0.jar;C:\Users\13552\.m2\repository\org\javassist\javassist\3.24.0-GA\javassist-3.24.0-GA.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-streaming-java_2.11\1.10.0\flink-streaming-java_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-clients_2.11\1.10.0\flink-clients_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-optimizer_2.11\1.10.0\flink-optimizer_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-java\1.10.0\flink-java-1.10.0.jar;C:\Users\13552\.m2\repository\commons-cli\commons-cli\1.3.1\commons-cli-1.3.1.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-hadoop-compatibility_2.11\1.10.0\flink-hadoop-compatibility_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-yarn_2.11\1.10.0\flink-yarn_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-shaded-hadoop-2\2.4.1-9.0\flink-shaded-hadoop-2-2.4.1-9.0.jar;C:\Users\13552\.m2\repository\commons-el\commons-el\1.0\commons-el-1.0.jar;C:\Users\13552\.m2\repository\commons-beanutils\commons-beanutils\1.9.3\commons-beanutils-1.9.3.jar;C:\Users\13552\.m2\repository\org\apache\flink\flink-queryable-state-runtime_2.11\1.10.0\flink-queryable-state-runtime_2.11-1.10.0.jar;C:\Users\13552\.m2\repository\org\apache\httpcomponents\httpcore\4.4.6\httpcore-4.4.6.jar;C:\Users\13552\.m2\repository\org\apache\httpcomponents\httpclient\4.5.3\httpclient-4.5.3.jar;C:\Users\13552\.m2\repository\com\fasterxml\jackson\core\jackson-databind\2.9.10.3\jackson-databind-2.9.10.3.jar;C:\Users\13552\.m2\repository\com\fasterxml\jackson\core\jackson-annotations\2.9.10\jackson-annotations-2.9.10.jar;C:\Users\13552\.m2\repository\com\fasterxml\jackson\core\jackson-core\2.9.10\jackson-core-2.9.10.jar;C:\Users\13552\.m2\repository\io\prometheus\simpleclient_pushgateway\0.5.0\simpleclient_pushgateway-0.5.0.jar;C:\Users\13552\.m2\repository\io\prometheus\simpleclient_common\0.5.0\simpleclient_common-0.5.0.jar;C:\Users\13552\.m2\repository\io\prometheus\simpleclient\0.5.0\simpleclient-0.5.0.jar;C:\Users\13552\.m2\repository\ch\qos\logback\logback-classic\1.1.7\logback-classic-1.1.7.jar;C:\Users\13552\.m2\repository\ch\qos\logback\logback-core\1.1.7\logback-core-1.1.7.jar;C:\Users\13552\.m2\repository\com\google\code\gson\gson\2.7\gson-2.7.jar;C:\Users\13552\.m2\repository\com\google\guava\guava\19.0\guava-19.0.jar;C:\Users\13552\.m2\repository\commons-codec\commons-codec\1.9\commons-codec-1.9.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-hdfs\2.7.3\hadoop-hdfs-2.7.3.jar;C:\Users\13552\.m2\repository\org\mortbay\jetty\jetty\6.1.26\jetty-6.1.26.jar;C:\Users\13552\.m2\repository\org\mortbay\jetty\jetty-util\6.1.26\jetty-util-6.1.26.jar;C:\Users\13552\.m2\repository\com\sun\jersey\jersey-core\1.9\jersey-core-1.9.jar;C:\Users\13552\.m2\repository\com\sun\jersey\jersey-server\1.9\jersey-server-1.9.jar;C:\Users\13552\.m2\repository\asm\asm\3.1\asm-3.1.jar;C:\Users\13552\.m2\repository\commons-io\commons-io\2.4\commons-io-2.4.jar;C:\Users\13552\.m2\repository\commons-lang\commons-lang\2.6\commons-lang-2.6.jar;C:\Users\13552\.m2\repository\commons-logging\commons-logging\1.1.3\commons-logging-1.1.3.jar;C:\Users\13552\.m2\repository\commons-daemon\commons-daemon\1.0.13\commons-daemon-1.0.13.jar;C:\Users\13552\.m2\repository\log4j\log4j\1.2.17\log4j-1.2.17.jar;C:\Users\13552\.m2\repository\com\google\protobuf\protobuf-java\2.5.0\protobuf-java-2.5.0.jar;C:\Users\13552\.m2\repository\javax\servlet\servlet-api\2.5\servlet-api-2.5.jar;C:\Users\13552\.m2\repository\org\codehaus\jackson\jackson-core-asl\1.9.13\jackson-core-asl-1.9.13.jar;C:\Users\13552\.m2\repository\org\codehaus\jackson\jackson-mapper-asl\1.9.13\jackson-mapper-asl-1.9.13.jar;C:\Users\13552\.m2\repository\xmlenc\xmlenc\0.52\xmlenc-0.52.jar;C:\Users\13552\.m2\repository\io\netty\netty\3.6.2.Final\netty-3.6.2.Final.jar;C:\Users\13552\.m2\repository\io\netty\netty-all\4.0.23.Final\netty-all-4.0.23.Final.jar;C:\Users\13552\.m2\repository\xerces\xercesImpl\2.9.1\xercesImpl-2.9.1.jar;C:\Users\13552\.m2\repository\xml-apis\xml-apis\1.3.04\xml-apis-1.3.04.jar;C:\Users\13552\.m2\repository\org\apache\htrace\htrace-core\3.1.0-incubating\htrace-core-3.1.0-incubating.jar;C:\Users\13552\.m2\repository\org\fusesource\leveldbjni\leveldbjni-all\1.8\leveldbjni-all-1.8.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-common\2.7.3\hadoop-common-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-annotations\2.7.3\hadoop-annotations-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\commons\commons-math3\3.1.1\commons-math3-3.1.1.jar;C:\Users\13552\.m2\repository\commons-httpclient\commons-httpclient\3.1\commons-httpclient-3.1.jar;C:\Users\13552\.m2\repository\commons-net\commons-net\3.1\commons-net-3.1.jar;C:\Users\13552\.m2\repository\commons-collections\commons-collections\3.2.2\commons-collections-3.2.2.jar;C:\Users\13552\.m2\repository\javax\servlet\jsp\jsp-api\2.1\jsp-api-2.1.jar;C:\Users\13552\.m2\repository\com\sun\jersey\jersey-json\1.9\jersey-json-1.9.jar;C:\Users\13552\.m2\repository\org\codehaus\jettison\jettison\1.1\jettison-1.1.jar;C:\Users\13552\.m2\repository\com\sun\xml\bind\jaxb-impl\2.2.3-1\jaxb-impl-2.2.3-1.jar;C:\Users\13552\.m2\repository\net\java\dev\jets3t\jets3t\0.9.0\jets3t-0.9.0.jar;C:\Users\13552\.m2\repository\com\jamesmurty\utils\java-xmlbuilder\0.4\java-xmlbuilder-0.4.jar;C:\Users\13552\.m2\repository\commons-configuration\commons-configuration\1.6\commons-configuration-1.6.jar;C:\Users\13552\.m2\repository\commons-digester\commons-digester\1.8\commons-digester-1.8.jar;C:\Users\13552\.m2\repository\commons-beanutils\commons-beanutils-core\1.8.0\commons-beanutils-core-1.8.0.jar;C:\Users\13552\.m2\repository\org\slf4j\slf4j-log4j12\1.7.10\slf4j-log4j12-1.7.10.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-auth\2.7.3\hadoop-auth-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\directory\server\apacheds-kerberos-codec\2.0.0-M15\apacheds-kerberos-codec-2.0.0-M15.jar;C:\Users\13552\.m2\repository\org\apache\directory\server\apacheds-i18n\2.0.0-M15\apacheds-i18n-2.0.0-M15.jar;C:\Users\13552\.m2\repository\org\apache\directory\api\api-asn1-api\1.0.0-M20\api-asn1-api-1.0.0-M20.jar;C:\Users\13552\.m2\repository\org\apache\directory\api\api-util\1.0.0-M20\api-util-1.0.0-M20.jar;C:\Users\13552\.m2\repository\org\apache\curator\curator-framework\2.7.1\curator-framework-2.7.1.jar;C:\Users\13552\.m2\repository\com\jcraft\jsch\0.1.42\jsch-0.1.42.jar;C:\Users\13552\.m2\repository\org\apache\curator\curator-client\2.7.1\curator-client-2.7.1.jar;C:\Users\13552\.m2\repository\org\apache\curator\curator-recipes\2.7.1\curator-recipes-2.7.1.jar;C:\Users\13552\.m2\repository\com\google\code\findbugs\jsr305\3.0.0\jsr305-3.0.0.jar;C:\Users\13552\.m2\repository\org\apache\zookeeper\zookeeper\3.4.6\zookeeper-3.4.6.jar;C:\Users\13552\.m2\repository\org\apache\commons\commons-compress\1.4.1\commons-compress-1.4.1.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-yarn-common\2.7.3\hadoop-yarn-common-2.7.3.jar;C:\Users\13552\.m2\repository\javax\xml\bind\jaxb-api\2.2.2\jaxb-api-2.2.2.jar;C:\Users\13552\.m2\repository\javax\xml\stream\stax-api\1.0-2\stax-api-1.0-2.jar;C:\Users\13552\.m2\repository\javax\activation\activation\1.1\activation-1.1.jar;C:\Users\13552\.m2\repository\com\sun\jersey\jersey-client\1.9\jersey-client-1.9.jar;C:\Users\13552\.m2\repository\org\codehaus\jackson\jackson-jaxrs\1.9.13\jackson-jaxrs-1.9.13.jar;C:\Users\13552\.m2\repository\org\codehaus\jackson\jackson-xc\1.9.13\jackson-xc-1.9.13.jar;C:\Users\13552\.m2\repository\com\google\inject\extensions\guice-servlet\3.0\guice-servlet-3.0.jar;C:\Users\13552\.m2\repository\com\google\inject\guice\3.0\guice-3.0.jar;C:\Users\13552\.m2\repository\javax\inject\javax.inject\1\javax.inject-1.jar;C:\Users\13552\.m2\repository\aopalliance\aopalliance\1.0\aopalliance-1.0.jar;C:\Users\13552\.m2\repository\com\sun\jersey\contribs\jersey-guice\1.9\jersey-guice-1.9.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-yarn-client\2.7.3\hadoop-yarn-client-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-mapreduce-client-core\2.7.3\hadoop-mapreduce-client-core-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\hadoop\hadoop-yarn-api\2.7.3\hadoop-yarn-api-2.7.3.jar;C:\Users\13552\.m2\repository\org\apache\avro\avro\1.8.2\avro-1.8.2.jar;C:\Users\13552\.m2\repository\com\thoughtworks\paranamer\paranamer\2.7\paranamer-2.7.jar;C:\Users\13552\.m2\repository\org\xerial\snappy\snappy-java\1.1.1.3\snappy-java-1.1.1.3.jar;C:\Users\13552\.m2\repository\org\tukaani\xz\1.5\xz-1.5.jar;C:\Users\13552\.m2\repository\org\objenesis\objenesis\2.6\objenesis-2.6.jar com.dtstack.flinkx.launcher.Launcher -job binlog.json -pluginRoot syncplugins -jobid sync同步
SLF4J: Class path contains multiple SLF4J bindings.
SLF4J: Found binding in [jar:file:/C:/Users/13552/.m2/repository/ch/qos/logback/logback-classic/1.1.7/logback-classic-1.1.7.jar!/org/slf4j/impl/StaticLoggerBinder.class]
SLF4J: Found binding in [jar:file:/C:/Users/13552/.m2/repository/org/slf4j/slf4j-log4j12/1.7.10/slf4j-log4j12-1.7.10.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 [ch.qos.logback.classic.util.ContextSelectorStaticBinder]
17:11:46.698 [main] INFO com.dtstack.flinkx.classloader.ClassLoaderManager - jarUrl:file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/binlogreader/flinkx-binlog-reader-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-core-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-reader-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-writer-release_1.10.1.jar create ClassLoad successful...
17:11:47.005 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - class org.apache.flink.types.Row does not contain a getter for field fields
17:11:47.005 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - class org.apache.flink.types.Row does not contain a setter for field fields
17:11:47.005 [main] INFO org.apache.flink.api.java.typeutils.TypeExtractor - Class class org.apache.flink.types.Row cannot be used as a POJO type because not all fields are valid POJO fields, and must be processed as GenericType. Please read the Flink documentation on "Data Types & Serialization" for details of the effect on performance.
17:11:47.020 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the org.apache.flink.api.java.typeutils.GenericTypeInfo
17:11:47.021 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Class
17:11:47.036 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the com.dtstack.flinkx.binlog.reader.BinlogInputFormat
17:11:47.044 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the com.dtstack.flinkx.binlog.reader.BinlogConfig
17:11:47.045 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.045 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.053 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.054 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.055 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.util.LinkedHashMap
17:11:47.056 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.058 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.058 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.058 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.058 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Long
17:11:47.058 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.util.ArrayList
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Long
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.059 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.060 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.060 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.060 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.060 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.063 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.util.ArrayList
17:11:47.081 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.082 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.133 [main] INFO com.dtstack.flinkx.classloader.ClassLoaderManager - jarUrl:file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-core-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-reader-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/common/flinkx-rdb-writer-release_1.10.1.jar_file:/C:/opensource/flinkx/flinkx-1.10.1/syncplugins/streamwriter/flinkx-stream-writer-release_1.10.1.jar create ClassLoad successful...
17:11:47.152 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the com.dtstack.flinkx.stream.writer.StreamOutputFormat
17:11:47.152 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.153 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.String
17:11:47.153 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the [C
17:11:47.153 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Integer
17:11:47.153 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.util.ArrayList
17:11:47.160 [main] DEBUG org.apache.flink.api.java.ClosureCleaner - Dig to clean the java.lang.Boolean
17:11:47.187 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraphGenerator - Transforming SinkTransformation{id=2, name='streamwriter', outputType=GenericType<java.lang.Object>, parallelism=1}
17:11:47.188 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraphGenerator - Transforming SourceTransformation{id=1, name='binlogreader', outputType=GenericType<org.apache.flink.types.Row>, parallelism=1}
17:11:47.211 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraph - Vertex: 1
17:11:47.213 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraph - Vertex: 2
17:11:47.260 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraphHasherV2 - Generated hash 'cbc357ccb763df2852fee8c4fc7d55f2' for node 'Source: binlogreader-1' {id: 1, parallelism: 1, user function: }
17:11:47.262 [main] DEBUG org.apache.flink.streaming.api.graph.StreamGraphHasherV2 - Generated hash '7df19f87deec5680128845fd9a6ca18d' for node 'Sink: streamwriter-2' {id: 2, parallelism: 1, user function: }
17:11:47.335 [main] DEBUG org.apache.flink.streaming.api.graph.StreamingJobGraphGenerator - Parallelism set: 1 for 1
17:11:47.659 [main] DEBUG org.apache.flink.core.fs.FileSystem - Loading extension file systems via services
17:11:47.681 [main] INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The configuration option Key: 'taskmanager.cpu.cores' , default: null (fallback keys: []) required for local execution is not set, setting it to its default value 1.7976931348623157E308
17:11:47.681 [main] INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The configuration option Key: 'taskmanager.memory.task.heap.size' , default: null (fallback keys: []) required for local execution is not set, setting it to its default value 9223372036854775807 bytes
17:11:47.687 [main] INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The configuration option Key: 'taskmanager.memory.task.off-heap.size' , default: 0 bytes (fallback keys: []) required for local execution is not set, setting it to its default value 9223372036854775807 bytes
17:11:47.688 [main] INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The configuration option Key: 'taskmanager.memory.network.min' , default: 64 mb (fallback keys: [{key=taskmanager.network.memory.min, isDeprecated=true}]) required for local execution is not set, setting it to its default value 64 mb
17:11:47.688 [main] INFO org.apache.flink.runtime.taskexecutor.TaskExecutorResourceUtils - The configuration option Key: 'taskmanager.memory.network.max' , default: 1 gb (fallback keys: [{key=taskmanager.network.memory.max, isDeprecated=true}]) required for local execution is not set, setting it to its default value 64 mb
17:11:47.689 [main] INFO org.apache.flink.streaming.api.environment.LocalStreamEnvironment - Running job on local embedded Flink mini cluster
17:11:47.746 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Flink Mini Cluster
17:11:47.746 [main] DEBUG org.apache.flink.runtime.minicluster.MiniCluster - Using configuration MiniClusterConfiguration {singleRpcService=SHARED, numTaskManagers=1, commonBindAddress='null', config={rest.bind-port=0, taskmanager.memory.network.max=64 mb, jobmanager.scheduler=ng, taskmanager.memory.network.min=64 mb, taskmanager.memory.managed.size=512M, taskmanager.numberOfTaskSlots=1, taskmanager.cpu.cores=1.7976931348623157E308, taskmanager.memory.task.heap.size=9223372036854775807 bytes, taskmanager.memory.task.off-heap.size=9223372036854775807 bytes, rest.address=localhost}}
17:11:47.750 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting Metrics Registry
17:11:47.850 [main] INFO org.apache.flink.runtime.metrics.MetricRegistryImpl - No metrics reporter configured, no metrics will be exposed/reported.
17:11:47.850 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting RPC Service(s)
17:11:48.629 [flink-akka.actor.default-dispatcher-2] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
17:11:48.637 [flink-akka.actor.default-dispatcher-2] DEBUG akka.event.EventStream - logger log1-Slf4jLogger started
17:11:48.639 [flink-akka.actor.default-dispatcher-2] DEBUG akka.event.EventStream - Default Loggers started
17:11:48.839 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Trying to start actor system at :0
17:11:48.849 [main] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Using akka configuration
 Config(SimpleConfigObject({"akka":{"actor":{"default-dispatcher":{"executor":"thread-pool-executor","thread-pool-executor":{"core-pool-size-max":1,"core-pool-size-min":1},"thread-priority":1,"throughput":15,"type":"akka.dispatch.PriorityThreadsDispatcher"},"guardian-supervisor-strategy":"org.apache.flink.runtime.akka.StoppingSupervisorWithoutLoggingActorKilledExceptionStrategy","provider":"akka.remote.RemoteActorRefProvider","warn-about-java-serializer-usage":"off"},"daemonic":"off","jvm-exit-on-fatal-error":"on","log-config-on-start":"off","log-dead-letters":"off","log-dead-letters-during-shutdown":"off","loggers":["akka.event.slf4j.Slf4jLogger"],"logging-filter":"akka.event.slf4j.Slf4jLoggingFilter","loglevel":"DEBUG","remote":{"log-remote-lifecycle-events":"off","netty":{"tcp":{"bind-hostname":"0.0.0.0","bind-port":0,"client-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"connection-timeout":"20000ms","hostname":"","maximum-frame-size":"10485760b","port":0,"server-socket-worker-pool":{"pool-size-factor":1,"pool-size-max":2,"pool-size-min":1},"tcp-nodelay":"on","transport-class":"akka.remote.transport.netty.NettyTransport"}},"retry-gate-closed-for":"50 ms","startup-timeout":"100000ms","transport-failure-detector":{"acceptable-heartbeat-pause":"6000000ms","heartbeat-interval":"1000000ms","threshold":300}},"serialize-messages":"off","stdout-loglevel":"OFF"}}))
17:11:48.910 [flink-metrics-2] INFO akka.event.slf4j.Slf4jLogger - Slf4jLogger started
17:11:48.912 [flink-metrics-2] DEBUG akka.event.EventStream - logger log1-Slf4jLogger started
17:11:48.912 [flink-metrics-2] DEBUG akka.event.EventStream - Default Loggers started
17:11:48.930 [flink-metrics-2] INFO akka.remote.Remoting - Starting remoting
17:11:48.983 [flink-metrics-akka.remote.default-remote-dispatcher-4] DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Using select timeout of 500
17:11:48.983 [flink-metrics-akka.remote.default-remote-dispatcher-4] DEBUG org.apache.flink.shaded.akka.org.jboss.netty.channel.socket.nio.SelectorUtil - Epoll-bug workaround enabled = false
17:11:49.118 [flink-metrics-2] INFO akka.remote.Remoting - Remoting started; listening on addresses :[akka.tcp://flink-metrics@10.222.5.114:59800]
17:11:49.156 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils - Actor system started at akka.tcp://flink-metrics@10.222.5.114:59800
17:11:49.165 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/MetricQueryService .
17:11:49.271 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting high-availability services
17:11:49.294 [main] INFO org.apache.flink.runtime.blob.BlobServer - Created BLOB server storage directory C:\Users\13552\AppData\Local\Temp\blobStore-15206286-96e2-4ab0-959e-c7a50eb869d5
17:11:49.300 [main] DEBUG org.apache.flink.util.NetUtils - Trying to open socket on port 0
17:11:49.300 [main] INFO org.apache.flink.runtime.blob.BlobServer - Started BLOB server at 0.0.0.0:59802 - max concurrent requests: 50 - max backlog: 1000
17:11:49.306 [main] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Created BLOB cache storage directory C:\Users\13552\AppData\Local\Temp\blobStore-51f91c59-8b3e-4cb2-a791-fa3105ffc181
17:11:49.308 [main] INFO org.apache.flink.runtime.blob.TransientBlobCache - Created BLOB cache storage directory C:\Users\13552\AppData\Local\Temp\blobStore-2f1c9fa6-b460-481b-adf2-331e8a3cbcbc
17:11:49.309 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Starting 1 TaskManger(s)
17:11:49.314 [main] INFO org.apache.flink.runtime.taskexecutor.TaskManagerRunner - Starting TaskManager with ResourceID: f173ddab-227e-447e-b258-ea63a94e9712
17:11:49.325 [main] WARN org.apache.flink.runtime.taskmanager.TaskManagerLocation - No hostname could be resolved for the IP address 127.0.0.1, using IP address as host name. Local input split assignment (such as for HDFS files) may be impacted.
17:11:49.337 [main] INFO org.apache.flink.runtime.taskexecutor.TaskManagerServices - Temporary file directory 'C:\Users\13552\AppData\Local\Temp': total 237 GB, usable 143 GB (60.34% usable)
17:11:49.346 [main] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager uses directory C:\Users\13552\AppData\Local\Temp\flink-io-54f1e050-03b9-4a52-9128-c8a1e15101c5 for spill files.
17:11:49.367 [main] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager uses directory C:\Users\13552\AppData\Local\Temp\flink-netty-shuffle-ab91c5c6-0977-4f5f-8aa9-8726eb220162 for spill files.
17:11:49.418 [main] INFO org.apache.flink.runtime.io.network.buffer.NetworkBufferPool - Allocated 64 MB for network buffer pool (number of memory segments: 2048, bytes per segment: 32768).
17:11:49.432 [main] INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Starting the network environment and its components.
17:11:49.432 [main] DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Starting network connection manager
17:11:49.435 [main] INFO org.apache.flink.runtime.taskexecutor.KvStateService - Starting the kvState service and its components.
17:11:49.435 [main] WARN org.apache.flink.runtime.taskmanager.TaskManagerLocation - No hostname could be resolved for the IP address 127.0.0.1, using IP address as host name. Local input split assignment (such as for HDFS files) may be impacted.
17:11:49.450 [main] INFO org.apache.flink.runtime.taskexecutor.TaskManagerConfiguration - Messages have a max timeout of 10000 ms
17:11:49.518 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.taskexecutor.TaskExecutor at akka://flink/user/taskmanager_0 .
17:11:49.539 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Start job leader service.
17:11:49.541 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.filecache.FileCache - User file cache uses directory C:\Users\13552\AppData\Local\Temp\flink-dist-cache-2afcef05-c479-44c9-97aa-d8adbbe55799
17:11:49.630 [main] DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory - Starting Dispatcher REST endpoint.
17:11:49.630 [main] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Starting rest endpoint.
17:11:49.948 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.logging.InternalLoggerFactory - Using SLF4J as the default logging framework
17:11:49.950 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.initialSize: 1024
17:11:49.950 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.InternalThreadLocalMap - -Dio.netty.threadLocalMap.stringBuilder.maxSize: 4096
17:11:50.050 [main] WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - Log file environment variable 'log.file' is not set.
17:11:50.050 [main] WARN org.apache.flink.runtime.webmonitor.WebMonitorUtils - JobManager log files are unavailable in the web dashboard. Log file location not found in environment variable 'log.file' or configuration key 'Key: 'web.log.path' , default: null (fallback keys: [{key=jobmanager.web.log.path, isDeprecated=true}])'.
17:11:50.097 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - Platform: Windows
17:11:50.099 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - -Dio.netty.noUnsafe: false
17:11:50.099 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - Java version: 8
17:11:50.100 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.theUnsafe: available
17:11:50.101 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - sun.misc.Unsafe.copyMemory: available
17:11:50.101 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Buffer.address: available
17:11:50.101 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - direct buffer constructor: available
17:11:50.102 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.Bits.unaligned: available, true
17:11:50.102 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - jdk.internal.misc.Unsafe.allocateUninitializedArray(int): unavailable prior to Java9
17:11:50.102 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent0 - java.nio.DirectByteBuffer.<init>(long, int): available
17:11:50.102 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - sun.misc.Unsafe: available
17:11:50.102 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.tmpdir: C:\Users\13552\AppData\Local\Temp (java.io.tmpdir)
17:11:50.103 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.bitMode: 64 (sun.arch.data.model)
17:11:50.104 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.maxDirectMemory: 1857028096 bytes
17:11:50.104 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.uninitializedArrayAllocationThreshold: -1
17:11:50.105 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.CleanerJava6 - java.nio.ByteBuffer.cleaner(): available
17:11:50.105 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - -Dio.netty.noPreferDirect: false
17:11:50.107 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@6631cb64 under DELETE@/v1/cluster.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ShutdownHandler@6631cb64 under DELETE@/cluster.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@3cbf1ba4 under GET@/v1/config.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.DashboardConfigHandler@3cbf1ba4 under GET@/config.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarListHandler@10bea4 under GET@/v1/jars.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarListHandler@10bea4 under GET@/jars.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler@7e2c64 under POST@/v1/jars/upload.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler@7e2c64 under POST@/jars/upload.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler@7c1e32c9 under DELETE@/v1/jars/:jarid.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarDeleteHandler@7c1e32c9 under DELETE@/jars/:jarid.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@383864d5 under GET@/v1/jars/:jarid/plan.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@383864d5 under GET@/jars/:jarid/plan.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@3dd818e8 under GET@/v1/jars/:jarid/plan.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarPlanHandler@3dd818e8 under GET@/jars/:jarid/plan.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarRunHandler@4cb40e3b under POST@/v1/jars/:jarid/run.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.webmonitor.handlers.JarRunHandler@4cb40e3b under POST@/jars/:jarid/run.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@41b1f51e under GET@/v1/jobmanager/config.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterConfigHandler@41b1f51e under GET@/jobmanager/config.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@3a543f31 under GET@/v1/jobmanager/log.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@3a543f31 under GET@/jobmanager/log.
17:11:50.108 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@47b67fcb under GET@/v1/jobmanager/metrics.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobManagerMetricsHandler@47b67fcb under GET@/jobmanager/metrics.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@2b9f74d0 under GET@/v1/jobmanager/stdout.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.ConstantTextHandler@2b9f74d0 under GET@/jobmanager/stdout.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@65c86db8 under GET@/v1/jobs.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobIdsHandler@65c86db8 under GET@/jobs.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@7efe7b87 under POST@/v1/jobs.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobSubmitHandler@7efe7b87 under POST@/jobs.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@ac20bb4 under GET@/v1/jobs/metrics.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingJobsMetricsHandler@ac20bb4 under GET@/jobs/metrics.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@5a2bd7c8 under GET@/v1/jobs/overview.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobsOverviewHandler@5a2bd7c8 under GET@/jobs/overview.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@7ca8d498 under GET@/v1/jobs/:jobid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobDetailsHandler@7ca8d498 under GET@/jobs/:jobid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7187bac9 under PATCH@/v1/jobs/:jobid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7187bac9 under PATCH@/jobs/:jobid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@6b8280e6 under GET@/v1/jobs/:jobid/accumulators.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobAccumulatorsHandler@6b8280e6 under GET@/jobs/:jobid/accumulators.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@6f139fc9 under GET@/v1/jobs/:jobid/checkpoints.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointingStatisticsHandler@6f139fc9 under GET@/jobs/:jobid/checkpoints.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@55259aa7 under GET@/v1/jobs/:jobid/checkpoints/config.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointConfigHandler@55259aa7 under GET@/jobs/:jobid/checkpoints/config.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@19382338 under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.CheckpointStatisticDetailsHandler@19382338 under GET@/jobs/:jobid/checkpoints/details/:checkpointid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@66420549 under GET@/v1/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid.
17:11:50.109 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.checkpoints.TaskCheckpointStatisticDetailsHandler@66420549 under GET@/jobs/:jobid/checkpoints/details/:checkpointid/subtasks/:vertexid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@15dc339f under GET@/v1/jobs/:jobid/config.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobConfigHandler@15dc339f under GET@/jobs/:jobid/config.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@6cd56321 under GET@/v1/jobs/:jobid/exceptions.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExceptionsHandler@6cd56321 under GET@/jobs/:jobid/exceptions.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@34acbc60 under GET@/v1/jobs/:jobid/execution-result.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobExecutionResultHandler@34acbc60 under GET@/jobs/:jobid/execution-result.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@42b28ff1 under GET@/v1/jobs/:jobid/metrics.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobMetricsHandler@42b28ff1 under GET@/jobs/:jobid/metrics.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@36061cf3 under GET@/v1/jobs/:jobid/plan.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobPlanHandler@36061cf3 under GET@/jobs/:jobid/plan.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@718dbd79 under PATCH@/v1/jobs/:jobid/rescaling.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingTriggerHandler@718dbd79 under PATCH@/jobs/:jobid/rescaling.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@20134094 under GET@/v1/jobs/:jobid/rescaling/:triggerid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.rescaling.RescalingHandlers$RescalingStatusHandler@20134094 under GET@/jobs/:jobid/rescaling/:triggerid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@76889e60 under POST@/v1/jobs/:jobid/savepoints.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointTriggerHandler@76889e60 under POST@/jobs/:jobid/savepoints.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@706fe5c6 under GET@/v1/jobs/:jobid/savepoints/:triggerid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$SavepointStatusHandler@706fe5c6 under GET@/jobs/:jobid/savepoints/:triggerid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@6c15e8c7 under POST@/v1/jobs/:jobid/stop.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointHandlers$StopWithSavepointHandler@6c15e8c7 under POST@/jobs/:jobid/stop.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@56380231 under GET@/v1/jobs/:jobid/vertices/:vertexid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexDetailsHandler@56380231 under GET@/jobs/:jobid/vertices/:vertexid.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@64f1fd08 under GET@/v1/jobs/:jobid/vertices/:vertexid/accumulators.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexAccumulatorsHandler@64f1fd08 under GET@/jobs/:jobid/vertices/:vertexid/accumulators.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@6b3f6585 under GET@/v1/jobs/:jobid/vertices/:vertexid/backpressure.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexBackPressureHandler@6b3f6585 under GET@/jobs/:jobid/vertices/:vertexid/backpressure.
17:11:50.110 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@282ffbf5 under GET@/v1/jobs/:jobid/vertices/:vertexid/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexMetricsHandler@282ffbf5 under GET@/jobs/:jobid/vertices/:vertexid/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@3e104d4b under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/accumulators.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksAllAccumulatorsHandler@3e104d4b under GET@/jobs/:jobid/vertices/:vertexid/subtasks/accumulators.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@55e2fe3c under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingSubtasksMetricsHandler@55e2fe3c under GET@/jobs/:jobid/vertices/:vertexid/subtasks/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@45e1aa48 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskCurrentAttemptDetailsHandler@45e1aa48 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@12c60152 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptDetailsHandler@12c60152 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@2e807c54 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtaskExecutionAttemptAccumulatorsHandler@2e807c54 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/attempts/:attempt/accumulators.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@6cd164a6 under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.SubtaskMetricsHandler@6cd164a6 under GET@/jobs/:jobid/vertices/:vertexid/subtasks/:subtaskindex/metrics.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@242a209e under GET@/v1/jobs/:jobid/vertices/:vertexid/subtasktimes.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.SubtasksTimesHandler@242a209e under GET@/jobs/:jobid/vertices/:vertexid/subtasktimes.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@64469d8 under GET@/v1/jobs/:jobid/vertices/:vertexid/taskmanagers.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobVertexTaskManagersHandler@64469d8 under GET@/jobs/:jobid/vertices/:vertexid/taskmanagers.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexWatermarksHandler@2b8bd798 under GET@/v1/jobs/:jobid/vertices/:vertexid/watermarks.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.JobVertexWatermarksHandler@2b8bd798 under GET@/jobs/:jobid/vertices/:vertexid/watermarks.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7187bac9 under GET@/v1/jobs/:jobid/yarn-cancel.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@7187bac9 under GET@/jobs/:jobid/yarn-cancel.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@4c18621b under GET@/v1/jobs/:jobid/yarn-stop.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.JobCancellationHandler@4c18621b under GET@/jobs/:jobid/yarn-stop.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@39c385d6 under GET@/v1/overview.
17:11:50.111 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.cluster.ClusterOverviewHandler@39c385d6 under GET@/overview.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@1cec219f under POST@/v1/savepoint-disposal.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalTriggerHandler@1cec219f under POST@/savepoint-disposal.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@692e028d under GET@/v1/savepoint-disposal/:triggerid.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.savepoints.SavepointDisposalHandlers$SavepointDisposalStatusHandler@692e028d under GET@/savepoint-disposal/:triggerid.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@6629ad09 under GET@/v1/taskmanagers.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagersHandler@6629ad09 under GET@/taskmanagers.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@43e1692f under GET@/v1/taskmanagers/metrics.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.AggregatingTaskManagersMetricsHandler@43e1692f under GET@/taskmanagers/metrics.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@3e7c4815 under GET@/v1/taskmanagers/:taskmanagerid.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerDetailsHandler@3e7c4815 under GET@/taskmanagers/:taskmanagerid.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@27df0f3d under GET@/v1/taskmanagers/:taskmanagerid/log.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerLogFileHandler@27df0f3d under GET@/taskmanagers/:taskmanagerid/log.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@c35af2a under GET@/v1/taskmanagers/:taskmanagerid/metrics.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.job.metrics.TaskManagerMetricsHandler@c35af2a under GET@/taskmanagers/:taskmanagerid/metrics.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@44550792 under GET@/v1/taskmanagers/:taskmanagerid/stdout.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.taskmanager.TaskManagerStdoutFileHandler@44550792 under GET@/taskmanagers/:taskmanagerid/stdout.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@1835d3ed under GET@/v1/:*.
17:11:50.112 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Register handler org.apache.flink.runtime.rest.handler.legacy.files.StaticFileServerHandler@1835d3ed under GET@/:*.
17:11:50.119 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.channel.MultithreadEventLoopGroup - -Dio.netty.eventLoopThreads: 16
17:11:50.141 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.noKeySetOptimization: false
17:11:50.142 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop - -Dio.netty.selectorAutoRebuildThreshold: 512
17:11:50.150 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.internal.PlatformDependent - org.jctools-core.MpscChunkedArrayQueue: available
17:11:50.184 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId - -Dio.netty.processId: 4980 (auto-detected)
17:11:50.186 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - -Djava.net.preferIPv4Stack: false
17:11:50.186 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - -Djava.net.preferIPv6Addresses: false
17:11:50.311 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - Loopback interface: lo (Software Loopback Interface 1, 127.0.0.1)
17:11:50.312 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.NetUtil - Failed to get SOMAXCONN from sysctl and file \proc\sys\net\core\somaxconn. Default: 200
17:11:50.439 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.channel.DefaultChannelId - -Dio.netty.machineId: f8:ac:65:ff:fe:f7:ba:2a (auto-detected)
17:11:50.455 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector - -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.level: simple
17:11:50.455 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.util.ResourceLeakDetector - -Dorg.apache.flink.shaded.netty4.io.netty.leakDetection.targetRecords: 4
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numHeapArenas: 16
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.numDirectArenas: 16
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.pageSize: 8192
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxOrder: 11
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.chunkSize: 16777216
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.tinyCacheSize: 512
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.smallCacheSize: 256
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.normalCacheSize: 64
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedBufferCapacity: 32768
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimInterval: 8192
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.cacheTrimIntervalMillis: 0
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.useCacheForAllThreads: true
17:11:50.491 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.PooledByteBufAllocator - -Dio.netty.allocator.maxCachedByteBuffersPerChunk: 1023
17:11:50.501 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.allocator.type: pooled
17:11:50.501 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.threadLocalDirectBufferSize: 0
17:11:50.501 [main] DEBUG org.apache.flink.shaded.netty4.io.netty.buffer.ByteBufUtil - -Dio.netty.maxThreadLocalCharBufferSize: 16384
17:11:50.517 [main] DEBUG org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Binding rest endpoint to null:0.
17:11:50.517 [main] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Rest endpoint listening at localhost:59838
17:11:50.519 [main] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender http://localhost:59838
17:11:50.521 [main] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Web frontend listening at http://localhost:59838.
17:11:50.521 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - http://localhost:59838 was granted leadership with leaderSessionID=d3ef221b-4658-487e-a491-031b9925e0a6
17:11:50.521 [mini-cluster-io-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader http://localhost:59838 , session=d3ef221b-4658-487e-a491-031b9925e0a6
17:11:50.534 [main] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.StandaloneResourceManager at akka://flink/user/resourcemanager .
17:11:50.547 [main] DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory - Starting Dispatcher.
17:11:50.551 [main] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender LeaderContender: DefaultDispatcherRunner
17:11:50.551 [main] DEBUG org.apache.flink.runtime.entrypoint.component.DefaultDispatcherResourceManagerComponentFactory - Starting ResourceManager.
17:11:50.551 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender LeaderContender: StandaloneResourceManager
17:11:50.552 [mini-cluster-io-thread-2] DEBUG org.apache.flink.runtime.dispatcher.runner.DefaultDispatcherRunner - Create new DispatcherLeaderProcess with leader session id 2c4366fb-be9c-4728-a29f-433fd97e22f2.
17:11:50.553 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - ResourceManager akka://flink/user/resourcemanager was granted leadership with fencing token 8a20f0492a5c7c7ec85e4c5b73424444
17:11:50.555 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Flink Mini Cluster started successfully
17:11:50.557 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Starting the SlotManager.
17:11:50.560 [mini-cluster-io-thread-2] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Start SessionDispatcherLeaderProcess.
17:11:50.560 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:11:50.560 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/resourcemanager , session=c85e4c5b-7342-4444-8a20-f0492a5c7c7e
17:11:50.560 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:11:50.562 [mini-cluster-io-thread-8] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Recover all persisted job graphs.
17:11:50.562 [mini-cluster-io-thread-8] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Successfully recovered 0 persisted job graphs.
17:11:50.563 [flink-akka.actor.default-dispatcher-4] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Connecting to ResourceManager akka://flink/user/resourcemanager(8a20f0492a5c7c7ec85e4c5b73424444).
17:11:50.563 [mini-cluster-io-thread-6] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway.
17:11:50.563 [mini-cluster-io-thread-7] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway.
17:11:50.569 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway.
17:11:50.573 [mini-cluster-io-thread-8] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/dispatcher .
17:11:50.583 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Resolved ResourceManager address, beginning registration
17:11:50.583 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Registration at ResourceManager attempt 1 (timeout=100ms)
17:11:50.587 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway.
17:11:50.592 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering TaskManager with ResourceID f173ddab-227e-447e-b258-ea63a94e9712 (akka://flink/user/taskmanager_0) at ResourceManager
17:11:50.595 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Successful registration at resource manager akka://flink/user/resourcemanager under registration id 7b6c019a96d054f53d362043565d5603.
17:11:50.596 [mini-cluster-io-thread-8] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/dispatcher , session=2c4366fb-be9c-4728-a29f-433fd97e22f2
17:11:50.596 [mini-cluster-io-thread-1] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway.
17:11:50.596 [mini-cluster-io-thread-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/dispatcher. Returning a org.apache.flink.runtime.dispatcher.DispatcherGateway gateway.
17:11:50.598 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Registering TaskManager f173ddab-227e-447e-b258-ea63a94e9712 under 7b6c019a96d054f53d362043565d5603 at the SlotManager.
17:11:50.609 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.blob.BlobClient - PUT BLOB stream to /127.0.0.1:59839.
17:11:50.609 [BLOB connection for /127.0.0.1:59839] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received PUT request for BLOB of job 096d4334a0974b13818a88ad07ff0a9b with from /127.0.0.1.
17:11:50.614 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.blob.BlobClient - PUT BLOB stream to /127.0.0.1:59839.
17:11:50.614 [BLOB connection for /127.0.0.1:59839] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received PUT request for BLOB of job 096d4334a0974b13818a88ad07ff0a9b with from /127.0.0.1.
17:11:50.618 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.blob.BlobClient - PUT BLOB stream to /127.0.0.1:59839.
17:11:50.618 [BLOB connection for /127.0.0.1:59839] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received PUT request for BLOB of job 096d4334a0974b13818a88ad07ff0a9b with from /127.0.0.1.
17:11:50.730 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.blob.BlobClient - PUT BLOB stream to /127.0.0.1:59839.
17:11:50.730 [BLOB connection for /127.0.0.1:59839] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received PUT request for BLOB of job 096d4334a0974b13818a88ad07ff0a9b with from /127.0.0.1.
17:11:50.735 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.blob.BlobClient - PUT BLOB stream to /127.0.0.1:59839.
17:11:50.735 [BLOB connection for /127.0.0.1:59839] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received PUT request for BLOB of job 096d4334a0974b13818a88ad07ff0a9b with from /127.0.0.1.
17:11:50.742 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Received JobGraph submission 096d4334a0974b13818a88ad07ff0a9b (sync同步).
17:11:50.743 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Submitting job 096d4334a0974b13818a88ad07ff0a9b (sync同步).
17:11:50.771 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Starting RPC endpoint for org.apache.flink.runtime.jobmaster.JobMaster at akka://flink/user/jobmanager_1 .
17:11:50.784 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Initializing job sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.809 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using restart back off time strategy NoRestartBackoffTimeStrategy for sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.862 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Running initialization on master for job sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.878 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Successfully ran initialization on master in 15 ms.
17:11:50.878 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Adding 1 vertices from job graph sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.878 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Attaching 1 topologically sorted vertices to existing job graph with 0 vertices and 0 intermediate results.
17:11:50.894 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.ExecutionGraph - Connecting ExecutionJobVertex cbc357ccb763df2852fee8c4fc7d55f2 (Source: binlogreader -> Sink: streamwriter) to 0 predecessors.
17:11:50.909 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Successfully created execution graph from job graph sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.927 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
17:11:50.940 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Status of the shared state registry of job 096d4334a0974b13818a88ad07ff0a9b after restore: SharedStateRegistry{registeredStates={}}.
17:11:50.941 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Resetting the master hooks.
17:11:50.944 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Start building failover regions.
17:11:50.944 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Creating a failover region with 1 vertices.
17:11:50.945 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Created 1 failover regions.
17:11:50.945 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Using failover strategy org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy@2953a2e0 for sync同步 (096d4334a0974b13818a88ad07ff0a9b).
17:11:50.950 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Proposing leadership to contender akka://flink/user/jobmanager_1
17:11:50.951 [mini-cluster-io-thread-4] INFO org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl - JobManager runner for job sync同步 (096d4334a0974b13818a88ad07ff0a9b) was granted leadership with session id 0d507a1d-b525-45a3-a6ca-2e67e87469c2 at akka://flink/user/jobmanager_1.
17:11:50.955 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting execution of job sync同步 (096d4334a0974b13818a88ad07ff0a9b) under job master id a6ca2e67e87469c20d507a1db52545a3.
17:11:50.957 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Starting scheduling with scheduling strategy [org.apache.flink.runtime.scheduler.strategy.EagerSchedulingStrategy]
17:11:50.958 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job sync同步 (096d4334a0974b13818a88ad07ff0a9b) switched from state CREATED to RUNNING.
17:11:50.967 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from CREATED to SCHEDULED.
17:11:50.972 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.scheduler.DefaultExecutionSlotAllocator - Allocate slot with id SlotRequestId{c2c0b3a5f8f9598d7addbf6f93b6e1c7} for execution cbc357ccb763df2852fee8c4fc7d55f2_0
17:11:50.974 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SchedulerImpl - Received slot request [SlotRequestId{c2c0b3a5f8f9598d7addbf6f93b6e1c7}] for task: null
17:11:50.985 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Cannot serve slot request, no ResourceManager connected. Adding as pending request [SlotRequestId{4ddd256595dd7feb84e15ed4514e9cb9}]
17:11:50.986 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager - Create multi task slot [SlotRequestId{94effbeb01efdef61a7991ce74541192}] in slot [SlotRequestId{4ddd256595dd7feb84e15ed4514e9cb9}].
17:11:50.988 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotSharingManager - Create single task slot [SlotRequestId{c2c0b3a5f8f9598d7addbf6f93b6e1c7}] in multi task slot [SlotRequestId{94effbeb01efdef61a7991ce74541192}] for group cbc357ccb763df2852fee8c4fc7d55f2.
17:11:50.994 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
17:11:50.994 [jobmanager-future-thread-1] INFO org.apache.flink.runtime.highavailability.nonha.embedded.EmbeddedLeaderService - Received confirmation of leadership for leader akka://flink/user/jobmanager_1 , session=0d507a1d-b525-45a3-a6ca-2e67e87469c2
17:11:50.995 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Connecting to ResourceManager akka://flink/user/resourcemanager(8a20f0492a5c7c7ec85e4c5b73424444)
17:11:50.996 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/resourcemanager. Returning a org.apache.flink.runtime.resourcemanager.ResourceManagerGateway gateway.
17:11:50.998 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Resolved ResourceManager address, beginning registration
17:11:50.998 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - Registration at ResourceManager attempt 1 (timeout=100ms)
17:11:50.999 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Add job 096d4334a0974b13818a88ad07ff0a9b to job leader id monitoring.
17:11:51.001 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registering job manager a6ca2e67e87469c20d507a1db52545a3@akka://flink/user/jobmanager_1 for job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.001 [mini-cluster-io-thread-2] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Found a new job leader 0d507a1d-b525-45a3-a6ca-2e67e87469c2@akka://flink/user/jobmanager_1.
17:11:51.001 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/jobmanager_1. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway.
17:11:51.007 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Registered job manager a6ca2e67e87469c20d507a1db52545a3@akka://flink/user/jobmanager_1 for job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.008 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.JobMaster - JobManager successfully registered at ResourceManager, leader id: 8a20f0492a5c7c7ec85e4c5b73424444.
17:11:51.009 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Requesting new slot [SlotRequestId{4ddd256595dd7feb84e15ed4514e9cb9}] and profile ResourceProfile{UNKNOWN} from resource manager.
17:11:51.011 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Request slot with profile ResourceProfile{UNKNOWN} for job 096d4334a0974b13818a88ad07ff0a9b with allocation id 8a02931e626afc20bbd5b4b76261f231.
17:11:51.017 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Receive slot request 8a02931e626afc20bbd5b4b76261f231 for job 096d4334a0974b13818a88ad07ff0a9b from resource manager with leader id 8a20f0492a5c7c7ec85e4c5b73424444.
17:11:51.027 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.memory.MemoryManager - Initialized MemoryManager with total memory size 536870912 ({OFF_HEAP=536870912}), page size 32768.
17:11:51.028 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Allocated slot for 8a02931e626afc20bbd5b4b76261f231.
17:11:51.028 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Add job 096d4334a0974b13818a88ad07ff0a9b for job leader monitoring.
17:11:51.030 [mini-cluster-io-thread-7] DEBUG org.apache.flink.runtime.taskexecutor.JobLeaderService - New leader information for job 096d4334a0974b13818a88ad07ff0a9b. Address: akka://flink/user/jobmanager_1, leader id: a6ca2e67e87469c20d507a1db52545a3.
17:11:51.031 [mini-cluster-io-thread-7] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Try to register at job manager akka://flink/user/jobmanager_1 with leader id 0d507a1d-b525-45a3-a6ca-2e67e87469c2.
17:11:51.032 [mini-cluster-io-thread-7] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/jobmanager_1. Returning a org.apache.flink.runtime.jobmaster.JobMasterGateway gateway.
17:11:51.033 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Resolved JobManager address, beginning registration
17:11:51.033 [flink-akka.actor.default-dispatcher-5] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Registration at JobManager attempt 1 (timeout=100ms)
17:11:51.034 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.rpc.akka.AkkaRpcService - Try to connect to remote RPC endpoint with address akka://flink/user/taskmanager_0. Returning a org.apache.flink.runtime.taskexecutor.TaskExecutorGateway gateway.
17:11:51.035 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Register new TaskExecutor f173ddab-227e-447e-b258-ea63a94e9712.
17:11:51.036 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Successful registration at job manager akka://flink/user/jobmanager_1 for job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.037 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Establish JobManager connection for job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.041 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Offer reserved slots to the leader of job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.047 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from SCHEDULED to DEPLOYING.
17:11:51.048 [flink-akka.actor.default-dispatcher-2] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Deploying Source: binlogreader -> Sink: streamwriter (1/1) (attempt #0) to f173ddab-227e-447e-b258-ea63a94e9712 @ 127.0.0.1 (dataPort=-1)
17:11:51.054 [flink-akka.actor.default-dispatcher-2] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Fulfilled slot request [SlotRequestId{4ddd256595dd7feb84e15ed4514e9cb9}] with allocated slot [8a02931e626afc20bbd5b4b76261f231].
17:11:51.063 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Registered new allocation id 8a02931e626afc20bbd5b4b76261f231 for local state stores for job 096d4334a0974b13818a88ad07ff0a9b.
17:11:51.066 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Registered new local state store with configuration LocalRecoveryConfig{localRecoveryMode=false, localStateDirectories=LocalRecoveryDirectoryProvider{rootDirectories=[C:\Users\13552\AppData\Local\Temp\localState\aid_8a02931e626afc20bbd5b4b76261f231], jobID=096d4334a0974b13818a88ad07ff0a9b, jobVertexID=cbc357ccb763df2852fee8c4fc7d55f2, subtaskIndex=0}} for 096d4334a0974b13818a88ad07ff0a9b - cbc357ccb763df2852fee8c4fc7d55f2 - 0 under allocation id 8a02931e626afc20bbd5b4b76261f231.
17:11:51.083 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Received task Source: binlogreader -> Sink: streamwriter (1/1).
17:11:51.084 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from CREATED to DEPLOYING.
17:11:51.084 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Creating FileSystem stream leak safety net for task Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) [DEPLOYING]
17:11:51.090 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Loading JAR files for task Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) [DEPLOYING].
17:11:51.090 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.runtime.taskmanager.Task - Getting user code class loader for task d35a8a9ec257926505614cc44c26896a at library cache manager took 0 milliseconds
17:11:51.091 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Activate slot 8a02931e626afc20bbd5b4b76261f231.
17:11:51.092 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Registering task at network: Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) [DEPLOYING].
17:11:51.092 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Obtaining local cache file for 'class_path_4'.
17:11:51.095 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Obtaining local cache file for 'class_path_3'.
17:11:51.096 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Obtaining local cache file for 'class_path_2'.
17:11:51.097 [flink-file-cache-thread-1] INFO org.apache.flink.runtime.blob.BlobClient - Downloading 096d4334a0974b13818a88ad07ff0a9b/p-13a19027c3b510e03bc91c9ff8cd0793a13416c7-6935106170f065dcc4719a934561d8d6 from localhost/127.0.0.1:59802
17:11:51.098 [flink-file-cache-thread-2] INFO org.apache.flink.runtime.blob.BlobClient - Downloading 096d4334a0974b13818a88ad07ff0a9b/p-47e1bf06ec8d064d2d9abb0c2f7266a11b3ea17d-eb49284ea939cfa373b9069940da4c63 from localhost/127.0.0.1:59802
17:11:51.098 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Obtaining local cache file for 'class_path_1'.
17:11:51.098 [flink-file-cache-thread-1] DEBUG org.apache.flink.runtime.blob.BlobClient - GET BLOB 096d4334a0974b13818a88ad07ff0a9b/p-13a19027c3b510e03bc91c9ff8cd0793a13416c7-6935106170f065dcc4719a934561d8d6 from /127.0.0.1:59841.
17:11:51.098 [flink-file-cache-thread-2] DEBUG org.apache.flink.runtime.blob.BlobClient - GET BLOB 096d4334a0974b13818a88ad07ff0a9b/p-47e1bf06ec8d064d2d9abb0c2f7266a11b3ea17d-eb49284ea939cfa373b9069940da4c63 from /127.0.0.1:59842.
17:11:51.099 [BLOB connection for /127.0.0.1:59841] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received GET request for BLOB 096d4334a0974b13818a88ad07ff0a9b/p-13a19027c3b510e03bc91c9ff8cd0793a13416c7-6935106170f065dcc4719a934561d8d6 from /127.0.0.1.
17:11:51.099 [BLOB connection for /127.0.0.1:59842] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received GET request for BLOB 096d4334a0974b13818a88ad07ff0a9b/p-47e1bf06ec8d064d2d9abb0c2f7266a11b3ea17d-eb49284ea939cfa373b9069940da4c63 from /127.0.0.1.
17:11:51.099 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Obtaining local cache file for 'class_path_0'.
17:11:51.100 [flink-file-cache-thread-3] INFO org.apache.flink.runtime.blob.BlobClient - Downloading 096d4334a0974b13818a88ad07ff0a9b/p-0866f626f8619a770f36bc713fc2916059a035bb-a773dabf1000ab927d39f6cbc3e5614e from localhost/127.0.0.1:59802
17:11:51.100 [flink-file-cache-thread-3] DEBUG org.apache.flink.runtime.blob.BlobClient - GET BLOB 096d4334a0974b13818a88ad07ff0a9b/p-0866f626f8619a770f36bc713fc2916059a035bb-a773dabf1000ab927d39f6cbc3e5614e from /127.0.0.1:59843.
17:11:51.101 [BLOB connection for /127.0.0.1:59843] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received GET request for BLOB 096d4334a0974b13818a88ad07ff0a9b/p-0866f626f8619a770f36bc713fc2916059a035bb-a773dabf1000ab927d39f6cbc3e5614e from /127.0.0.1.
17:11:51.103 [flink-file-cache-thread-4] INFO org.apache.flink.runtime.blob.BlobClient - Downloading 096d4334a0974b13818a88ad07ff0a9b/p-f841334a58c2978957a2c24c82c239a44024a1af-77bc578d54d162c2425f2c5eb1909cbf from localhost/127.0.0.1:59802
17:11:51.103 [flink-file-cache-thread-4] DEBUG org.apache.flink.runtime.blob.BlobClient - GET BLOB 096d4334a0974b13818a88ad07ff0a9b/p-f841334a58c2978957a2c24c82c239a44024a1af-77bc578d54d162c2425f2c5eb1909cbf from /127.0.0.1:59844.
17:11:51.104 [flink-file-cache-thread-5] INFO org.apache.flink.runtime.blob.BlobClient - Downloading 096d4334a0974b13818a88ad07ff0a9b/p-f81e5fc3fa875260d970afba9c66377db5fec5d0-466d691dadf293cd346f1ce9cf989731 from localhost/127.0.0.1:59802
17:11:51.105 [flink-file-cache-thread-5] DEBUG org.apache.flink.runtime.blob.BlobClient - GET BLOB 096d4334a0974b13818a88ad07ff0a9b/p-f81e5fc3fa875260d970afba9c66377db5fec5d0-466d691dadf293cd346f1ce9cf989731 from /127.0.0.1:59845.
17:11:51.106 [BLOB connection for /127.0.0.1:59845] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received GET request for BLOB 096d4334a0974b13818a88ad07ff0a9b/p-f81e5fc3fa875260d970afba9c66377db5fec5d0-466d691dadf293cd346f1ce9cf989731 from /127.0.0.1.
17:11:51.108 [BLOB connection for /127.0.0.1:59844] DEBUG org.apache.flink.runtime.blob.BlobServerConnection - Received GET request for BLOB 096d4334a0974b13818a88ad07ff0a9b/p-f841334a58c2978957a2c24c82c239a44024a1af-77bc578d54d162c2425f2c5eb1909cbf from /127.0.0.1.
17:11:51.130 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from DEPLOYING to RUNNING.
17:11:51.132 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask - Initializing Source: binlogreader -> Sink: streamwriter (1/1).
17:11:51.132 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.streaming.runtime.tasks.StreamTask - No state backend has been configured, using default (Memory / JobManager) MemoryStateBackend (data in heap memory / checkpoints to JobManager) (checkpoints: 'null', savepoints: 'null', asynchronous: TRUE, maxStateSize: 5242880)
17:11:51.134 [flink-akka.actor.default-dispatcher-3] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from DEPLOYING to RUNNING.
17:11:51.204 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.streaming.runtime.tasks.StreamTask - Invoking Source: binlogreader -> Sink: streamwriter (1/1)
17:11:51.220 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.streaming.api.operators.BackendRestorerProcedure - Creating operator state backend for StreamSink_7df19f87deec5680128845fd9a6ca18d_(1/1) with empty state.
17:11:51.246 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.sink.DtOutputFormatSinkFunction - Start initialize output format state
17:11:51.280 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.sink.DtOutputFormatSinkFunction - Is restored:false
17:11:51.280 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.sink.DtOutputFormatSinkFunction - End initialize output format state
17:11:51.280 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.stream.writer.StreamOutputFormat - subtask[0] open start
17:11:51.298 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.streaming.api.operators.BackendRestorerProcedure - Creating operator state backend for StreamSource_cbc357ccb763df2852fee8c4fc7d55f2_(1/1) with empty state.
17:11:51.298 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction - Start initialize input format state
17:11:51.301 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction - Is restored:false
17:11:51.301 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction - End initialize input format state
17:11:51.304 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.api.common.io.DefaultInputSplitAssigner - Assigning split GenericSplit (0/1) to 127.0.0.1
17:11:51.304 [flink-akka.actor.default-dispatcher-3] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Send next input split GenericSplit (0/1).
17:11:51.321 [Legacy Source Thread - Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.binlog.reader.BinlogInputFormat - binlog configure...
17:11:51.322 [Legacy Source Thread - Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.binlog.reader.BinlogInputFormat - []
17:11:51.558 [Legacy Source Thread - Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.binlog.reader.BinlogInputFormat - binlog openInternal split number:0 start...
17:11:51.559 [Legacy Source Thread - Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.binlog.reader.BinlogInputFormat - binlog config:BinlogConfig{host='10.222.5.114', port=3306, username='root', password='******', jdbcUrl='jdbc:mysql://127.0..0.1:3306/test', start={}, cat='insert,delete,update', filter='test.test', period=1000, bufferSize=256, pavingData=true, table=[test], slaveId=1107024580, connectionCharset='UTF-8', detectingEnable=true, detectingSQL='SELECT CURRENT_DATE', enableTsdb=true, parallel=true, parallelThreadSize=2, isGTIDMode=false}
17:12:00.576 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:00.577 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:00.577 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:00.577 [flink-akka.actor.default-dispatcher-7] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:00.577 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from cdd2aca453331fc4c6daae489cedd489.
17:12:00.578 [flink-akka.actor.default-dispatcher-7] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:00.579 [flink-akka.actor.default-dispatcher-7] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Received slot report from instance 7b6c019a96d054f53d362043565d5603: SlotReport{slotsStatus=[SlotStatus{slotID=f173ddab-227e-447e-b258-ea63a94e9712_0, resourceProfile=ResourceProfile{managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationID=8a02931e626afc20bbd5b4b76261f231, jobID=096d4334a0974b13818a88ad07ff0a9b}]}.
17:12:01.015 [flink-akka.actor.default-dispatcher-7] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
17:12:01.018 [flink-akka.actor.default-dispatcher-4] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from cdd2aca453331fc4c6daae489cedd489.
17:12:01.058 [flink-akka.actor.default-dispatcher-7] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:10.594 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:10.595 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:10.595 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:10.596 [flink-akka.actor.default-dispatcher-8] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:10.596 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:10.596 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Received slot report from instance 7b6c019a96d054f53d362043565d5603: SlotReport{slotsStatus=[SlotStatus{slotID=f173ddab-227e-447e-b258-ea63a94e9712_0, resourceProfile=ResourceProfile{managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationID=8a02931e626afc20bbd5b4b76261f231, jobID=096d4334a0974b13818a88ad07ff0a9b}]}.
17:12:10.596 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from cdd2aca453331fc4c6daae489cedd489.
17:12:11.038 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
17:12:11.039 [flink-akka.actor.default-dispatcher-8] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from cdd2aca453331fc4c6daae489cedd489.
17:12:11.041 [flink-akka.actor.default-dispatcher-5] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:11.567 [Legacy Source Thread - Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.binlog.reader.BinlogInputFormat - subtask input close finished
17:12:11.572 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.stream.writer.StreamOutputFormat - subtask[0}] close()
17:12:20.614 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:20.615 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:20.615 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:20.615 [flink-akka.actor.default-dispatcher-10] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:20.615 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from cdd2aca453331fc4c6daae489cedd489.
17:12:20.616 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:20.616 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Received slot report from instance 7b6c019a96d054f53d362043565d5603: SlotReport{slotsStatus=[SlotStatus{slotID=f173ddab-227e-447e-b258-ea63a94e9712_0, resourceProfile=ResourceProfile{managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationID=8a02931e626afc20bbd5b4b76261f231, jobID=096d4334a0974b13818a88ad07ff0a9b}]}.
17:12:21.054 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
17:12:21.055 [flink-akka.actor.default-dispatcher-10] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from cdd2aca453331fc4c6daae489cedd489.
17:12:21.056 [flink-akka.actor.default-dispatcher-6] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:30.639 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:30.639 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Trigger heartbeat request.
17:12:30.639 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:30.639 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat request from 628c0565e7402102824d008cb6962e31.
17:12:30.639 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from cdd2aca453331fc4c6daae489cedd489.
17:12:30.639 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:30.640 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Received slot report from instance 7b6c019a96d054f53d362043565d5603: SlotReport{slotsStatus=[SlotStatus{slotID=f173ddab-227e-447e-b258-ea63a94e9712_0, resourceProfile=ResourceProfile{managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationID=8a02931e626afc20bbd5b4b76261f231, jobID=096d4334a0974b13818a88ad07ff0a9b}]}.
17:12:31.077 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Trigger heartbeat request.
17:12:31.077 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Received heartbeat request from cdd2aca453331fc4c6daae489cedd489.
17:12:31.078 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Received heartbeat from f173ddab-227e-447e-b258-ea63a94e9712.
17:12:31.573 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO com.dtstack.flinkx.stream.writer.StreamOutputFormat - subtask[0}] close() finished
17:12:31.581 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from RUNNING to FAILED.
java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.TableMetaTSDBBuilder.<clinit>(TableMetaTSDBBuilder.java:22)
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.DefaultTableMetaTSDBFactory.build(DefaultTableMetaTSDBFactory.java:13)
    at com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setEnableTsdb(AbstractMysqlEventParser.java:228)
    at com.dtstack.flinkx.binlog.reader.BinlogInputFormat.openInternal(BinlogInputFormat.java:148)
    at com.dtstack.flinkx.inputformat.BaseRichInputFormat.open(BaseRichInputFormat.java:159)
    at com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:122)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: java.lang.ClassNotFoundException: shade.core.com.google.common.collect.Maps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 9 common frames omitted
17:12:31.583 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Freeing task resources for Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a).
17:12:31.583 [Source: binlogreader -> Sink: streamwriter (1/1)] DEBUG org.apache.flink.runtime.taskmanager.Task - Release task Source: binlogreader -> Sink: streamwriter (1/1) network resources (state: FAILED).
17:12:31.586 [Source: binlogreader -> Sink: streamwriter (1/1)] INFO org.apache.flink.runtime.taskmanager.Task - Ensuring all FileSystem streams are closed for task Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) [FAILED]
17:12:31.607 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Un-registering task and sending final execution state FAILED to JobManager for task Source: binlogreader -> Sink: streamwriter (1/1) d35a8a9ec257926505614cc44c26896a.
17:12:31.611 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Source: binlogreader -> Sink: streamwriter (1/1) (d35a8a9ec257926505614cc44c26896a) switched from RUNNING to FAILED.
java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.TableMetaTSDBBuilder.<clinit>(TableMetaTSDBBuilder.java:22)
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.DefaultTableMetaTSDBFactory.build(DefaultTableMetaTSDBFactory.java:13)
    at com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setEnableTsdb(AbstractMysqlEventParser.java:228)
    at com.dtstack.flinkx.binlog.reader.BinlogInputFormat.openInternal(BinlogInputFormat.java:148)
    at com.dtstack.flinkx.inputformat.BaseRichInputFormat.open(BaseRichInputFormat.java:159)
    at com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:122)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: java.lang.ClassNotFoundException: shade.core.com.google.common.collect.Maps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 9 common frames omitted
17:12:31.612 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Releasing slot [SlotRequestId{4ddd256595dd7feb84e15ed4514e9cb9}] because: Release multi task slot because all children have been released.
17:12:31.614 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Adding returned slot [8a02931e626afc20bbd5b4b76261f231] to available slots
17:12:31.617 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - Calculating tasks to restart to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0.
17:12:31.617 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionStrategy - 1 tasks should be restarted to recover the failed task cbc357ccb763df2852fee8c4fc7d55f2_0. 
17:12:31.618 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job sync同步 (096d4334a0974b13818a88ad07ff0a9b) switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110)
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:186)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:180)
    at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:484)
    at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:380)
    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:279)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    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)
    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: java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.TableMetaTSDBBuilder.<clinit>(TableMetaTSDBBuilder.java:22)
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.DefaultTableMetaTSDBFactory.build(DefaultTableMetaTSDBFactory.java:13)
    at com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setEnableTsdb(AbstractMysqlEventParser.java:228)
    at com.dtstack.flinkx.binlog.reader.BinlogInputFormat.openInternal(BinlogInputFormat.java:148)
    at com.dtstack.flinkx.inputformat.BaseRichInputFormat.open(BaseRichInputFormat.java:159)
    at com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:122)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: java.lang.ClassNotFoundException: shade.core.com.google.common.collect.Maps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 9 common frames omitted
17:12:31.623 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.executiongraph.ExecutionGraph - Job sync同步 (096d4334a0974b13818a88ad07ff0a9b) switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110)
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:186)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:180)
    at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:484)
    at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:380)
    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:279)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    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)
    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: java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.TableMetaTSDBBuilder.<clinit>(TableMetaTSDBBuilder.java:22)
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.DefaultTableMetaTSDBFactory.build(DefaultTableMetaTSDBFactory.java:13)
    at com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setEnableTsdb(AbstractMysqlEventParser.java:228)
    at com.dtstack.flinkx.binlog.reader.BinlogInputFormat.openInternal(BinlogInputFormat.java:148)
    at com.dtstack.flinkx.inputformat.BaseRichInputFormat.open(BaseRichInputFormat.java:159)
    at com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:122)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: java.lang.ClassNotFoundException: shade.core.com.google.common.collect.Maps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 9 common frames omitted
17:12:31.623 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.checkpoint.CheckpointCoordinator - Stopping checkpoint coordinator for job 096d4334a0974b13818a88ad07ff0a9b.
17:12:31.624 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore - Shutting down
17:12:31.631 [main] INFO org.apache.flink.runtime.minicluster.MiniCluster - Shutting down Flink Mini Cluster
17:12:31.631 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Job 096d4334a0974b13818a88ad07ff0a9b reached globally terminal state FAILED.
17:12:31.631 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopping TaskExecutor akka://flink/user/taskmanager_0.
17:12:31.631 [main] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shutting down rest endpoint.
17:12:31.631 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Close ResourceManager connection 628c0565e7402102824d008cb6962e31.
org.apache.flink.util.FlinkException: The TaskExecutor is shutting down.
    at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:359)
    at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175)
    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 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)
    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)
17:12:31.631 [flink-akka.actor.default-dispatcher-11] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Closing TaskExecutor connection f173ddab-227e-447e-b258-ea63a94e9712 because: The TaskExecutor is shutting down.
17:12:31.631 [flink-akka.actor.default-dispatcher-11] DEBUG org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Unregister TaskManager 7b6c019a96d054f53d362043565d5603 from the SlotManager.
17:12:31.632 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.jobmaster.JobMaster - Stopping the JobMaster for job sync同步(096d4334a0974b13818a88ad07ff0a9b).
17:12:31.632 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl - Free slot TaskSlot(index:0, state:ACTIVE, resource profile: ResourceProfile{managedMemory=512.000mb (536870912 bytes), networkMemory=64.000mb (67108864 bytes)}, allocationId: 8a02931e626afc20bbd5b4b76261f231, jobId: 096d4334a0974b13818a88ad07ff0a9b).
org.apache.flink.util.FlinkException: Closing task slot table
    at org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl.closeAsync(TaskSlotTableImpl.java:160)
    at org.apache.flink.runtime.taskexecutor.TaskExecutor.onStop(TaskExecutor.java:375)
    at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175)
    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 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)
    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)
17:12:31.632 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Disconnect TaskExecutor f173ddab-227e-447e-b258-ea63a94e9712 because: Stopping JobMaster for job sync同步(096d4334a0974b13818a88ad07ff0a9b).
17:12:31.633 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Suspending SlotPool.
17:12:31.634 [flink-akka.actor.default-dispatcher-12] DEBUG org.apache.flink.runtime.jobmaster.JobMaster - Close ResourceManager connection 628c0565e7402102824d008cb6962e31.
org.apache.flink.util.FlinkException: JobManager is shutting down.
    at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:350)
    at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175)
    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 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)
    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)
17:12:31.634 [flink-akka.actor.default-dispatcher-12] INFO org.apache.flink.runtime.jobmaster.slotpool.SlotPoolImpl - Stopping SlotPool.
17:12:31.634 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Disconnect job manager a6ca2e67e87469c20d507a1db52545a3@akka://flink/user/jobmanager_1 for job 096d4334a0974b13818a88ad07ff0a9b from the resource manager.
17:12:31.636 [mini-cluster-io-thread-8] DEBUG org.apache.flink.runtime.resourcemanager.JobLeaderIdService - Found a new job leader null@null.
17:12:31.636 [mini-cluster-io-thread-6] DEBUG org.apache.flink.runtime.taskexecutor.JobLeaderService - New leader information for job 096d4334a0974b13818a88ad07ff0a9b. Address: null, leader id: null.
17:12:31.636 [mini-cluster-io-thread-6] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - JobManager for job 096d4334a0974b13818a88ad07ff0a9b with leader id a6ca2e67e87469c20d507a1db52545a3 lost leadership.
17:12:31.639 [flink-akka.actor.default-dispatcher-9] DEBUG org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Discard job leader lost leadership for outdated leader a6ca2e67e87469c20d507a1db52545a3 for job 096d4334a0974b13818a88ad07ff0a9b.
17:12:31.641 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Free slot with allocation id 8a02931e626afc20bbd5b4b76261f231 because: Stopping JobMaster for job sync同步(096d4334a0974b13818a88ad07ff0a9b).
17:12:31.641 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Could not free slot for allocation id 8a02931e626afc20bbd5b4b76261f231.
org.apache.flink.runtime.taskexecutor.slot.SlotNotFoundException: Could not find slot for 8a02931e626afc20bbd5b4b76261f231.
    at org.apache.flink.runtime.taskexecutor.slot.TaskSlotTableImpl.freeSlot(TaskSlotTableImpl.java:367)
    at org.apache.flink.runtime.taskexecutor.TaskExecutor.freeSlotInternal(TaskExecutor.java:1480)
    at org.apache.flink.runtime.taskexecutor.TaskExecutor.freeSlot(TaskExecutor.java:884)
    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:279)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    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)
    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)
17:12:31.641 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Releasing local state under allocation id 8a02931e626afc20bbd5b4b76261f231.
17:12:31.652 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.TaskExecutor - Close JobManager connection for job 096d4334a0974b13818a88ad07ff0a9b.
org.apache.flink.util.FlinkException: Stopping JobMaster for job sync同步(096d4334a0974b13818a88ad07ff0a9b).
    at org.apache.flink.runtime.jobmaster.JobMaster.onStop(JobMaster.java:343)
    at org.apache.flink.runtime.rpc.RpcEndpoint.internalCallOnStop(RpcEndpoint.java:218)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor$StartedState.terminate(AkkaRpcActor.java:509)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleControlMessage(AkkaRpcActor.java:175)
    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 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)
    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)
17:12:31.653 [ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Removing cache directory C:\Users\13552\AppData\Local\Temp\flink-web-ui
17:12:31.653 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.taskexecutor.JobLeaderService - Could not reconnect to the JobMaster akka://flink/user/jobmanager_1.
17:12:31.653 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
17:12:31.653 [ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.dispatcher.DispatcherRestEndpoint - Shut down complete.
17:12:31.653 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.state.TaskExecutorLocalStateStoresManager - Shutting down TaskExecutorLocalStateStoresManager.
17:12:31.654 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.io.disk.iomanager.IOManager - Shutting down I/O manager.
17:12:31.657 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager removed spill file directory C:\Users\13552\AppData\Local\Temp\flink-io-54f1e050-03b9-4a52-9128-c8a1e15101c5
17:12:31.657 [flink-akka.actor.default-dispatcher-11] INFO org.apache.flink.runtime.resourcemanager.StandaloneResourceManager - Shut down cluster because application is in CANCELED, diagnostics DispatcherResourceManagerComponent has been closed..
17:12:31.657 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Shutting down the network environment and its components.
17:12:31.657 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Shutting down network connection manager
17:12:31.657 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.io.network.NettyShuffleEnvironment - Shutting down intermediate result partition manager
17:12:31.657 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.io.network.partition.ResultPartitionManager - Releasing 0 partitions because of shutdown.
17:12:31.657 [flink-akka.actor.default-dispatcher-13] DEBUG org.apache.flink.runtime.io.network.partition.ResultPartitionManager - Successful shutdown.
17:12:31.657 [ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.entrypoint.component.DispatcherResourceManagerComponent - Closing components.
17:12:31.658 [ForkJoinPool.commonPool-worker-1] INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess - Stopping SessionDispatcherLeaderProcess.
17:12:31.658 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping dispatcher akka://flink/user/dispatcher.
17:12:31.658 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopping all currently running jobs of dispatcher akka://flink/user/dispatcher.
17:12:31.658 [flink-akka.actor.default-dispatcher-11] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Closing the SlotManager.
17:12:31.658 [flink-akka.actor.default-dispatcher-11] INFO org.apache.flink.runtime.resourcemanager.slotmanager.SlotManagerImpl - Suspending the SlotManager.
17:12:31.658 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.rest.handler.legacy.backpressure.BackPressureRequestCoordinator - Shutting down back pressure request coordinator.
17:12:31.659 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.dispatcher.StandaloneDispatcher - Stopped dispatcher akka://flink/user/dispatcher.
17:12:31.659 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.io.disk.FileChannelManagerImpl - FileChannelManager removed spill file directory C:\Users\13552\AppData\Local\Temp\flink-netty-shuffle-ab91c5c6-0977-4f5f-8aa9-8726eb220162
17:12:31.660 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.taskexecutor.KvStateService - Shutting down the kvState service and its components.
17:12:31.660 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.taskexecutor.JobLeaderService - Stop job leader service.
17:12:36.664 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.filecache.FileCache - removed file cache directory C:\Users\13552\AppData\Local\Temp\flink-dist-cache-2afcef05-c479-44c9-97aa-d8adbbe55799
17:12:36.666 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.taskexecutor.TaskExecutor - Stopped TaskExecutor akka://flink/user/taskmanager_0.
17:12:36.667 [flink-akka.actor.default-dispatcher-13] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
17:12:36.686 [flink-metrics-2] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Shutting down remote daemon.
17:12:36.690 [flink-metrics-2] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remote daemon shut down; proceeding with flushing remote transports.
17:12:36.732 [flink-metrics-2] INFO akka.remote.RemoteActorRefProvider$RemotingTerminator - Remoting shut down.
17:12:36.758 [flink-metrics-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopping Akka RPC service.
17:12:36.758 [flink-metrics-2] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
17:12:36.759 [flink-akka.actor.default-dispatcher-13] DEBUG akka.event.EventStream - shutting down: StandardOutLogger
17:12:36.770 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.blob.PermanentBlobCache - Shutting down BLOB cache
17:12:36.775 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.blob.TransientBlobCache - Shutting down BLOB cache
17:12:36.776 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.blob.BlobServer - Stopped BLOB server at 0.0.0.0:59802
17:12:36.777 [flink-akka.actor.default-dispatcher-9] INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService - Stopped Akka RPC service.
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.MiniCluster.executeJobBlocking(MiniCluster.java:648)
    at com.dtstack.flink.api.java.MyLocalStreamEnvironment.execute(MyLocalStreamEnvironment.java:153)
    at com.dtstack.flinkx.Main.main(Main.java:140)
    at com.dtstack.flinkx.launcher.Launcher.main(Launcher.java:95)
Caused by: org.apache.flink.runtime.JobException: Recovery is suppressed by NoRestartBackoffTimeStrategy
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:110)
    at org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:76)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:192)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:186)
    at org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:180)
    at org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:484)
    at org.apache.flink.runtime.jobmaster.JobMaster.updateTaskExecutionState(JobMaster.java:380)
    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:279)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:194)
    at org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:74)
    at org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:152)
    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)
    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: java.lang.NoClassDefFoundError: shade/core/com/google/common/collect/Maps
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.TableMetaTSDBBuilder.<clinit>(TableMetaTSDBBuilder.java:22)
    at com.alibaba.otter.canal.parse.inbound.mysql.tsdb.DefaultTableMetaTSDBFactory.build(DefaultTableMetaTSDBFactory.java:13)
    at com.alibaba.otter.canal.parse.inbound.mysql.AbstractMysqlEventParser.setEnableTsdb(AbstractMysqlEventParser.java:228)
    at com.dtstack.flinkx.binlog.reader.BinlogInputFormat.openInternal(BinlogInputFormat.java:148)
    at com.dtstack.flinkx.inputformat.BaseRichInputFormat.open(BaseRichInputFormat.java:159)
    at com.dtstack.flinkx.streaming.api.functions.source.DtInputFormatSourceFunction.run(DtInputFormatSourceFunction.java:122)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:100)
    at org.apache.flink.streaming.api.operators.StreamSource.run(StreamSource.java:63)
    at org.apache.flink.streaming.runtime.tasks.SourceStreamTask$LegacySourceFunctionThread.run(SourceStreamTask.java:196)
Caused by: java.lang.ClassNotFoundException: shade.core.com.google.common.collect.Maps
    at java.net.URLClassLoader.findClass(URLClassLoader.java:382)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:424)
    at org.apache.flink.util.ChildFirstClassLoader.loadClass(ChildFirstClassLoader.java:69)
    at java.lang.ClassLoader.loadClass(ClassLoader.java:357)
    ... 9 more

Process finished with exit code 1

job json

{
  "job" : {
    "content" : [ {
      "reader" : {
        "parameter" : {
          "schema" : "test",
          "password" : "xxx",
          "cat" : "insert,delete,update",
          "jdbcUrl" : "jdbc:mysql://127.0..0.1:3306/test",
          "host" : "10.222.5.114",
          "start" : {
          },
          "table" : [ "test" ],
          "pavingData" : true,
          "username" : "root"
        },
        "name" : "binlogreader"
      },
      "writer" : {
        "parameter" : {
          "print" : true
        },
        "name" : "streamwriter"
      }
    } ],
    "setting" : {
      "restore" : {
        "isRestore" : false,
        "isStream" : true
      },
      "errorLimit" : { },
      "speed" : {
        "bytes" : 0,
        "channel" : 1
      },
      "log" : {
        "isLogger": false,
        "level" : "trace",
        "path" : "",
        "pattern":""
      }
    }
  }
}
xunchangguo commented 3 years ago

本机调式运行有问题，直接服务器上脚本跑是没有问题的

zhaoysg commented 3 years ago

最终本机处理了吗？？

zhaoysg commented 3 years ago

可以留下一个qq vx 请教一些关于flinkx 实时采集的问题吗 @xunchangguo

chenxuewu commented 2 years ago

你好，这个问题解决了吗？