You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@flink.apache.org by "JasonLee (Jira)" <ji...@apache.org> on 2022/05/24 04:29:00 UTC
[jira] [Created] (FLINK-27749) Job submit failed when JM enabled HA with flink 1.15.0
JasonLee created FLINK-27749:
--------------------------------
Summary: Job submit failed when JM enabled HA with flink 1.15.0
Key: FLINK-27749
URL: https://issues.apache.org/jira/browse/FLINK-27749
Project: Flink
Issue Type: Bug
Components: Deployment / YARN
Affects Versions: 1.15.0
Environment: Flink: 1.15.0
zookeeper: 3.4.10/3.5.9(failed),3.7.1(success)
hadoop：2.9.0
Reporter: JasonLee
Job submit failed when JM enabled HA with flink 1.15.0，zookeeper 3.4.10
{code:java}
// code placeholder
Logs for container_1653234457991_0009_01_000001
ResourceManager
RM Home
NodeManager
Tools
2022-05-22 23:18:37,520 WARN org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Job Clusters are deprecated since Flink 1.15. Please use an Application Cluster/Application Mode instead.
2022-05-22 23:18:37,574 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2022-05-22 23:18:37,574 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnJobClusterEntrypoint (Version: 1.15.0, Scala: 2.12, Rev:3a4c113, Date:2022-04-20T19:50:32+02:00)
2022-05-22 23:18:37,574 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current user: root
2022-05-22 23:18:37,703 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current Hadoop/Kerberos user: root
2022-05-22 23:18:37,703 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.111-b14
2022-05-22 23:18:37,703 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Arch: amd64
2022-05-22 23:18:37,705 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap size: 859 MiBytes
2022-05-22 23:18:37,705 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME: /home/jason/bigdata/jdk/jdk1.8.0_111
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Hadoop version: 2.9.0
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options:
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xmx939524096
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xms939524096
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:MaxMetaspaceSize=268435456
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dflink_job_name=FlinkStreamingNewDemoHome
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xloggc:/home/jason/bigdata/hadoop/hadoop-2.9.0/logs/userlogs/application_1653234457991_0009/container_1653234457991_0009_01_000001/gc.log
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+PrintGCDetails
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+PrintGCDateStamps
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+UseGCLogFileRotation
2022-05-22 23:18:37,706 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:NumberOfGCLogFiles=5
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:GCLogFileSize=100M
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog.file=/home/jason/bigdata/hadoop/hadoop-2.9.0/logs/userlogs/application_1653234457991_0009/container_1653234457991_0009_01_000001/jobmanager.log
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configuration=file:log4j.properties
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configurationFile=file:log4j.properties
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program Arguments:
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.off-heap.size=134217728b
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.min=201326592b
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-metaspace.size=268435456b
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.heap.size=939524096b
2022-05-22 23:18:37,707 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-22 23:18:37,708 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.max=201326592b
2022-05-22 23:18:37,708 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath: :flink-1.14.0-1.0-SNAPSHOT.jar:lib/flink-cep-1.15.0.jar:lib/flink-connector-files-1.15.0.jar:lib/flink-csv-1.15.0.jar:lib/flink-json-1.15.0.jar:lib/flink-scala_2.12-1.15.0.jar:lib/flink-shaded-zookeeper-3.5.9.jar:lib/flink-table-api-java-uber-1.15.0.jar:lib/flink-table-planner-loader-1.15.0.jar:lib/flink-table-runtime-1.15.0.jar:lib/log4j-1.2-api-2.17.1.jar:lib/log4j-api-2.17.1.jar:lib/log4j-core-2.17.1.jar:lib/log4j-slf4j-impl-2.17.1.jar:flink-dist-1.15.0.jar:job.graph:flink-conf.yaml::/home/jason/bigdata/hadoop/hadoop-2.9.0/etc/hadoop:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mockito-all-1.8.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-log4j12-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-auth-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hamcrest-core-1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/junit-4.11.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-annotations-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-api-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mysql-connector-java-5.1.47.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jedis-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okhttp-2.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xml-apis-1.3.04.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-all-4.0.23.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-annotations-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-daemon-1.0.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-databind-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okio-1.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xercesImpl-2.9.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-tests-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-api-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-nodemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-sharedcachemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-registry-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-distributedshell-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-timeline-pluginstorage-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-web-proxy-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-applicationhistoryservice-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-router-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-resourcemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javassist-3.18.1-GA.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-servlet-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/HikariCP-java7-2.4.12.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-test-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/geronimo-jcache_1.0_spec-1.0-alpha-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-client-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math-2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/ehcache-3.3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-util-1.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javax.inject-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-io-2.5.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-guice-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/mssql-jdbc-6.2.1.jre7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/metrics-core-3.0.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/fst-2.50.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/aopalliance-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jline-2.12.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/spark-2.4.0-yarn-shuffle.jar
2022-05-22 23:18:37,708 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2022-05-22 23:18:37,709 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered UNIX signal handlers for [TERM, HUP, INT]
2022-05-22 23:18:37,711 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - YARN daemon is running as: root Yarn client user obtainer: root
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.jobgraph-path, job.graph
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.jobmanager, -Xloggc:<LOG_DIR>/gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=100M
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.checkpoints.history, 15
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts, -Dflink_job_name=FlinkStreamingNewDemoHome
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.promgateway.jobName, FlinkStreamingNewDemoHome
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.cluster-id, application_1653234457991_0009
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, storm1
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.promgateway.groupingKey, jobname=FlinkStreamingNewDemoHome
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.web.port, 8081
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.zookeeper.path.root, /flink
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.storageDir, hdfs:///flink/recovery/ha
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.tmp.dirs, /tmp
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.watch.heartbeat.pause, 20 s
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.off-heap, true
2022-05-22 23:18:37,718 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 4
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.block.cache-size, 512M
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: cluster.evenly-spread-out-slots, false
2022-05-22 23:18:37,719 WARN org.apache.flink.configuration.GlobalConfiguration [] - Error while trying to split key and value in configuration file /home/jason/bigdata/hadoop/hadoop-2.9.0/tmp/nm-local-dir/usercache/root/appcache/application_1653234457991_0009/container_1653234457991_0009_01_000001/flink-conf.yaml:18: "pipeline.classpaths: "
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.stack-depth, 100
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.queue, flink
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.num-samples, 100
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.archive.fs.dir, hdfs:///flink/flink-jobs/
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.flink.size, 1024m
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.per-job-cluster.include-user-jar, ORDER
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 4096m
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.local-recovery, false
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.cleanup-interval, 100 s
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.cancel.enable, true
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.incremental, true
2022-05-22 23:18:37,719 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.web.submit.enable, true
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.upload.dir, /home/jason/bigdata/flink/flink-1.13.1/jars
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.port, 8082
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.interval, 300s
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.delay-between-samples, 1 s
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application-attempt-failures-validity-interval, 60000
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.zookeeper.quorum, master:2181,storm1:2181,storm2:2181
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend, rocksdb
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.count, 2
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.number-to-merge, 1
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.deployment.config-dir, /home/jason/bigdata/flink/flink-1.15.0/conf
2022-05-22 23:18:37,720 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.yarn.log-config-file, /home/jason/bigdata/flink/flink-1.15.0/conf/log4j.properties
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 2
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.web.port, 8082
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.enabled, true
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.connection-timeout, 360000000
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, hdfs:///flink-rockdb/savepoints
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.watch.heartbeat.interval, 5 s
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: cluster.declarative-resource-management.enabled, true
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: table.dynamic-table-options.enabled, true
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.thread.num, 4
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint.ignore-unclaimed-state, false
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application-attempts, 3
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 4
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.scope.jm.job, <job_name>.<host>.jobmanager
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.async, true
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.refresh-interval, 30 s
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.ask.timeout, 60 s
2022-05-22 23:18:37,721 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.name, FlinkStreamingNewDemoHome
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint-restore-mode, NO_CLAIM
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.idleness-timeout, 360000000
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, child-first
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.latency.interval, 20000
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, yarn-per-job
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.framesize, 20971520b
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.attached, false
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, DETACHED
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.scheduler, adaptive
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability, zookeeper
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.shutdown-on-attached-exit, false
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, file:/home/jason/bigdata/jar/flink-1.14.0-1.0-SNAPSHOT.jar
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.taskmanager, -Xloggc:<LOG_DIR>/gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=100M
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.size, 32M
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.latency-track-enabled, true
2022-05-22 23:18:37,722 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, hdfs:///flink-rockdb/checkpoints
2022-05-22 23:18:37,737 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'jobmanager.web.port' instead of proper key 'web.port'
2022-05-22 23:18:37,738 INFO org.apache.flink.configuration.Configuration [] - Config uses fallback configuration key 'rest.port' instead of key 'rest.bind-port'
2022-05-22 23:18:37,747 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-22 23:18:37,747 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-22 23:18:37,748 INFO org.apache.flink.runtime.clusterframework.BootstrapTools [] - Overriding Flink's temporary file directories with those specified in the Flink config: /tmp
2022-05-22 23:18:37,754 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnJobClusterEntrypoint.
2022-05-22 23:18:37,772 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install default filesystem.
2022-05-22 23:18:37,808 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install security context.
2022-05-22 23:18:37,827 INFO org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user set to root (auth:SIMPLE)
2022-05-22 23:18:37,829 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-22 23:18:37,832 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /tmp/jaas-7584859953935097287.conf.
2022-05-22 23:18:37,837 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing cluster services.
2022-05-22 23:18:37,841 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-22 23:18:37,844 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Using working directory: WorkingDirectory(/tmp/jm_c8c66329c023da74ef100f27ae2044e8).
2022-05-22 23:18:37,845 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-22 23:18:38,081 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address storm1:0, bind address 0.0.0.0:0.
2022-05-22 23:18:38,620 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started
2022-05-22 23:18:38,640 INFO akka.remote.RemoteActorRefProvider [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
2022-05-22 23:18:38,640 INFO akka.remote.Remoting [] - Starting remoting
2022-05-22 23:18:38,743 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://flink@storm1:35680]
2022-05-22 23:18:38,857 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://flink@storm1:35680
2022-05-22 23:18:39,255 INFO org.apache.flink.runtime.blob.FileSystemBlobStore [] - Creating highly available BLOB storage directory at hdfs:/flink/recovery/ha/application_1653234457991_0009/blob
2022-05-22 23:18:39,317 INFO org.apache.flink.runtime.util.ZooKeeperUtils [] - Enforcing default ACL for ZK connections
2022-05-22 23:18:39,318 INFO org.apache.flink.runtime.util.ZooKeeperUtils [] - Using '/flink/application_1653234457991_0009' as Zookeeper namespace.
2022-05-22 23:18:39,375 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Starting
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:zookeeper.version=3.5.9-83df9301aa5c2a5d284a9940177808c01bc35cef, built on 01/06/2021 20:03 GMT
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:host.name=storm1
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.version=1.8.0_111
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.vendor=Oracle Corporation
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.home=/home/jason/bigdata/jdk/jdk1.8.0_111/jre
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.class.path=:flink-1.14.0-1.0-SNAPSHOT.jar:lib/flink-cep-1.15.0.jar:lib/flink-connector-files-1.15.0.jar:lib/flink-csv-1.15.0.jar:lib/flink-json-1.15.0.jar:lib/flink-scala_2.12-1.15.0.jar:lib/flink-shaded-zookeeper-3.5.9.jar:lib/flink-table-api-java-uber-1.15.0.jar:lib/flink-table-planner-loader-1.15.0.jar:lib/flink-table-runtime-1.15.0.jar:lib/log4j-1.2-api-2.17.1.jar:lib/log4j-api-2.17.1.jar:lib/log4j-core-2.17.1.jar:lib/log4j-slf4j-impl-2.17.1.jar:flink-dist-1.15.0.jar:job.graph:flink-conf.yaml::/home/jason/bigdata/hadoop/hadoop-2.9.0/etc/hadoop:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mockito-all-1.8.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-log4j12-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-auth-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hamcrest-core-1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/junit-4.11.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-annotations-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-api-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mysql-connector-java-5.1.47.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jedis-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okhttp-2.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xml-apis-1.3.04.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-all-4.0.23.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-annotations-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-daemon-1.0.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-databind-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okio-1.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xercesImpl-2.9.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-tests-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-api-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-nodemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-sharedcachemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-registry-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-distributedshell-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-timeline-pluginstorage-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-web-proxy-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-applicationhistoryservice-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-router-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-resourcemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javassist-3.18.1-GA.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-servlet-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/HikariCP-java7-2.4.12.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-test-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/geronimo-jcache_1.0_spec-1.0-alpha-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-client-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math-2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/ehcache-3.3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-util-1.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javax.inject-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-io-2.5.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-guice-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/mssql-jdbc-6.2.1.jre7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/metrics-core-3.0.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/fst-2.50.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/aopalliance-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jline-2.12.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/spark-2.4.0-yarn-shuffle.jar
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.library.path=:/home/jason/bigdata/hadoop/hadoop-2.9.0/lib/native:/home/jason/bigdata/hadoop/hadoop-2.9.0/lib/native:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.io.tmpdir=/tmp
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.compiler=<NA>
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.name=Linux
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.arch=amd64
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.version=3.10.0-693.el7.x86_64
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.name=root
2022-05-22 23:18:39,380 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.home=/root
2022-05-22 23:18:39,381 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.dir=/home/jason/bigdata/hadoop/hadoop-2.9.0/tmp/nm-local-dir/usercache/root/appcache/application_1653234457991_0009/container_1653234457991_0009_01_000001
2022-05-22 23:18:39,381 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.free=726MB
2022-05-22 23:18:39,381 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.max=859MB
2022-05-22 23:18:39,381 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.total=859MB
2022-05-22 23:18:39,382 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Initiating client connection, connectString=master:2181,storm1:2181,storm2:2181 sessionTimeout=60000 watcher=org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState@472a11ae
2022-05-22 23:18:39,386 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.common.X509Util [] - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
2022-05-22 23:18:39,389 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxnSocket [] - jute.maxbuffer value is 4194304 Bytes
2022-05-22 23:18:39,394 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - zookeeper.request.timeout value is 0. feature enabled=
2022-05-22 23:18:39,398 WARN org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-7584859953935097287.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
2022-05-22 23:18:39,401 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Opening socket connection to server storm2/192.168.0.2:2181
2022-05-22 23:18:39,401 ERROR org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState [] - Authentication failed
2022-05-22 23:18:39,402 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Default schema
2022-05-22 23:18:39,402 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Socket connection established, initiating session, client: /192.168.0.3:52884, server: storm2/192.168.0.2:2181
2022-05-22 23:18:39,411 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Session establishment complete on server storm2/192.168.0.2:2181, sessionid = 0x380eabbdaf10007, negotiated timeout = 40000
2022-05-22 23:18:39,412 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: CONNECTED
2022-05-22 23:18:39,535 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Unable to read additional data from server sessionid 0x380eabbdaf10007, likely server has closed socket, closing socket connection and attempting reconnect
2022-05-22 23:18:39,534 ERROR org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Ensure path threw exception
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1538) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-22 23:18:39,538 ERROR org.apache.flink.runtime.util.ZooKeeperUtils [] - Unhandled error in curator framework, error message: Ensure path threw exception
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1538) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-22 23:18:39,540 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error occurred in the cluster entrypoint.
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1538) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.5.9.jar:3.5.9-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-22 23:18:39,543 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting YarnJobClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..
2022-05-22 23:18:39,636 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: SUSPENDED
2022-05-22 23:18:40,025 WARN org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - SASL configuration failed: javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-7584859953935097287.conf'. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
2022-05-22 23:18:40,025 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Opening socket connection to server master/192.168.0.4:2181
2022-05-22 23:18:40,026 ERROR org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState [] - Authentication failed
2022-05-22 23:18:40,028 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Socket connection established, initiating session, client: /192.168.0.3:43286, server: master/192.168.0.4:2181
2022-05-22 23:18:40,035 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Session establishment complete on server master/192.168.0.4:2181, sessionid = 0x380eabbdaf10007, negotiated timeout = 40000
2022-05-22 23:18:40,036 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: RECONNECTED
{code}
When I upgraded ZooKeeper to 3.5.9, the error was still reported
{code:java}
// code placeholder
Logs for container_1653323265354_0006_01_000001
ResourceManager
RM Home
NodeManager
Tools
2022-05-24 09:55:31,503 WARN org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Job Clusters are deprecated since Flink 1.15. Please use an Application Cluster/Application Mode instead.
2022-05-24 09:55:31,523 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2022-05-24 09:55:31,523 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnJobClusterEntrypoint (Version: 1.15.0, Scala: 2.12, Rev:3a4c113, Date:2022-04-20T19:50:32+02:00)
2022-05-24 09:55:31,523 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current user: root
2022-05-24 09:55:31,645 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current Hadoop/Kerberos user: root
2022-05-24 09:55:31,645 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.111-b14
2022-05-24 09:55:31,645 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Arch: amd64
2022-05-24 09:55:31,647 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap size: 859 MiBytes
2022-05-24 09:55:31,647 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME: /home/jason/bigdata/jdk/jdk1.8.0_111
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Hadoop version: 2.9.0
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options:
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xmx939524096
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xms939524096
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:MaxMetaspaceSize=268435456
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dflink_job_name=FlinkStreamingNewDemoHome
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xloggc:/home/jason/bigdata/hadoop/hadoop-2.9.0/logs/userlogs/application_1653323265354_0006/container_1653323265354_0006_01_000001/gc.log
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+PrintGCDetails
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+PrintGCDateStamps
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:+UseGCLogFileRotation
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:NumberOfGCLogFiles=5
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:GCLogFileSize=100M
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog.file=/home/jason/bigdata/hadoop/hadoop-2.9.0/logs/userlogs/application_1653323265354_0006/container_1653323265354_0006_01_000001/jobmanager.log
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configuration=file:log4j.properties
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configurationFile=file:log4j.properties
2022-05-24 09:55:31,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program Arguments:
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.off-heap.size=134217728b
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.min=201326592b
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-metaspace.size=268435456b
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.heap.size=939524096b
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.max=201326592b
2022-05-24 09:55:31,649 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath: :flink-1.14.0-1.0-SNAPSHOT.jar:lib/flink-cep-1.15.0.jar:lib/flink-connector-files-1.15.0.jar:lib/flink-csv-1.15.0.jar:lib/flink-json-1.15.0.jar:lib/flink-scala_2.12-1.15.0.jar:lib/flink-shaded-zookeeper-3.6.3.jar:lib/flink-table-api-java-uber-1.15.0.jar:lib/flink-table-planner-loader-1.15.0.jar:lib/flink-table-runtime-1.15.0.jar:lib/log4j-1.2-api-2.17.1.jar:lib/log4j-api-2.17.1.jar:lib/log4j-core-2.17.1.jar:lib/log4j-slf4j-impl-2.17.1.jar:flink-dist-1.15.0.jar:job.graph:flink-conf.yaml::/home/jason/bigdata/hadoop/hadoop-2.9.0/etc/hadoop:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mockito-all-1.8.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-log4j12-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-auth-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hamcrest-core-1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/junit-4.11.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-annotations-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-api-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mysql-connector-java-5.1.47.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jedis-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okhttp-2.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xml-apis-1.3.04.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-all-4.0.23.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-annotations-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-daemon-1.0.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-databind-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okio-1.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xercesImpl-2.9.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-tests-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-api-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-nodemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-sharedcachemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-registry-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-distributedshell-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-timeline-pluginstorage-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-web-proxy-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-applicationhistoryservice-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-router-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-resourcemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javassist-3.18.1-GA.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-servlet-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/HikariCP-java7-2.4.12.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-test-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/geronimo-jcache_1.0_spec-1.0-alpha-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-client-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math-2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/ehcache-3.3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-util-1.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javax.inject-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-io-2.5.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-guice-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/mssql-jdbc-6.2.1.jre7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/metrics-core-3.0.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/fst-2.50.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/aopalliance-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jline-2.12.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/spark-2.4.0-yarn-shuffle.jar
2022-05-24 09:55:31,650 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - --------------------------------------------------------------------------------
2022-05-24 09:55:31,650 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered UNIX signal handlers for [TERM, HUP, INT]
2022-05-24 09:55:31,653 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - YARN daemon is running as: root Yarn client user obtainer: root
2022-05-24 09:55:31,659 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.jobgraph-path, job.graph
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.jobmanager, -Xloggc:<LOG_DIR>/gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=100M
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.checkpoints.history, 15
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts, -Dflink_job_name=FlinkStreamingNewDemoHome
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.promgateway.jobName, FlinkStreamingNewDemoHome
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.cluster-id, application_1653323265354_0006
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, storm1
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.reporter.promgateway.groupingKey, jobname=FlinkStreamingNewDemoHome
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.web.port, 8081
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.zookeeper.path.root, /flink
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.storageDir, hdfs:///flink/recovery/ha
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.tmp.dirs, /tmp
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.watch.heartbeat.pause, 20 s
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.off-heap, true
2022-05-24 09:55:31,660 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 4
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.block.cache-size, 512M
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: cluster.evenly-spread-out-slots, false
2022-05-24 09:55:31,661 WARN org.apache.flink.configuration.GlobalConfiguration [] - Error while trying to split key and value in configuration file /home/jason/bigdata/hadoop/hadoop-2.9.0/tmp/nm-local-dir/usercache/root/appcache/application_1653323265354_0006/container_1653323265354_0006_01_000001/flink-conf.yaml:18: "pipeline.classpaths: "
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.stack-depth, 100
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.queue, flink
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.num-samples, 100
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.archive.fs.dir, hdfs:///flink/flink-jobs/
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.flink.size, 1024m
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.per-job-cluster.include-user-jar, ORDER
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 4096m
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.mode, EXACTLY_ONCE
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.local-recovery, false
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.cleanup-interval, 100 s
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.cancel.enable, true
2022-05-24 09:55:31,661 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.incremental, true
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.web.submit.enable, true
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.archive.fs.refresh-interval, 10000
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: web.upload.dir, /home/jason/bigdata/flink/flink-1.13.1/jars
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.port, 8082
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.interval, 300s
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.delay-between-samples, 1 s
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application-attempt-failures-validity-interval, 60000
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.zookeeper.quorum, master:2181,storm1:2181,storm2:2181
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend, rocksdb
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.count, 2
2022-05-24 09:55:31,662 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.number-to-merge, 1
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.deployment.config-dir, /home/jason/bigdata/flink/flink-1.15.0/conf
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.yarn.log-config-file, /home/jason/bigdata/flink/flink-1.15.0/conf/log4j.properties
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 2
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: historyserver.web.port, 8082
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.enabled, true
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.connection-timeout, 360000000
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, hdfs:///flink-rockdb/savepoints
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.watch.heartbeat.interval, 5 s
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: cluster.declarative-resource-management.enabled, true
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: table.dynamic-table-options.enabled, true
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.thread.num, 4
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint.ignore-unclaimed-state, false
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application-attempts, 3
2022-05-24 09:55:31,663 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 4
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.scope.jm.job, <job_name>.<host>.jobmanager
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.async, true
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.flamegraph.refresh-interval, 30 s
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.ask.timeout, 60 s
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.name, FlinkStreamingNewDemoHome
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint-restore-mode, NO_CLAIM
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: rest.idleness-timeout, 360000000
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, child-first
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: metrics.latency.interval, 20000
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, yarn-per-job
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: akka.framesize, 20971520b
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.attached, false
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, DETACHED
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.scheduler, adaptive
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.checkpointing.externalized-checkpoint-retention, RETAIN_ON_CANCELLATION
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability, zookeeper
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.shutdown-on-attached-exit, false
2022-05-24 09:55:31,664 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, file:/home/jason/bigdata/jar/flink-1.14.0-1.0-SNAPSHOT.jar
2022-05-24 09:55:31,665 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.taskmanager, -Xloggc:<LOG_DIR>/gc.log -XX:+PrintGCDetails -XX:+PrintGCDateStamps -XX:+UseGCLogFileRotation -XX:NumberOfGCLogFiles=5 -XX:GCLogFileSize=100M
2022-05-24 09:55:31,665 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.writebuffer.size, 32M
2022-05-24 09:55:31,665 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.rocksdb.latency-track-enabled, true
2022-05-24 09:55:31,665 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, hdfs:///flink-rockdb/checkpoints
2022-05-24 09:55:31,680 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'jobmanager.web.port' instead of proper key 'web.port'
2022-05-24 09:55:31,680 INFO org.apache.flink.configuration.Configuration [] - Config uses fallback configuration key 'rest.port' instead of key 'rest.bind-port'
2022-05-24 09:55:31,689 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-24 09:55:31,689 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-24 09:55:31,689 INFO org.apache.flink.runtime.clusterframework.BootstrapTools [] - Overriding Flink's temporary file directories with those specified in the Flink config: /tmp
2022-05-24 09:55:31,695 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnJobClusterEntrypoint.
2022-05-24 09:55:31,712 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install default filesystem.
2022-05-24 09:55:31,741 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install security context.
2022-05-24 09:55:31,761 INFO org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user set to root (auth:SIMPLE)
2022-05-24 09:55:31,763 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-24 09:55:31,766 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /tmp/jaas-809470794203701266.conf.
2022-05-24 09:55:31,772 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing cluster services.
2022-05-24 09:55:31,775 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-24 09:55:31,778 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Using working directory: WorkingDirectory(/tmp/jm_a48a039ba0c76d84e2a942d7092db5d5).
2022-05-24 09:55:31,779 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'taskmanager.tmp.dirs' instead of proper key 'io.tmp.dirs'
2022-05-24 09:55:32,057 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address storm1:0, bind address 0.0.0.0:0.
2022-05-24 09:55:32,580 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started
2022-05-24 09:55:32,604 INFO akka.remote.RemoteActorRefProvider [] - Akka Cluster not in use - enabling unsafe features anyway because `akka.remote.use-unsafe-remote-features-outside-cluster` has been enabled.
2022-05-24 09:55:32,604 INFO akka.remote.Remoting [] - Starting remoting
2022-05-24 09:55:32,702 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://flink@storm1:34382]
2022-05-24 09:55:32,810 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://flink@storm1:34382
2022-05-24 09:55:33,183 INFO org.apache.flink.runtime.blob.FileSystemBlobStore [] - Creating highly available BLOB storage directory at hdfs:/flink/recovery/ha/application_1653323265354_0006/blob
2022-05-24 09:55:33,232 INFO org.apache.flink.runtime.util.ZooKeeperUtils [] - Enforcing default ACL for ZK connections
2022-05-24 09:55:33,233 INFO org.apache.flink.runtime.util.ZooKeeperUtils [] - Using '/flink/application_1653323265354_0006' as Zookeeper namespace.
2022-05-24 09:55:33,290 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Starting
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:host.name=storm1
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.version=1.8.0_111
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.vendor=Oracle Corporation
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.home=/home/jason/bigdata/jdk/jdk1.8.0_111/jre
2022-05-24 09:55:33,294 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.class.path=:flink-1.14.0-1.0-SNAPSHOT.jar:lib/flink-cep-1.15.0.jar:lib/flink-connector-files-1.15.0.jar:lib/flink-csv-1.15.0.jar:lib/flink-json-1.15.0.jar:lib/flink-scala_2.12-1.15.0.jar:lib/flink-shaded-zookeeper-3.6.3.jar:lib/flink-table-api-java-uber-1.15.0.jar:lib/flink-table-planner-loader-1.15.0.jar:lib/flink-table-runtime-1.15.0.jar:lib/log4j-1.2-api-2.17.1.jar:lib/log4j-api-2.17.1.jar:lib/log4j-core-2.17.1.jar:lib/log4j-slf4j-impl-2.17.1.jar:flink-dist-1.15.0.jar:job.graph:flink-conf.yaml::/home/jason/bigdata/hadoop/hadoop-2.9.0/etc/hadoop:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/hadoop-common-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mockito-all-1.8.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-log4j12-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-auth-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hamcrest-core-1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/junit-4.11.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/hadoop-annotations-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/slf4j-api-1.7.25.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/mysql-connector-java-5.1.47.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/common/lib/jedis-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-nfs-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-2.9.0-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/hadoop-hdfs-native-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okhttp-2.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xml-apis-1.3.04.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-all-4.0.23.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-annotations-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-daemon-1.0.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-databind-2.7.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/okio-1.4.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/hadoop-hdfs-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/xercesImpl-2.9.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/hdfs/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-tests-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-api-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-nodemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-sharedcachemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-registry-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-distributedshell-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-timeline-pluginstorage-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-applications-unmanaged-am-launcher-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-web-proxy-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-applicationhistoryservice-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-router-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-common-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-client-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/hadoop-yarn-server-resourcemanager-2.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/nimbus-jose-jwt-3.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javassist-3.18.1-GA.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-xmlbuilder-0.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-servlet-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-configuration-1.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-cli-1.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-net-3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-core-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guava-11.0.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/gson-2.2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-core-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/log4j-1.2.17.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/woodstox-core-5.0.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jettison-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-digester-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/HikariCP-java7-2.4.12.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax2-api-3.1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xz-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-test-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-jaxrs-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/geronimo-jcache_1.0_spec-1.0-alpha-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/leveldbjni-all-1.8.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-i18n-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/stax-api-1.0-2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-asn1-api-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/protobuf-java-2.5.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-recipes-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-client-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-io-2.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-framework-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/api-util-1.0.0-M20.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-smart-1.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math-2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang-2.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/apacheds-kerberos-codec-2.0.0-M15.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-collections-3.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-server-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/ehcache-3.3.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jets3t-0.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/xmlenc-0.52.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/servlet-api-2.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-logging-1.1.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-codec-1.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/paranamer-2.3.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/java-util-1.9.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/javax.inject-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6-tests.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jcip-annotations-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/zookeeper-3.4.6.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/activation-1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/json-io-2.5.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsch-0.1.54.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-guice-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-core-1.8.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/mssql-jdbc-6.2.1.jre7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jersey-json-1.9.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/htrace-core4-4.1.0-incubating.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/guice-3.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-mapper-asl-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-util-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-math3-3.1.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/metrics-core-3.0.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpcore-4.4.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/fst-2.50.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-compress-1.4.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-lang3-3.4.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/asm-3.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jetty-sslengine-6.1.26.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-api-2.2.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jaxb-impl-2.2.3-1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/commons-beanutils-1.7.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/avro-1.7.7.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/httpclient-4.5.2.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsp-api-2.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/curator-client-2.7.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jsr305-3.0.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/netty-3.6.2.Final.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/snappy-java-1.0.5.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jackson-xc-1.9.13.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/aopalliance-1.0.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/jline-2.12.1.jar:/home/jason/bigdata/hadoop/hadoop-2.9.0/share/hadoop/yarn/lib/spark-2.4.0-yarn-shuffle.jar
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.library.path=:/home/jason/bigdata/hadoop/hadoop-2.9.0/lib/native:/home/jason/bigdata/hadoop/hadoop-2.9.0/lib/native:/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.io.tmpdir=/tmp
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:java.compiler=<NA>
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.name=Linux
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.arch=amd64
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.version=3.10.0-693.el7.x86_64
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.name=root
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.home=/root
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:user.dir=/home/jason/bigdata/hadoop/hadoop-2.9.0/tmp/nm-local-dir/usercache/root/appcache/application_1653323265354_0006/container_1653323265354_0006_01_000001
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.free=730MB
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.max=859MB
2022-05-24 09:55:33,295 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Client environment:os.memory.total=859MB
2022-05-24 09:55:33,297 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper [] - Initiating client connection, connectString=master:2181,storm1:2181,storm2:2181 sessionTimeout=60000 watcher=org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState@21079a12
2022-05-24 09:55:33,300 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.common.X509Util [] - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
2022-05-24 09:55:33,303 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxnSocket [] - jute.maxbuffer value is 1048575 Bytes
2022-05-24 09:55:33,308 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - zookeeper.request.timeout value is 0. feature enabled=false
2022-05-24 09:55:33,311 WARN org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - SASL configuration failed. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-809470794203701266.conf'.
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:189) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:1161) [flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1210) [flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
2022-05-24 09:55:33,314 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Default schema
2022-05-24 09:55:33,315 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Opening socket connection to server storm1/192.168.0.3:2181.
2022-05-24 09:55:33,316 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Socket connection established, initiating session, client: /192.168.0.3:43878, server: storm1/192.168.0.3:2181
2022-05-24 09:55:33,319 ERROR org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState [] - Authentication failed
2022-05-24 09:55:33,324 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Session establishment complete on server storm1/192.168.0.3:2181, session id = 0x280f1be183a0003, negotiated timeout = 40000
2022-05-24 09:55:33,325 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: CONNECTED
2022-05-24 09:55:33,432 ERROR org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl [] - Ensure path threw exception
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1734) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-24 09:55:33,433 ERROR org.apache.flink.runtime.util.ZooKeeperUtils [] - Unhandled error in curator framework, error message: Ensure path threw exception
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1734) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-24 09:55:33,434 WARN org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Session 0x280f1be183a0003 for sever storm1/192.168.0.3:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException.
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x280f1be183a0003, likely server has closed socket
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
2022-05-24 09:55:33,435 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error occurred in the cluster entrypoint.
org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException$UnimplementedException: KeeperErrorCode = Unimplemented for /flink
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:106) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.KeeperException.create(KeeperException.java:54) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ZooKeeper.create(ZooKeeper.java:1734) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.utils.ZKPaths.mkdirs(ZKPaths.java:351) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl$1.call(NamespaceImpl.java:90) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.RetryLoop.callWithRetry(RetryLoop.java:93) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.fixForNamespace(NamespaceImpl.java:83) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.NamespaceImpl.newNamespaceAwareEnsurePath(NamespaceImpl.java:109) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.curator5.org.apache.curator.framework.imps.CuratorFrameworkImpl.newNamespaceAwareEnsurePath(CuratorFrameworkImpl.java:618) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.runtime.util.ZooKeeperUtils.useNamespaceAndEnsurePath(ZooKeeperUtils.java:729) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.zookeeper.ZooKeeperMultipleComponentLeaderElectionHaServices.<init>(ZooKeeperMultipleComponentLeaderElectionHaServices.java:85) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createZooKeeperHaServices(HighAvailabilityServicesUtils.java:96) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.highavailability.HighAvailabilityServicesUtils.createHighAvailabilityServices(HighAvailabilityServicesUtils.java:140) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.createHaServices(ClusterEntrypoint.java:427) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:376) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:277) ~[flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:227) ~[flink-dist-1.15.0.jar:1.15.0]
at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_111]
at javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_111]
at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1886) [hadoop-common-2.9.0.jar:?]
at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:224) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:711) [flink-dist-1.15.0.jar:1.15.0]
at org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint.main(YarnJobClusterEntrypoint.java:109) [flink-dist-1.15.0.jar:1.15.0]
2022-05-24 09:55:33,439 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting YarnJobClusterEntrypoint down with application status UNKNOWN. Diagnostics Cluster entrypoint has been closed externally..
2022-05-24 09:55:33,535 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: SUSPENDED
2022-05-24 09:55:34,250 WARN org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - SASL configuration failed. Will continue connection to Zookeeper server without SASL authentication, if Zookeeper server allows it.
javax.security.auth.login.LoginException: No JAAS configuration section named 'Client' was found in specified JAAS configuration file: '/tmp/jaas-809470794203701266.conf'.
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.client.ZooKeeperSaslClient.<init>(ZooKeeperSaslClient.java:189) ~[flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$SendThread.startConnect(ClientCnxn.java:1161) [flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
at org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1210) [flink-shaded-zookeeper-3.6.3.jar:3.6.3-15.0]
2022-05-24 09:55:34,251 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Opening socket connection to server master/192.168.0.4:2181.
2022-05-24 09:55:34,251 ERROR org.apache.flink.shaded.curator5.org.apache.curator.ConnectionState [] - Authentication failed
2022-05-24 09:55:34,251 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Socket connection established, initiating session, client: /192.168.0.3:44618, server: master/192.168.0.4:2181
2022-05-24 09:55:34,253 INFO org.apache.flink.shaded.zookeeper3.org.apache.zookeeper.ClientCnxn [] - Session establishment complete on server master/192.168.0.4:2181, session id = 0x280f1be183a0003, negotiated timeout = 40000
2022-05-24 09:55:34,253 INFO org.apache.flink.shaded.curator5.org.apache.curator.framework.state.ConnectionStateManager [] - State change: RECONNECTED
{code}
When I upgrade ZooKeeper to 3.7.1, I can submit the job successfully
--
This message was sent by Atlassian Jira
(v8.20.7#820007)