search

apache / incubator-streampark

Make stream processing easier! Easy-to-use streaming application development framework and operation platform.
https://streampark.apache.org/
Apache License 2.0
3.84k stars 984 forks source link

flink1.12.5 on hadoop 3.1.5 quickstart-flink-1.2.o.jar报错 #484

Closed honghaoli9898 closed 2 years ago

honghaoli9898 commented 2 years ago

Log Type: jobmanager.log

Log Upload Time: 星期四 十二月 02 10:26:19 +0800 2021

Log Length: 63096

2021-12-02 10:26:14,109 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -------------------------------------------------------------------------------- 2021-12-02 10:26:14,114 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnApplicationClusterEntryPoint (Version: 1.12.0, Scala: 2.11, Rev:fc00492, Date:2020-12-02T08:49:16+01:00) 2021-12-02 10:26:14,114 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - OS current user: yarn 2021-12-02 10:26:14,381 WARN org.apache.hadoop.util.NativeCodeLoader [] - Unable to load native-hadoop library for your platform... using builtin-java classes where applicable 2021-12-02 10:26:14,424 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Current Hadoop/Kerberos user: hdfs 2021-12-02 10:26:14,424 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM: Java HotSpot(TM) 64-Bit Server VM - Oracle Corporation - 1.8/25.192-b12 2021-12-02 10:26:14,428 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Maximum heap size: 429 MiBytes 2021-12-02 10:26:14,428 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JAVA_HOME: /usr/lib/jdk 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Hadoop version: 3.1.1.3.1.5.0-152 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - JVM Options: 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xmx469762048 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Xms469762048 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -XX:MaxMetaspaceSize=268435456 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog.file=/data/hadoop/yarn/log/application_1637831619909_0031/container_e31_1637831619909_0031_01_000001/jobmanager.log 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configuration=file:log4j.properties 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -Dlog4j.configurationFile=file:log4j.properties 2021-12-02 10:26:14,431 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Program Arguments: 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.off-heap.size=134217728b 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.min=201326592b 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-metaspace.size=268435456b 2021-12-02 10:26:14,433 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D 2021-12-02 10:26:14,434 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.heap.size=469762048b 2021-12-02 10:26:14,434 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -D 2021-12-02 10:26:14,434 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - jobmanager.memory.jvm-overhead.max=201326592b 2021-12-02 10:26:14,434 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Classpath: :lib/flink-csv-1.12.5.jar:lib/flink-json-1.12.5.jar:lib/flink-shaded-zookeeper-3.4.14.jar:lib/flink-table-blink_2.11-1.12.5.jar:lib/flink-table_2.11-1.12.5.jar:lib/log4j-1.2-api-2.12.1.jar:lib/log4j-api-2.12.1.jar:lib/log4j-core-2.12.1.jar:lib/log4j-slf4j-impl-2.12.1.jar:quickstart-flink-1.2.0.jar:lib/flink-dist_2.11-1.12.5.jar:flink-conf.yaml::/usr/hdp/3.1.5.0-152/hadoop/conf:/usr/hdp/3.1.5.0-152/hadoop/azure-data-lake-store-sdk-2.3.3.jar:/usr/hdp/3.1.5.0-152/hadoop/azure-keyvault-core-1.0.0.jar:/usr/hdp/3.1.5.0-152/hadoop/azure-storage-7.0.0.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-annotations-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-annotations.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-auth-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-auth.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-azure-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-azure-datalake-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-azure-datalake.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-azure.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-common-3.1.1.3.1.5.0-152-tests.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-common-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-common-tests.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-common.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-kms-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-kms.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-nfs-3.1.1.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/hadoop-nfs.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/ranger-plugin-classloader-1.2.0.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/ranger-yarn-plugin-shim-1.2.0.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/ranger-hdfs-plugin-shim-1.2.0.3.1.5.0-152.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/json-smart-2.3.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/accessors-smart-1.2.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jersey-core-1.19.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/xz-1.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/animal-sniffer-annotations-1.17.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/netty-3.10.5.Final.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/asm-5.0.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/nimbus-jose-jwt-4.41.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/avro-1.7.7.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jsp-api-2.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/checker-qual-2.8.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jsr305-3.0.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-beanutils-1.9.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/slf4j-log4j12-1.7.25.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-cli-1.2.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jsr311-api-1.1.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-codec-1.11.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jcip-annotations-1.0-1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-collections-3.2.2.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jul-to-slf4j-1.7.25.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-compress-1.4.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jersey-json-1.19.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-configuration2-2.1.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/paranamer-2.3.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-io-2.5.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-admin-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-lang-2.6.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-client-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-lang3-3.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-common-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-logging-1.1.3.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-core-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-math3-3.1.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/protobuf-java-2.5.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/commons-net-3.6.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-crypto-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/curator-client-2.12.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jersey-server-1.19.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/curator-framework-2.12.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-identity-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/curator-recipes-2.12.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jersey-servlet-1.19.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/error_prone_annotations-2.3.2.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-server-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/failureaccess-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/re2j-1.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/gson-2.2.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/slf4j-api-1.7.25.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/guava-28.0-jre.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-servlet-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/htrace-core4-4.1.0-incubating.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-simplekdc-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/httpclient-4.5.2.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/snappy-java-1.0.5.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/httpcore-4.4.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerb-util-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/j2objc-annotations-1.3.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jettison-1.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-annotations-2.10.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerby-asn1-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-core-2.10.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerby-config-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerby-pkix-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-databind-2.10.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerby-util-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-util-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/kerby-xdr-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jackson-xc-1.9.13.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/log4j-1.2.17.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/javax.servlet-api-3.1.0.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/token-provider-1.0.1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jaxb-api-2.2.11.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/metrics-core-3.2.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-http-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-webapp-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-io-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-xml-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-security-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jsch-0.1.54.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/jetty-server-9.3.24.v20180605.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/stax2-api-3.1.4.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/woodstox-core-5.0.3.jar:/usr/hdp/3.1.5.0-152/hadoop/lib/zookeeper-3.4.6.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-3.1.1.3.1.5.0-152-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-client-3.1.1.3.1.5.0-152-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-client-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-client-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-client.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-httpfs-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-httpfs.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-native-client-3.1.1.3.1.5.0-152-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-native-client-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-native-client-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-native-client.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-nfs-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-nfs.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-rbf-3.1.1.3.1.5.0-152-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-rbf-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-rbf-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-rbf.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs-tests.jar:/usr/hdp/current/hadoop-hdfs-client/hadoop-hdfs.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-server-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/accessors-smart-1.2.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jersey-json-1.19.jar:/usr/hdp/current/hadoop-hdfs-client/lib/animal-sniffer-annotations-1.17.jar:/usr/hdp/current/hadoop-hdfs-client/lib/paranamer-2.3.jar:/usr/hdp/current/hadoop-hdfs-client/lib/asm-5.0.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/protobuf-java-2.5.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/avro-1.7.7.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-servlet-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/checker-qual-2.8.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-util-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-beanutils-1.9.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/re2j-1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-cli-1.2.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jsr311-api-1.1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-codec-1.11.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jersey-server-1.19.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-collections-3.2.2.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-admin-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-compress-1.4.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jersey-servlet-1.19.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-configuration2-2.1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-client-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-daemon-1.0.13.jar:/usr/hdp/current/hadoop-hdfs-client/lib/snappy-java-1.0.5.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-io-2.5.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-common-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-lang-2.6.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-core-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-lang3-3.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-crypto-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-logging-1.1.3.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-identity-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-math3-3.1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/stax2-api-3.1.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/commons-net-3.6.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-server-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/curator-client-2.12.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-http-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/curator-framework-2.12.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-simplekdc-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/curator-recipes-2.12.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jettison-1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/error_prone_annotations-2.3.2.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerb-util-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/failureaccess-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/token-provider-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/gson-2.2.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/woodstox-core-5.0.3.jar:/usr/hdp/current/hadoop-hdfs-client/lib/guava-28.0-jre.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-io-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/htrace-core4-4.1.0-incubating.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerby-asn1-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/httpclient-4.5.2.jar:/usr/hdp/current/hadoop-hdfs-client/lib/xz-1.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/httpcore-4.4.4.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerby-config-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/j2objc-annotations-1.3.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-security-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-annotations-2.10.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerby-pkix-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-core-2.10.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerby-util-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-core-asl-1.9.13.jar:/usr/hdp/current/hadoop-hdfs-client/lib/kerby-xdr-1.0.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-databind-2.10.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/leveldbjni-all-1.8.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-jaxrs-1.9.13.jar:/usr/hdp/current/hadoop-hdfs-client/lib/json-simple-1.1.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-mapper-asl-1.9.13.jar:/usr/hdp/current/hadoop-hdfs-client/lib/log4j-1.2.17.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jackson-xc-1.9.13.jar:/usr/hdp/current/hadoop-hdfs-client/lib/netty-3.10.5.Final.jar:/usr/hdp/current/hadoop-hdfs-client/lib/javax.servlet-api-3.1.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jaxb-api-2.2.11.jar:/usr/hdp/current/hadoop-hdfs-client/lib/netty-all-4.0.52.Final.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jaxb-impl-2.2.3-1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/nimbus-jose-jwt-4.41.1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jcip-annotations-1.0-1.jar:/usr/hdp/current/hadoop-hdfs-client/lib/okhttp-2.7.5.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jersey-core-1.19.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-util-ajax-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/json-smart-2.3.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-webapp-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jsr305-3.0.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jetty-xml-9.3.24.v20180605.jar:/usr/hdp/current/hadoop-hdfs-client/lib/jsch-0.1.54.jar:/usr/hdp/current/hadoop-hdfs-client/lib/okio-1.6.0.jar:/usr/hdp/current/hadoop-hdfs-client/lib/listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/usr/hdp/current/hadoop-hdfs-client/lib/zookeeper-3.4.6.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-api-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-api.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-web-proxy.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-applications-distributedshell-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-applications-distributedshell.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-applications-unmanaged-am-launcher-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-applications-unmanaged-am-launcher.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-client-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-client.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-common-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-common.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-registry-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-registry.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-services-api-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-applicationhistoryservice-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-applicationhistoryservice.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-common-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-common.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-nodemanager-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-nodemanager.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-resourcemanager-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-resourcemanager.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-router-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-router.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-sharedcachemanager-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-sharedcachemanager.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-tests-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-tests.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-services-api.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-timeline-pluginstorage-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-timeline-pluginstorage.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-server-web-proxy-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-services-core-3.1.1.3.1.5.0-152.jar:/usr/hdp/current/hadoop-yarn-client/hadoop-yarn-services-core.jar:/usr/hdp/current/hadoop-yarn-client/lib/HikariCP-java7-2.4.12.jar:/usr/hdp/current/hadoop-yarn-client/lib/aopalliance-1.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/bcpkix-jdk15on-1.60.jar:/usr/hdp/current/hadoop-yarn-client/lib/bcprov-jdk15on-1.60.jar:/usr/hdp/current/hadoop-yarn-client/lib/dnsjava-2.1.7.jar:/usr/hdp/current/hadoop-yarn-client/lib/ehcache-3.3.1.jar:/usr/hdp/current/hadoop-yarn-client/lib/fst-2.50.jar:/usr/hdp/current/hadoop-yarn-client/lib/geronimo-jcache_1.0_spec-1.0-alpha-1.jar:/usr/hdp/current/hadoop-yarn-client/lib/guice-4.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/guice-servlet-4.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/jackson-jaxrs-base-2.10.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/jackson-jaxrs-json-provider-2.10.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/jackson-module-jaxb-annotations-2.10.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/jakarta.activation-api-1.2.1.jar:/usr/hdp/current/hadoop-yarn-client/lib/jakarta.xml.bind-api-2.3.2.jar:/usr/hdp/current/hadoop-yarn-client/lib/java-util-1.9.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/javax.inject-1.jar:/usr/hdp/current/hadoop-yarn-client/lib/jersey-client-1.19.jar:/usr/hdp/current/hadoop-yarn-client/lib/jersey-guice-1.19.jar:/usr/hdp/current/hadoop-yarn-client/lib/json-io-2.5.1.jar:/usr/hdp/current/hadoop-yarn-client/lib/metrics-core-3.2.4.jar:/usr/hdp/current/hadoop-yarn-client/lib/mssql-jdbc-6.2.1.jre7.jar:/usr/hdp/current/hadoop-yarn-client/lib/objenesis-1.0.jar:/usr/hdp/current/hadoop-yarn-client/lib/snakeyaml-1.16.jar:/usr/hdp/current/hadoop-yarn-client/lib/swagger-annotations-1.5.4.jar 2021-12-02 10:26:14,436 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - -------------------------------------------------------------------------------- 2021-12-02 10:26:14,437 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Registered UNIX signal handlers for [TERM, HUP, INT] 2021-12-02 10:26:14,441 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - YARN daemon is running as: hdfs Yarn client user obtainer: hdfs 2021-12-02 10:26:14,452 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: fs.defaultFS, /usr/local/hadooop 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 1 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.yarn.conf.dir, /usr/local/hadoop 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.flink-dist-jar, hdfs://MyHdfsHA/streamx/flink/flink/lib/flink-dist_2.11-1.12.5.jar 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.cluster-id, application_1637831619909_0031 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, localhost 2021-12-02 10:26:14,453 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, hdfs:///flink-savepoints 2021-12-02 10:26:14,454 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.type, Apache Flink 2021-12-02 10:26:14,454 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint.ignore-unclaimed-state, false 2021-12-02 10:26:14,454 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.provided.lib.dirs, hdfs://MyHdfsHA/streamx/flink/flink/lib;hdfs://MyHdfsHA/streamx/jars;hdfs://MyHdfsHA/streamx/plugins 2021-12-02 10:26:14,454 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.program-args, --hostname;10.1.3.24;--port;8888;--flink.conf;eNq9Wmtv28gV/e5fMXCAKgYkyna221R9AIpjN94kdmB5u9j9EozIkcQ1yWE5pBUV/fE9587wIcebtEVcJ7Alcea+5t5zH6Nnz77tz8Ezpd6lsSmcSVRtVb0xal7qGH8WdlVvdWXUhW2KRNepLdTz+eLiSOGtqZQtDHfbSuUWq2Jb1FW6bGp8kHmKSq8rY3JT1C5SamGMkL+6vr08O1erNJP9Ser8PgiwTesN1qRObW11p1YgpZMkJWudqbTAB7kIwo2VWesqSYs1WJe7Kl1vamW3hancJi3B75aqLC5aYZwn3LKFrjvbBFUGWgdjjNXfQYgqn0bH6jkWcNNheHp49CfZneudKmytGmd66sp8ik1ZQ1wIlpdZqotYdgftOh6Q8edAxC5rjfVaVFF2NVymdH0g58SfTV2Xs+l0u91GWgSObLWetipO38GyV4vzCYT2e34sMuMcbPWPJq1g4eVO6RIyxXoJSTO95fnJMcnxQ4ZtBXsX67Fy4fwfHlJvslZAKD5cAKPpQh3OF+pycahezReXizGJ/HR5++b6x1v10/zmZn51e3m+UNc36uz66vXl7eX1Fd5dqPnVz+rt5dXrsTKwFviYT2VFDSBmSmOaJCKt1plaEegqfO9KE6erNIZqxbrRa6PW9t5UBd2kNFWeOh6qg4AJyGRpntbiUO5ztcDnWwfbwcGzv3zTH+hwZvOcAfGNCYMyA8h8qmE9BB/i0J+D982NdTUPertJY+/UP9jle13A4pWqGm9hFcMPlnSgytBXxf249la7u7DYL9TFTsU4XCBFILnVRU2PBKwUJq4jSAM3c6amc4Ii3tgi2zH0ErrtogYdnQGUAEeJEaqMrKVRdAB6dW0KivxAWJcmlBCSed/Z0VW4ZjIRJf/M34XOzV9VqSv8rYl93grLtJj+ape5JxW5Dexl4qZmcNFNLwu1AS4pfa/TTC/TLK13It5YpSuPP850lFytq3oSZ42rPTEXVymAhKpA8aYERa6FSVbTXHOVR5xxwMw0y6hvre+gaUzohpwaiEzQjHWW7SL1s66K6XvjrAO1vWdCN103lelPmHqrpXY+qtuP5dNggoLG3iJSZRdoPvCD6OBgYKGqjKPgSTOVWfAlvdbZbj6cqdJWdU9vSC113o28cR9S5b6Z+v7k9MXBgSnuox30jKhRlKTVTE0bV02F4XSjE2vLfpF//4W1WLxyUWJWusnqi8WjC7wCta0RKmVlY4ZKbpAY4VbpP3t86vWJBKCvbB1Sh45j5Fn4v2Q9nGTY3jiiGHNH+pnvBk7wpgJuI7nwh7+/x85aO2QHHwVWcJRBsDE62bec5xEFOhFFnamT74+P84OD/1inQTT/z0oNaPyPWuHh3ZfV+sPpy1y0skzRoGweoxsojlWZGc1CQEJUjHCRpcXdngnSAlGoEwbD6CsCjAQQaroxS4bKoDhAaZT4xIv4Vkvo9HUyIuVQEm/zR7atuKhV/vTlcd4eadHkywBi2KVcZmtWR7pWjK+9s7CrFVAmUud8wIUe3AmzRMMsM/CNtDRgZR4cgudyvSK5BVlAilaCdm/qco/g9A+ouQbABlGSNBFDBVQeHPpgM1gO34UYHTAKn/jCzO1wWjlgdYOi1Oedpt5YpAYaUeH/q93+jlLXGyd+apu621jx4IG+qExY71QmA4bem7Z+FmRg0rN2n/GIb1C9TUeR+rEtGbGJPlchDcnulj/F67hICg1cvExDphrG4jkhfQ75seiiXc0njcrJqNEmWTmwz3cEcAL3DHD53e9H4kA9xE28nk9RrLxhNpwPsuFT1S1Mu5PP0m6kPlgUgCx9benLPh7m6Or66nzEEnP0T2vvjEGlOPJh9RmdmeqW9M6MuPUpi1iCVkmL3X2KlkjHAe8Y+SWbCnyaROqnDU/qF2vfCjHl0DgZF1K8ywmW64qdl6oreKlQxLnEd6WFW4h7AKBYs5oMBRKUCWUA3U+atT2Kma4knpe/YjGwNUvvTC+OotCrzG7BU5cbF8LhPUoRVhRwsKaSjmHozhKmHuRNsOqqsrngPL2LrJ8LnzevLxZjtXgxVmem3IxVsYIEURQdqceNHFF0gMhrpuPgtVOBMyTcaWt3hHxNEOtt+I/GVk0OtVgZiXixtewRdR2KmoecQEpKq1Bf5p3CLXHuYts5w8pDFisnM1+ofkDBMeYHp8MPoNShet7GcP9gpk5PXp4c/Ya6nUtFXoNBbTTjPknG87N3e17blWXsCWmhnsqgNUxsPK1eRCfRaf/8gwfanMi+qfPsmYs/vmrSDKU1mCwk+p3PVr6Cb5uxwxgVGI4GKv5yff3x7OZ8fnv+cf7u3UfsO2IAHdrSFOHx9YfzKz74+OPVYn5xfvQAku911kjvGPYI4HUcUecVa58be64omn95iwOLG2I295qCbpl81a7+JCIdZzNFdk8BbheiVm0zU7Hl9x1QF7HStjwN2C11jIo/8R7fdgFNmOgIClDnijbEW8ZCL5aDUUFmT86BYT0KLpqS9TUbOM8q4GZfSY7GPrt5aOA71Cx3LlnipS8TQebPcaadmzD7TOxqstIxJNr9VXiIXFEgP1M9LSoJHDCy9gEKusG6MSG4gNpUgP1kCN7W3ZaAUvGUYIJWkwH3AWHfCexBz2TwWIQKhGsiK+uVoYxO3xu/dByCVmcDTv3jxxj1T8nnItNrHqQ/kWmSOkFiFMeVzNZQmO5ZBNy7U6JHUGN/fr+5x6M0rXXDU3v9at9GR5HH6b0zigbEcF46c6b1xxVCkCkPG+B0Zr1DKR+ZaIzmcStc4DcyG2v88KVNkc7nDylKSQOtqGSiazb6eM3+WJ4GcGd/v4Gt4O44eY0SKK77IcOQzLgdVOzK0Oz63kJgLrFblPHAmDwQZ+CW6GEQDLK2Kfcep+JYqRSsSROH7OkLewB3wTwbYCjzXRJ6S9fk4gb7/ZcfF/Dj1maT1mYzDjg56nwCpLqBLdXv1NYsaXEUmZyGPQ02id/Be/tB0c354jZkxna6wyo4UpcrOeRomRbJRPZtNM+HXYCccBjumYSVjvGNozMVPc2jXlqEITZLLRLQKN5N5iNPaPsxwcvjl12H0A62flNGIR0ExaqOVDfHOI7kHwky1auKmavrjoUUPYrWDtKCV5C1l6zTWsQ7nrw8/uPxZzLS6zuivxuS5HY3FE/oPSZjiydtYwXYlOTOoHTNMoxIBzkgRCXYgt9Eyg72I+jr05zTtiIF7KGjKXxHK8cdUAre/gybIqFbR55gjxbf3LHnyT1T75N48/VelxbQPjUecZGAcHaa6M+MJM7cd6+tyxJDJVlNujn1D0CKwe4+izz/FU+i1EZ1XiYebJDD690RT0ZGfD43X4D7inNJuTKRYpb9uQz6mHpl1jcOEwPx5f2pHwDxDggXxOMtjk55iTISqfYUbftgZtfChK69nRpqj27P5BQStgxGxutYJrW0dETIlylb0QHVcUjZEsy+seiMQHAOVCr1PLYAVzWajaheU6SfpOLknUme67Ey0TqahXuSKRH5ZArTzeTlaf/yBV92Y6qZn2z0Zof/+lat4lzH9zMM3jA/ZuTu9hruy+m1tFhcH8mFDivYkF68VhyX9hw6IzB8HGfXaFE8KEihy2Po1oB6oI20tNacN7XjkUAvdC6p2+v1KzSF9xyh48O2NAYd26w3yLrqZn752lc+ynsYyxDAhNgmgI4Ua5nVMoADitgMmVZEHbTRUsSHajBGR5tMViBUj9RzcbiRa+svVv805KjUNFu3jP4/WOVlOiMlJUv2xYDH2q1jbVsJYnM21x9FglK/SEwR76ZZumQ8gda9v8cTQ/u0HS7ApPKALfnL8hbLJxThx5Y+Ugs4PJQCX9Y8PGX7UH4pQUxW+su9xCyb9ZobelFwMq4xwdidMpxae5NOxKQzNbBeB/s5h6csZMPMcW0lUvyYqTC1D/kawtELjGtHe7RQI9EtYSo5VNUNb8EiROev6HJDyOXtJQmyGxIFIYj3lsB4uTso1OElSpcVkEpyoScPenjY8l82MiM8VIBH5oFhj5enkki+/+79q/FeNZ7rT3xw8rdXYdTwyPwyMIiAbjLfYBY7+fJS8JuBW778yjL9aaZO1ssn6QIFaM/8LY5atL3q2RAmnyI9vTUVjsY6mWmydA0eTlS411VqGyc1ty3klm2i3si9x7gfn4x9x+orHQsnmhCJvHu0pUBKgg0re1M6ou1J9ODeSCYX6q5a/l6uVNoL99OIGeye+bOTFHCX+CIbLUgYMWh1Z3a1XnpohxZ3hjMBXs1vp+ouRbFBKHkRQbLQswzJ9HU3oqRV+4f5fAG51nIjj2r3U82y8ruHkneat8jCfdPFfPGua7QNR2T9LvYzj2pDPAzqIinMW532evP+7oDQuK+qbzHabTJglKakQl5JS17HVix9a9ZX3TwkuguiRKJrBC4TT3UiVGecJJovbPDskAXIcFrbaft86p98YWsnGYo76WEJ0V0mGfp+MCKAAGVGe9v72Al9gVu7ZoY4Iy6N3+rVnfavnyKmf3n7fwzkV3tOpvuB3+CLG34Qxm8p5PLW9U7pq7LWcnuF6/JzynT1Ni5jQBbKHZmwVfdpbPz1L3j1xEGuH6o57bIorJWpziPD8cfOXqasqEBx8LxICoOaUErwJgxucPi1sz/8XBRZMAkLgkBP5xRvUo7Wdgvpv56qfd5jwnOWIYhJ/JcCaluWeH2favkCwcYv9h0hv0DwXFb/i+uO9udoRLiShYj/jpLcY6EB9I0463fpoZPh+rofuTMv+LaPw49BhxCOcl/q0IRDGhN8kGXeYAqiKxQ/9yZaPZiGdaJNKNr0YTfsv7HTN+1dd/qAP4U2/CbCs30DsTF9rEHuxhbfgkHX0Z8ehC/raLg4Ly27zghGG9oQpg7GDf3V8Hw+4/Ff2O6St4n38kU6FGYZeBvESuIbh8qsYIhN24k9erxfYh72T9LABPXVMX4ODv4Niid4Yg==;--app.name;SocketWindowWordCount;--parallelism.default;1;--conf;'json://{"$internal.application.main":"com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount"}' 2021-12-02 10:26:14,455 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 1 2021-12-02 10:26:14,455 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2021-12-02 10:26:14,455 WARN org.apache.flink.configuration.GlobalConfiguration [] - Error while trying to split key and value in configuration file /data/hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031/container_e31_1637831619909_0031_01_000001/flink-conf.yaml:15: "pipeline.classpaths: " 2021-12-02 10:26:14,455 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.name, SocketWindowWordCount 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.main, com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1728m 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, parent-first 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.incremental, false 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, yarn-application 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1024mb 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.yarn.hadoop.conf.dir, /usr/local/hadooop 2021-12-02 10:26:14,456 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.attached, true 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, NORMAL 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.shutdown-on-attached-exit, false 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, hdfs://MyHdfsHA/streamx/workspace/1465991971328589825/quickstart-flink-1.2.0.jar 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend, filesystem 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.taskmanager, -javaagent:$PWD/plugins/streamx-jvm-profiler-1.2.0.jar=sampleInterval=120000,metricInterval=120000,reporter=com.streamxhub.streamx.plugin.profiling.reporter.HttpReporter,id=1465991971328589825,type=1,url=http://10.1.0.131:10000//metrics/report,token=68c044283aec444b8f6c719820bb8143 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.deployment.config-dir, /usr/local/flink/conf 2021-12-02 10:26:14,457 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.yarn.log-config-file, /usr/local/flink/conf/log4j.properties 2021-12-02 10:26:14,458 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, hdfs:///flink-checkpoints 2021-12-02 10:26:14,478 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'web.port' instead of proper key 'rest.bind-port' 2021-12-02 10:26:14,491 INFO org.apache.flink.runtime.clusterframework.BootstrapTools [] - Setting directories for temporary files to: /hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031,/data/hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031 2021-12-02 10:26:14,648 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Starting YarnApplicationClusterEntryPoint. 2021-12-02 10:26:14,674 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install default filesystem. 2021-12-02 10:26:14,709 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Install security context. 2021-12-02 10:26:14,746 INFO org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user set to hdfs (auth:SIMPLE) 2021-12-02 10:26:14,753 INFO org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file will be created as /hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031/jaas-8152667746193223291.conf. 2021-12-02 10:26:14,762 INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Initializing cluster services. 2021-12-02 10:26:14,778 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address slave2:0, bind address 0.0.0.0:0. 2021-12-02 10:26:15,337 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started 2021-12-02 10:26:15,382 INFO akka.remote.Remoting [] - Starting remoting 2021-12-02 10:26:15,546 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://flink@slave2:32933] 2021-12-02 10:26:16,093 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://flink@slave2:32933 2021-12-02 10:26:16,156 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'web.port' instead of proper key 'rest.port' 2021-12-02 10:26:16,167 INFO org.apache.flink.runtime.blob.BlobServer [] - Created BLOB server storage directory /hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031/blobStore-8b7c6d5b-7d93-4a06-b684-29e2675e3092 2021-12-02 10:26:16,172 INFO org.apache.flink.runtime.blob.BlobServer [] - Started BLOB server at 0.0.0.0:38885 - max concurrent requests: 50 - max backlog: 1000 2021-12-02 10:26:16,194 INFO org.apache.flink.runtime.metrics.MetricRegistryImpl [] - No metrics reporter configured, no metrics will be exposed/reported. 2021-12-02 10:26:16,199 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Trying to start actor system, external address slave2:0, bind address 0.0.0.0:0. 2021-12-02 10:26:16,225 INFO akka.event.slf4j.Slf4jLogger [] - Slf4jLogger started 2021-12-02 10:26:16,237 INFO akka.remote.Remoting [] - Starting remoting 2021-12-02 10:26:16,244 INFO akka.remote.Remoting [] - Remoting started; listening on addresses :[akka.tcp://flink-metrics@slave2:37506] 2021-12-02 10:26:16,328 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor system started at akka.tcp://flink-metrics@slave2:37506 2021-12-02 10:26:16,365 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.metrics.dump.MetricQueryService at akka://flink-metrics/user/rpc/MetricQueryService . 2021-12-02 10:26:16,411 WARN org.apache.flink.configuration.Configuration [] - Config uses deprecated configuration key 'web.port' instead of proper key 'rest.bind-port' 2021-12-02 10:26:16,413 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Upload directory /tmp/flink-web-f32ab768-3616-4cb5-9b45-59c0ed5098e3/flink-web-upload does not exist. 2021-12-02 10:26:16,414 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Created directory /tmp/flink-web-f32ab768-3616-4cb5-9b45-59c0ed5098e3/flink-web-upload for file uploads. 2021-12-02 10:26:16,435 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Starting rest endpoint. 2021-12-02 10:26:16,889 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component log file: /data/hadoop/yarn/log/application_1637831619909_0031/container_e31_1637831619909_0031_01_000001/jobmanager.log 2021-12-02 10:26:16,889 INFO org.apache.flink.runtime.webmonitor.WebMonitorUtils [] - Determined location of main cluster component stdout file: /data/hadoop/yarn/log/application_1637831619909_0031/container_e31_1637831619909_0031_01_000001/jobmanager.out 2021-12-02 10:26:17,069 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Rest endpoint listening at slave2:40815 2021-12-02 10:26:17,070 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - http://slave2:40815 was granted leadership with leaderSessionID=00000000-0000-0000-0000-000000000000 2021-12-02 10:26:17,071 INFO org.apache.flink.runtime.jobmaster.MiniDispatcherRestEndpoint [] - Web frontend listening at http://slave2:40815. 2021-12-02 10:26:17,087 INFO org.apache.flink.runtime.util.config.memory.ProcessMemoryUtils [] - The derived from fraction jvm overhead memory (172.800mb (181193935 bytes)) is less than its min value 192.000mb (201326592 bytes), min value will be used instead 2021-12-02 10:26:17,114 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: fs.defaultFS, /usr/local/hadooop 2021-12-02 10:26:17,114 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.num-retained, 1 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.yarn.conf.dir, /usr/local/hadoop 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.flink-dist-jar, hdfs://MyHdfsHA/streamx/flink/flink/lib/flink-dist_2.11-1.12.5.jar 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.execution.failover-strategy, region 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: high-availability.cluster-id, application_1637831619909_0031 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.address, localhost 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.savepoints.dir, hdfs:///flink-savepoints 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.type, Apache Flink 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.savepoint.ignore-unclaimed-state, false 2021-12-02 10:26:17,115 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.provided.lib.dirs, hdfs://MyHdfsHA/streamx/flink/flink/lib;hdfs://MyHdfsHA/streamx/jars;hdfs://MyHdfsHA/streamx/plugins 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.program-args, --hostname;10.1.3.24;--port;8888;--flink.conf;eNq9Wmtv28gV/e5fMXCAKgYkyna221R9AIpjN94kdmB5u9j9EozIkcQ1yWE5pBUV/fE9587wIcebtEVcJ7Alcea+5t5zH6Nnz77tz8Ezpd6lsSmcSVRtVb0xal7qGH8WdlVvdWXUhW2KRNepLdTz+eLiSOGtqZQtDHfbSuUWq2Jb1FW6bGp8kHmKSq8rY3JT1C5SamGMkL+6vr08O1erNJP9Ser8PgiwTesN1qRObW11p1YgpZMkJWudqbTAB7kIwo2VWesqSYs1WJe7Kl1vamW3hancJi3B75aqLC5aYZwn3LKFrjvbBFUGWgdjjNXfQYgqn0bH6jkWcNNheHp49CfZneudKmytGmd66sp8ik1ZQ1wIlpdZqotYdgftOh6Q8edAxC5rjfVaVFF2NVymdH0g58SfTV2Xs+l0u91GWgSObLWetipO38GyV4vzCYT2e34sMuMcbPWPJq1g4eVO6RIyxXoJSTO95fnJMcnxQ4ZtBXsX67Fy4fwfHlJvslZAKD5cAKPpQh3OF+pycahezReXizGJ/HR5++b6x1v10/zmZn51e3m+UNc36uz66vXl7eX1Fd5dqPnVz+rt5dXrsTKwFviYT2VFDSBmSmOaJCKt1plaEegqfO9KE6erNIZqxbrRa6PW9t5UBd2kNFWeOh6qg4AJyGRpntbiUO5ztcDnWwfbwcGzv3zTH+hwZvOcAfGNCYMyA8h8qmE9BB/i0J+D982NdTUPertJY+/UP9jle13A4pWqGm9hFcMPlnSgytBXxf249la7u7DYL9TFTsU4XCBFILnVRU2PBKwUJq4jSAM3c6amc4Ii3tgi2zH0ErrtogYdnQGUAEeJEaqMrKVRdAB6dW0KivxAWJcmlBCSed/Z0VW4ZjIRJf/M34XOzV9VqSv8rYl93grLtJj+ape5JxW5Dexl4qZmcNFNLwu1AS4pfa/TTC/TLK13It5YpSuPP850lFytq3oSZ42rPTEXVymAhKpA8aYERa6FSVbTXHOVR5xxwMw0y6hvre+gaUzohpwaiEzQjHWW7SL1s66K6XvjrAO1vWdCN103lelPmHqrpXY+qtuP5dNggoLG3iJSZRdoPvCD6OBgYKGqjKPgSTOVWfAlvdbZbj6cqdJWdU9vSC113o28cR9S5b6Z+v7k9MXBgSnuox30jKhRlKTVTE0bV02F4XSjE2vLfpF//4W1WLxyUWJWusnqi8WjC7wCta0RKmVlY4ZKbpAY4VbpP3t86vWJBKCvbB1Sh45j5Fn4v2Q9nGTY3jiiGHNH+pnvBk7wpgJuI7nwh7+/x85aO2QHHwVWcJRBsDE62bec5xEFOhFFnamT74+P84OD/1inQTT/z0oNaPyPWuHh3ZfV+sPpy1y0skzRoGweoxsojlWZGc1CQEJUjHCRpcXdngnSAlGoEwbD6CsCjAQQaroxS4bKoDhAaZT4xIv4Vkvo9HUyIuVQEm/zR7atuKhV/vTlcd4eadHkywBi2KVcZmtWR7pWjK+9s7CrFVAmUud8wIUe3AmzRMMsM/CNtDRgZR4cgudyvSK5BVlAilaCdm/qco/g9A+ouQbABlGSNBFDBVQeHPpgM1gO34UYHTAKn/jCzO1wWjlgdYOi1Oedpt5YpAYaUeH/q93+jlLXGyd+apu621jx4IG+qExY71QmA4bem7Z+FmRg0rN2n/GIb1C9TUeR+rEtGbGJPlchDcnulj/F67hICg1cvExDphrG4jkhfQ75seiiXc0njcrJqNEmWTmwz3cEcAL3DHD53e9H4kA9xE28nk9RrLxhNpwPsuFT1S1Mu5PP0m6kPlgUgCx9benLPh7m6Or66nzEEnP0T2vvjEGlOPJh9RmdmeqW9M6MuPUpi1iCVkmL3X2KlkjHAe8Y+SWbCnyaROqnDU/qF2vfCjHl0DgZF1K8ywmW64qdl6oreKlQxLnEd6WFW4h7AKBYs5oMBRKUCWUA3U+atT2Kma4knpe/YjGwNUvvTC+OotCrzG7BU5cbF8LhPUoRVhRwsKaSjmHozhKmHuRNsOqqsrngPL2LrJ8LnzevLxZjtXgxVmem3IxVsYIEURQdqceNHFF0gMhrpuPgtVOBMyTcaWt3hHxNEOtt+I/GVk0OtVgZiXixtewRdR2KmoecQEpKq1Bf5p3CLXHuYts5w8pDFisnM1+ofkDBMeYHp8MPoNShet7GcP9gpk5PXp4c/Ya6nUtFXoNBbTTjPknG87N3e17blWXsCWmhnsqgNUxsPK1eRCfRaf/8gwfanMi+qfPsmYs/vmrSDKU1mCwk+p3PVr6Cb5uxwxgVGI4GKv5yff3x7OZ8fnv+cf7u3UfsO2IAHdrSFOHx9YfzKz74+OPVYn5xfvQAku911kjvGPYI4HUcUecVa58be64omn95iwOLG2I295qCbpl81a7+JCIdZzNFdk8BbheiVm0zU7Hl9x1QF7HStjwN2C11jIo/8R7fdgFNmOgIClDnijbEW8ZCL5aDUUFmT86BYT0KLpqS9TUbOM8q4GZfSY7GPrt5aOA71Cx3LlnipS8TQebPcaadmzD7TOxqstIxJNr9VXiIXFEgP1M9LSoJHDCy9gEKusG6MSG4gNpUgP1kCN7W3ZaAUvGUYIJWkwH3AWHfCexBz2TwWIQKhGsiK+uVoYxO3xu/dByCVmcDTv3jxxj1T8nnItNrHqQ/kWmSOkFiFMeVzNZQmO5ZBNy7U6JHUGN/fr+5x6M0rXXDU3v9at9GR5HH6b0zigbEcF46c6b1xxVCkCkPG+B0Zr1DKR+ZaIzmcStc4DcyG2v88KVNkc7nDylKSQOtqGSiazb6eM3+WJ4GcGd/v4Gt4O44eY0SKK77IcOQzLgdVOzK0Oz63kJgLrFblPHAmDwQZ+CW6GEQDLK2Kfcep+JYqRSsSROH7OkLewB3wTwbYCjzXRJ6S9fk4gb7/ZcfF/Dj1maT1mYzDjg56nwCpLqBLdXv1NYsaXEUmZyGPQ02id/Be/tB0c354jZkxna6wyo4UpcrOeRomRbJRPZtNM+HXYCccBjumYSVjvGNozMVPc2jXlqEITZLLRLQKN5N5iNPaPsxwcvjl12H0A62flNGIR0ExaqOVDfHOI7kHwky1auKmavrjoUUPYrWDtKCV5C1l6zTWsQ7nrw8/uPxZzLS6zuivxuS5HY3FE/oPSZjiydtYwXYlOTOoHTNMoxIBzkgRCXYgt9Eyg72I+jr05zTtiIF7KGjKXxHK8cdUAre/gybIqFbR55gjxbf3LHnyT1T75N48/VelxbQPjUecZGAcHaa6M+MJM7cd6+tyxJDJVlNujn1D0CKwe4+izz/FU+i1EZ1XiYebJDD690RT0ZGfD43X4D7inNJuTKRYpb9uQz6mHpl1jcOEwPx5f2pHwDxDggXxOMtjk55iTISqfYUbftgZtfChK69nRpqj27P5BQStgxGxutYJrW0dETIlylb0QHVcUjZEsy+seiMQHAOVCr1PLYAVzWajaheU6SfpOLknUme67Ey0TqahXuSKRH5ZArTzeTlaf/yBV92Y6qZn2z0Zof/+lat4lzH9zMM3jA/ZuTu9hruy+m1tFhcH8mFDivYkF68VhyX9hw6IzB8HGfXaFE8KEihy2Po1oB6oI20tNacN7XjkUAvdC6p2+v1KzSF9xyh48O2NAYd26w3yLrqZn752lc+ynsYyxDAhNgmgI4Ua5nVMoADitgMmVZEHbTRUsSHajBGR5tMViBUj9RzcbiRa+svVv805KjUNFu3jP4/WOVlOiMlJUv2xYDH2q1jbVsJYnM21x9FglK/SEwR76ZZumQ8gda9v8cTQ/u0HS7ApPKALfnL8hbLJxThx5Y+Ugs4PJQCX9Y8PGX7UH4pQUxW+su9xCyb9ZobelFwMq4xwdidMpxae5NOxKQzNbBeB/s5h6csZMPMcW0lUvyYqTC1D/kawtELjGtHe7RQI9EtYSo5VNUNb8EiROev6HJDyOXtJQmyGxIFIYj3lsB4uTso1OElSpcVkEpyoScPenjY8l82MiM8VIBH5oFhj5enkki+/+79q/FeNZ7rT3xw8rdXYdTwyPwyMIiAbjLfYBY7+fJS8JuBW778yjL9aaZO1ssn6QIFaM/8LY5atL3q2RAmnyI9vTUVjsY6mWmydA0eTlS411VqGyc1ty3klm2i3si9x7gfn4x9x+orHQsnmhCJvHu0pUBKgg0re1M6ou1J9ODeSCYX6q5a/l6uVNoL99OIGeye+bOTFHCX+CIbLUgYMWh1Z3a1XnpohxZ3hjMBXs1vp+ouRbFBKHkRQbLQswzJ9HU3oqRV+4f5fAG51nIjj2r3U82y8ruHkneat8jCfdPFfPGua7QNR2T9LvYzj2pDPAzqIinMW532evP+7oDQuK+qbzHabTJglKakQl5JS17HVix9a9ZX3TwkuguiRKJrBC4TT3UiVGecJJovbPDskAXIcFrbaft86p98YWsnGYo76WEJ0V0mGfp+MCKAAGVGe9v72Al9gVu7ZoY4Iy6N3+rVnfavnyKmf3n7fwzkV3tOpvuB3+CLG34Qxm8p5PLW9U7pq7LWcnuF6/JzynT1Ni5jQBbKHZmwVfdpbPz1L3j1xEGuH6o57bIorJWpziPD8cfOXqasqEBx8LxICoOaUErwJgxucPi1sz/8XBRZMAkLgkBP5xRvUo7Wdgvpv56qfd5jwnOWIYhJ/JcCaluWeH2favkCwcYv9h0hv0DwXFb/i+uO9udoRLiShYj/jpLcY6EB9I0463fpoZPh+rofuTMv+LaPw49BhxCOcl/q0IRDGhN8kGXeYAqiKxQ/9yZaPZiGdaJNKNr0YTfsv7HTN+1dd/qAP4U2/CbCs30DsTF9rEHuxhbfgkHX0Z8ehC/raLg4Ly27zghGG9oQpg7GDf3V8Hw+4/Ff2O6St4n38kU6FGYZeBvESuIbh8qsYIhN24k9erxfYh72T9LABPXVMX4ODv4Niid4Yg==;--app.name;SocketWindowWordCount;--parallelism.default;1;--conf;'json://{"$internal.application.main":"com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount"}' 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: parallelism.default, 1 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.numberOfTaskSlots, 1 2021-12-02 10:26:17,116 WARN org.apache.flink.configuration.GlobalConfiguration [] - Error while trying to split key and value in configuration file /data/hadoop/yarn/local/usercache/hdfs/appcache/application_1637831619909_0031/container_e31_1637831619909_0031_01_000001/flink-conf.yaml:15: "pipeline.classpaths: " 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: yarn.application.name, SocketWindowWordCount 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.application.main, com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount 2021-12-02 10:26:17,116 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: taskmanager.memory.process.size, 1728m 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: classloader.resolve-order, parent-first 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend.incremental, false 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.target, yarn-application 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.memory.process.size, 1024mb 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.yarn.hadoop.conf.dir, /usr/local/hadooop 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: jobmanager.rpc.port, 6123 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.attached, true 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: internal.cluster.execution-mode, NORMAL 2021-12-02 10:26:17,117 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: execution.shutdown-on-attached-exit, false 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: pipeline.jars, hdfs://MyHdfsHA/streamx/workspace/1465991971328589825/quickstart-flink-1.2.0.jar 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.backend, filesystem 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: env.java.opts.taskmanager, -javaagent:$PWD/plugins/streamx-jvm-profiler-1.2.0.jar=sampleInterval=120000,metricInterval=120000,reporter=com.streamxhub.streamx.plugin.profiling.reporter.HttpReporter,id=1465991971328589825,type=1,url=http://10.1.0.131:10000//metrics/report,token=68c044283aec444b8f6c719820bb8143 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.deployment.config-dir, /usr/local/flink/conf 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: $internal.yarn.log-config-file, /usr/local/flink/conf/log4j.properties 2021-12-02 10:26:17,118 INFO org.apache.flink.configuration.GlobalConfiguration [] - Loading configuration property: state.checkpoints.dir, hdfs:///flink-checkpoints 2021-12-02 10:26:17,165 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager at akka://flink/user/rpc/resourcemanager_0 . 2021-12-02 10:26:17,207 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Start SessionDispatcherLeaderProcess. 2021-12-02 10:26:17,244 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Recover all persisted job graphs. 2021-12-02 10:26:17,244 INFO org.apache.flink.runtime.dispatcher.runner.SessionDispatcherLeaderProcess [] - Successfully recovered 0 persisted job graphs. 2021-12-02 10:26:17,273 INFO org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Starting RPC endpoint for org.apache.flink.runtime.dispatcher.StandaloneDispatcher at akka://flink/user/rpc/dispatcher_1 . 2021-12-02 10:26:17,305 INFO org.apache.flink.client.ClientUtils [] - Starting program (detached: false) 2021-12-02 10:26:17,339 INFO org.apache.hadoop.yarn.client.RMProxy [] - Connecting to ResourceManager at master/10.1.3.24:8030 2021-12-02 10:26:17,670 INFO org.apache.flink.yarn.YarnResourceManagerDriver [] - Recovered 0 containers from previous attempts ([]). 2021-12-02 10:26:17,670 INFO org.apache.flink.runtime.resourcemanager.active.ActiveResourceManager [] - Recovered 0 workers from previous attempt. 2021-12-02 10:26:17,694 WARN org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap [] - Application failed unexpectedly: java.util.concurrent.CompletionException: org.apache.flink.client.deployment.application.ApplicationExecutionException: Could not execute application. at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) ~[?:1.8.0_192] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:257) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$1(ApplicationDispatcherBootstrap.java:212) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_192] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_192] at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [quickstart-flink-1.2.0.jar:?] Caused by: org.apache.flink.client.deployment.application.ApplicationExecutionException: Could not execute application. ... 11 more Caused by: java.lang.NoSuchMethodError: org.apache.flink.runtime.jobgraph.SavepointRestoreSettings.fromConfiguration(Lorg/apache/flink/configuration/ReadableConfig;)Lorg/apache/flink/runtime/jobgraph/SavepointRestoreSettings; at org.apache.flink.client.cli.ExecutionConfigAccessor.getSavepointRestoreSettings(ExecutionConfigAccessor.java:94) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.executors.PipelineExecutorUtils.getJobGraph(PipelineExecutorUtils.java:65) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:122) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1940) ~[quickstart-flink-1.2.0.jar:?] at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:135) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:76) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1822) ~[quickstart-flink-1.2.0.jar:?] at com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount.main(SocketWindowWordCount.java:67) ~[quickstart-flink-1.2.0.jar:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_192] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_192] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_192] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_192] at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:349) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:219) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242) ~[flink-dist_2.11-1.12.5.jar:1.12.5] ... 10 more 2021-12-02 10:26:17,702 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Fatal error occurred in the cluster entrypoint. org.apache.flink.util.FlinkException: Application failed unexpectedly. at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAndShutdownClusterAsync$0(ApplicationDispatcherBootstrap.java:170) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at java.util.concurrent.CompletableFuture.uniHandle(CompletableFuture.java:822) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture$UniHandle.tryFire(CompletableFuture.java:797) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977) ~[?:1.8.0_192] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:257) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.lambda$runApplicationAsync$1(ApplicationDispatcherBootstrap.java:212) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_192] at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_192] at org.apache.flink.runtime.concurrent.akka.ActorSystemScheduledExecutorAdapter$ScheduledFutureTask.run(ActorSystemScheduledExecutorAdapter.java:154) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(ForkJoinExecutorConfigurator.scala:44) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) [quickstart-flink-1.2.0.jar:?] at akka.dispatch.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) [quickstart-flink-1.2.0.jar:?] Caused by: java.util.concurrent.CompletionException: org.apache.flink.client.deployment.application.ApplicationExecutionException: Could not execute application. at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:943) ~[?:1.8.0_192] at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926) ~[?:1.8.0_192] ... 13 more Caused by: org.apache.flink.client.deployment.application.ApplicationExecutionException: Could not execute application. ... 11 more Caused by: java.lang.NoSuchMethodError: org.apache.flink.runtime.jobgraph.SavepointRestoreSettings.fromConfiguration(Lorg/apache/flink/configuration/ReadableConfig;)Lorg/apache/flink/runtime/jobgraph/SavepointRestoreSettings; at org.apache.flink.client.cli.ExecutionConfigAccessor.getSavepointRestoreSettings(ExecutionConfigAccessor.java:94) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.executors.PipelineExecutorUtils.getJobGraph(PipelineExecutorUtils.java:65) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.submitAndGetJobClientFuture(EmbeddedExecutor.java:122) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.executors.EmbeddedExecutor.execute(EmbeddedExecutor.java:104) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.executeAsync(StreamExecutionEnvironment.java:1940) ~[quickstart-flink-1.2.0.jar:?] at org.apache.flink.client.program.StreamContextEnvironment.executeAsync(StreamContextEnvironment.java:135) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.program.StreamContextEnvironment.execute(StreamContextEnvironment.java:76) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.streaming.api.environment.StreamExecutionEnvironment.execute(StreamExecutionEnvironment.java:1822) ~[quickstart-flink-1.2.0.jar:?] at com.streamxhub.streamx.quickstart.flink.SocketWindowWordCount.main(SocketWindowWordCount.java:67) ~[quickstart-flink-1.2.0.jar:?] at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_192] at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_192] at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_192] at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_192] at org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:349) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:219) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:114) ~[flink-dist_2.11-1.12.5.jar:1.12.5] at org.apache.flink.client.deployment.application.ApplicationDispatcherBootstrap.runApplicationEntryPoint(ApplicationDispatcherBootstrap.java:242) ~[flink-dist_2.11-1.12.5.jar:1.12.5] ... 10 more 2021-12-02 10:26:17,775 INFO org.apache.flink.runtime.blob.BlobServer [] - Stopped BLOB server at 0.0.0.0:38885

PaperKite233 commented 2 years ago

请问这个问题你解决了吗？我也遇到了相同的问题，环境也跟你相同

wolfboys commented 2 years ago

fixed.