gaborgsomogyi commented on pull request #18687:
URL: https://github.com/apache/flink/pull/18687#issuecomment-1040283835
I've just checked out the latest PR code and it constantly fails the
following way:
```
/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/bin/java
-ea -DforkNumber=01 -Dhadoop.version=2.8.5 -Dcheckpointing.randomization=true
-Dbuffer-debloat.randomization=true -Dcheckpointing.changelog=random
-Dproject.basedir=/Users/gaborsomogyi/flink/flink-yarn-tests
-Dtest.randomization.seed -Xms256m -Xmx2048m -Dmvn.forkNumber=1 -XX:+UseG1GC
-Duser.country=US -Duser.language=en -Didea.test.cyclic.buffer.size=1048576
-javaagent:/Applications/IntelliJ IDEA
CE.app/Contents/lib/idea_rt.jar=58715:/Applications/IntelliJ IDEA
CE.app/Contents/bin -Dfile.encoding=UTF-8 -classpath /Applications/IntelliJ
IDEA CE.app/Contents/lib/idea_rt.jar:/Applications/IntelliJ IDEA
CE.app/Contents/plugins/junit/lib/junit5-rt.jar:/Applications/IntelliJ IDEA
CE.app/Contents/plugins/junit/lib/junit-rt.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/charsets.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/cldrdata.jar:/Library/
Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/dnsns.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/jaccess.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/localedata.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/nashorn.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/sunec.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/sunjce_provider.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/sunpkcs11.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/ext/zipfs.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/jce.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/jfr.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/jsse.jar:/Library/Java/JavaVir
tualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/management-agent.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/resources.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/jre/lib/rt.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/lib/dt.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/lib/jconsole.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/lib/sa-jdi.jar:/Library/Java/JavaVirtualMachines/adoptopenjdk-8.jdk/Contents/Home/lib/tools.jar:/Users/gaborsomogyi/flink/flink-yarn-tests/target/test-classes:/Users/gaborsomogyi/flink/flink-yarn-tests/target/classes:/Users/gaborsomogyi/flink/flink-test-utils-parent/flink-test-utils-junit/target/classes:/Users/gaborsomogyi/flink/flink-test-utils-parent/flink-test-utils/target/classes:/Users/gaborsomogyi/flink/flink-runtime/target/classes:/Users/gaborsomogyi/flink/flink-core/target/test-classes:/Users/gaborsomogyi/fli
nk/flink-annotations/target/classes:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-asm-9/9.2-15.0/flink-shaded-asm-9-9.2-15.0.jar:/Users/gaborsomogyi/.m2/repository/com/esotericsoftware/kryo/kryo/2.24.0/kryo-2.24.0.jar:/Users/gaborsomogyi/.m2/repository/com/esotericsoftware/minlog/minlog/1.2/minlog-1.2.jar:/Users/gaborsomogyi/flink/flink-rpc/flink-rpc-akka-loader/target/test-classes:/Users/gaborsomogyi/flink/flink-clients/target/classes:/Users/gaborsomogyi/.m2/repository/io/netty/netty/3.10.6.Final/netty-3.10.6.Final.jar:/Users/gaborsomogyi/.m2/repository/org/apache/curator/curator-test/5.2.0/curator-test-5.2.0.jar:/Users/gaborsomogyi/.m2/repository/io/dropwizard/metrics/metrics-core/3.2.5/metrics-core-3.2.5.jar:/Users/gaborsomogyi/flink/flink-state-backends/flink-statebackend-changelog/target/classes:/Users/gaborsomogyi/flink/flink-core/target/classes:/Users/gaborsomogyi/flink/flink-java/target/classes:/Users/gaborsomogyi/.m2/repository/com/twitter/chill-java/0.7.
6/chill-java-0.7.6.jar:/Users/gaborsomogyi/flink/flink-runtime-web/target/classes:/Users/gaborsomogyi/flink/flink-optimizer/target/classes:/Users/gaborsomogyi/flink/flink-metrics/flink-metrics-core/target/classes:/Users/gaborsomogyi/flink/flink-container/target/classes:/Users/gaborsomogyi/flink/flink-state-backends/flink-statebackend-rocksdb/target/classes:/Users/gaborsomogyi/.m2/repository/com/ververica/frocksdbjni/6.20.3-ververica-1.0/frocksdbjni-6.20.3-ververica-1.0.jar:/Users/gaborsomogyi/flink/flink-dstl/flink-dstl-dfs/target/classes:/Users/gaborsomogyi/flink/flink-kubernetes/target/classes:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-client/5.5.0/kubernetes-client-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-core/5.5.0/kubernetes-model-core-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-common/5.5.0/kubernetes-model-common-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-rbac/5.5.0/kubern
etes-model-rbac-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-admissionregistration/5.5.0/kubernetes-model-admissionregistration-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-apps/5.5.0/kubernetes-model-apps-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-autoscaling/5.5.0/kubernetes-model-autoscaling-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-apiextensions/5.5.0/kubernetes-model-apiextensions-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-batch/5.5.0/kubernetes-model-batch-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-certificates/5.5.0/kubernetes-model-certificates-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-coordination/5.5.0/kubernetes-model-coordination-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-discovery/5.5.0/kubernetes-model-discovery-5.5.0.jar:/Users/gabors
omogyi/.m2/repository/io/fabric8/kubernetes-model-events/5.5.0/kubernetes-model-events-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-extensions/5.5.0/kubernetes-model-extensions-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-flowcontrol/5.5.0/kubernetes-model-flowcontrol-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-networking/5.5.0/kubernetes-model-networking-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-metrics/5.5.0/kubernetes-model-metrics-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-policy/5.5.0/kubernetes-model-policy-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-scheduling/5.5.0/kubernetes-model-scheduling-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-storageclass/5.5.0/kubernetes-model-storageclass-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/kubernetes-model-node/5.5.0/kubernet
es-model-node-5.5.0.jar:/Users/gaborsomogyi/.m2/repository/com/squareup/okhttp3/okhttp/3.14.9/okhttp-3.14.9.jar:/Users/gaborsomogyi/.m2/repository/com/squareup/okio/okio/1.17.2/okio-1.17.2.jar:/Users/gaborsomogyi/.m2/repository/com/squareup/okhttp3/logging-interceptor/3.14.9/logging-interceptor-3.14.9.jar:/Users/gaborsomogyi/.m2/repository/com/fasterxml/jackson/dataformat/jackson-dataformat-yaml/2.13.0/jackson-dataformat-yaml-2.13.0.jar:/Users/gaborsomogyi/.m2/repository/org/yaml/snakeyaml/1.27/snakeyaml-1.27.jar:/Users/gaborsomogyi/.m2/repository/com/fasterxml/jackson/datatype/jackson-datatype-jsr310/2.13.0/jackson-datatype-jsr310-2.13.0.jar:/Users/gaborsomogyi/.m2/repository/io/fabric8/zjsonpatch/0.3.0/zjsonpatch-0.3.0.jar:/Users/gaborsomogyi/.m2/repository/com/github/mifmif/generex/1.0.2/generex-1.0.2.jar:/Users/gaborsomogyi/.m2/repository/dk/brics/automaton/automaton/1.11-8/automaton-1.11-8.jar:/Users/gaborsomogyi/flink/flink-filesystems/flink-hadoop-fs/target/classes:/Users/gab
orsomogyi/flink/flink-runtime/target/test-classes:/Users/gaborsomogyi/flink/flink-rpc/flink-rpc-core/target/classes:/Users/gaborsomogyi/flink/flink-rpc/flink-rpc-akka-loader/target/classes:/Users/gaborsomogyi/flink/flink-queryable-state/flink-queryable-state-client-java/target/classes:/Users/gaborsomogyi/.m2/repository/commons-io/commons-io/2.11.0/commons-io-2.11.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-netty/4.1.70.Final-15.0/flink-shaded-netty-4.1.70.Final-15.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-guava/30.1.1-jre-15.0/flink-shaded-guava-30.1.1-jre-15.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-jackson/2.12.4-15.0/flink-shaded-jackson-2.12.4-15.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-zookeeper-3/3.5.9-15.0/flink-shaded-zookeeper-3-3.5.9-15.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/commons/commons-lang3/3.3.2/commons-lang3-3.3.2.jar:/Users/gaborsomogyi/.
m2/repository/commons-cli/commons-cli/1.5.0/commons-cli-1.5.0.jar:/Users/gaborsomogyi/.m2/repository/org/javassist/javassist/3.24.0-GA/javassist-3.24.0-GA.jar:/Users/gaborsomogyi/.m2/repository/org/xerial/snappy/snappy-java/1.1.8.3/snappy-java-1.1.8.3.jar:/Users/gaborsomogyi/.m2/repository/org/lz4/lz4-java/1.8.0/lz4-java-1.8.0.jar:/Users/gaborsomogyi/flink/flink-clients/target/test-classes:/Users/gaborsomogyi/flink/flink-streaming-java/target/classes:/Users/gaborsomogyi/flink/flink-connectors/flink-file-sink-common/target/classes:/Users/gaborsomogyi/.m2/repository/org/apache/commons/commons-math3/3.6.1/commons-math3-3.6.1.jar:/Users/gaborsomogyi/flink/flink-yarn/target/classes:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.8.5/hadoop-hdfs-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-hdfs-client/2.8.5/hadoop-hdfs-client-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/com/squareup/okhttp/okhttp/2.4.0/okhttp-2.4.0.jar:/Users/gaborsomogyi/.m2/re
pository/commons-daemon/commons-daemon/1.0.13/commons-daemon-1.0.13.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-all/4.1.70.Final/netty-all-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-buffer/4.1.70.Final/netty-buffer-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec/4.1.70.Final/netty-codec-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-dns/4.1.70.Final/netty-codec-dns-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-haproxy/4.1.70.Final/netty-codec-haproxy-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-http/4.1.70.Final/netty-codec-http-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-http2/4.1.70.Final/netty-codec-http2-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-memcache/4.1.70.Final/netty-codec-memcache-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-mqtt/4.1.70.Final/netty
-codec-mqtt-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-redis/4.1.70.Final/netty-codec-redis-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-smtp/4.1.70.Final/netty-codec-smtp-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-socks/4.1.70.Final/netty-codec-socks-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-stomp/4.1.70.Final/netty-codec-stomp-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-codec-xml/4.1.70.Final/netty-codec-xml-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-common/4.1.70.Final/netty-common-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-handler/4.1.70.Final/netty-handler-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-handler-proxy/4.1.70.Final/netty-handler-proxy-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-resolver/4.1.70.Final/netty-resolver-4.1.70.Final.jar:/Use
rs/gaborsomogyi/.m2/repository/io/netty/netty-resolver-dns/4.1.70.Final/netty-resolver-dns-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport/4.1.70.Final/netty-transport-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-rxtx/4.1.70.Final/netty-transport-rxtx-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-sctp/4.1.70.Final/netty-transport-sctp-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-udt/4.1.70.Final/netty-transport-udt-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-classes-epoll/4.1.70.Final/netty-transport-classes-epoll-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-native-unix-common/4.1.70.Final/netty-transport-native-unix-common-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-classes-kqueue/4.1.70.Final/netty-transport-classes-kqueue-4.1.70.Final.jar:/Users/gaborsomogyi/.m2
/repository/io/netty/netty-resolver-dns-classes-macos/4.1.70.Final/netty-resolver-dns-classes-macos-4.1.70.Final.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-native-epoll/4.1.70.Final/netty-transport-native-epoll-4.1.70.Final-linux-x86_64.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-native-epoll/4.1.70.Final/netty-transport-native-epoll-4.1.70.Final-linux-aarch_64.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-native-kqueue/4.1.70.Final/netty-transport-native-kqueue-4.1.70.Final-osx-x86_64.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-transport-native-kqueue/4.1.70.Final/netty-transport-native-kqueue-4.1.70.Final-osx-aarch_64.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-resolver-dns-native-macos/4.1.70.Final/netty-resolver-dns-native-macos-4.1.70.Final-osx-x86_64.jar:/Users/gaborsomogyi/.m2/repository/io/netty/netty-resolver-dns-native-macos/4.1.70.Final/netty-resolver-dns-native-macos-4.1.70.Final-osx-aarch_64.
jar:/Users/gaborsomogyi/.m2/repository/xerces/xercesImpl/2.9.1/xercesImpl-2.9.1.jar:/Users/gaborsomogyi/.m2/repository/xml-apis/xml-apis/1.3.04/xml-apis-1.3.04.jar:/Users/gaborsomogyi/.m2/repository/org/fusesource/leveldbjni/leveldbjni-all/1.8/leveldbjni-all-1.8.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-common/2.8.5/hadoop-yarn-common-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/javax/xml/bind/jaxb-api/2.3.1/jaxb-api-2.3.1.jar:/Users/gaborsomogyi/.m2/repository/javax/activation/javax.activation-api/1.2.0/javax.activation-api-1.2.0.jar:/Users/gaborsomogyi/.m2/repository/com/sun/jersey/jersey-client/1.9/jersey-client-1.9.jar:/Users/gaborsomogyi/.m2/repository/org/codehaus/jackson/jackson-jaxrs/1.9.13/jackson-jaxrs-1.9.13.jar:/Users/gaborsomogyi/.m2/repository/org/codehaus/jackson/jackson-xc/1.9.13/jackson-xc-1.9.13.jar:/Users/gaborsomogyi/.m2/repository/com/google/inject/extensions/guice-servlet/3.0/guice-servlet-3.0.jar:/Users/gaborsomogyi/.m2/repository/co
m/google/inject/guice/3.0/guice-3.0.jar:/Users/gaborsomogyi/.m2/repository/javax/inject/javax.inject/1/javax.inject-1.jar:/Users/gaborsomogyi/.m2/repository/aopalliance/aopalliance/1.0/aopalliance-1.0.jar:/Users/gaborsomogyi/.m2/repository/com/sun/jersey/contribs/jersey-guice/1.9/jersey-guice-1.9.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-core/2.8.5/hadoop-mapreduce-client-core-2.8.5.jar:/Users/gaborsomogyi/flink/flink-yarn/target/test-classes:/Users/gaborsomogyi/flink/flink-examples/flink-examples-batch/target/classes:/Users/gaborsomogyi/flink/flink-scala/target/classes:/Users/gaborsomogyi/.m2/repository/org/scala-lang/scala-reflect/2.12.7/scala-reflect-2.12.7.jar:/Users/gaborsomogyi/.m2/repository/org/scala-lang/scala-library/2.12.7/scala-library-2.12.7.jar:/Users/gaborsomogyi/.m2/repository/org/scala-lang/scala-compiler/2.12.7/scala-compiler-2.12.7.jar:/Users/gaborsomogyi/.m2/repository/org/scala-lang/modules/scala-xml_2.12/1.0.6/scala-xml_2.
12-1.0.6.jar:/Users/gaborsomogyi/.m2/repository/com/twitter/chill_2.12/0.7.6/chill_2.12-0.7.6.jar:/Users/gaborsomogyi/flink/flink-examples/flink-examples-streaming/target/classes:/Users/gaborsomogyi/flink/flink-streaming-scala/target/classes:/Users/gaborsomogyi/flink/flink-connectors/flink-connector-twitter/target/classes:/Users/gaborsomogyi/.m2/repository/com/twitter/hbc-core/2.2.0/hbc-core-2.2.0.jar:/Users/gaborsomogyi/.m2/repository/com/twitter/joauth/6.0.2/joauth-6.0.2.jar:/Users/gaborsomogyi/flink/flink-connectors/flink-connector-files/target/classes:/Users/gaborsomogyi/flink/flink-connectors/flink-connector-base/target/classes:/Users/gaborsomogyi/flink/flink-connectors/flink-connector-kafka/target/classes:/Users/gaborsomogyi/.m2/repository/org/apache/kafka/kafka-clients/2.8.1/kafka-clients-2.8.1.jar:/Users/gaborsomogyi/.m2/repository/com/github/luben/zstd-jni/1.4.9-1/zstd-jni-1.4.9-1.jar:/Users/gaborsomogyi/.m2/repository/org/jcuda/jcuda/10.0.0/jcuda-10.0.0.jar:/Users/gaborsom
ogyi/.m2/repository/org/jcuda/jcublas/10.0.0/jcublas-10.0.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-common/2.8.5/hadoop-common-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-annotations/2.8.5/hadoop-annotations-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/com/google/guava/guava/11.0.2/guava-11.0.2.jar:/Users/gaborsomogyi/.m2/repository/xmlenc/xmlenc/0.52/xmlenc-0.52.jar:/Users/gaborsomogyi/.m2/repository/org/apache/httpcomponents/httpclient/4.5.13/httpclient-4.5.13.jar:/Users/gaborsomogyi/.m2/repository/org/apache/httpcomponents/httpcore/4.4.14/httpcore-4.4.14.jar:/Users/gaborsomogyi/.m2/repository/commons-codec/commons-codec/1.15/commons-codec-1.15.jar:/Users/gaborsomogyi/.m2/repository/commons-net/commons-net/3.1/commons-net-3.1.jar:/Users/gaborsomogyi/.m2/repository/commons-collections/commons-collections/3.2.2/commons-collections-3.2.2.jar:/Users/gaborsomogyi/.m2/repository/javax/servlet/servlet-api/2.5/servlet-api-2.5.jar:/Users/ga
borsomogyi/.m2/repository/org/mortbay/jetty/jetty/6.1.26/jetty-6.1.26.jar:/Users/gaborsomogyi/.m2/repository/org/mortbay/jetty/jetty-util/6.1.26/jetty-util-6.1.26.jar:/Users/gaborsomogyi/.m2/repository/org/mortbay/jetty/jetty-sslengine/6.1.26/jetty-sslengine-6.1.26.jar:/Users/gaborsomogyi/.m2/repository/javax/servlet/jsp/jsp-api/2.1/jsp-api-2.1.jar:/Users/gaborsomogyi/.m2/repository/com/sun/jersey/jersey-core/1.9/jersey-core-1.9.jar:/Users/gaborsomogyi/.m2/repository/com/sun/jersey/jersey-json/1.9/jersey-json-1.9.jar:/Users/gaborsomogyi/.m2/repository/org/codehaus/jettison/jettison/1.1/jettison-1.1.jar:/Users/gaborsomogyi/.m2/repository/com/sun/xml/bind/jaxb-impl/2.2.3-1/jaxb-impl-2.2.3-1.jar:/Users/gaborsomogyi/.m2/repository/com/sun/jersey/jersey-server/1.9/jersey-server-1.9.jar:/Users/gaborsomogyi/.m2/repository/asm/asm/3.1/asm-3.1.jar:/Users/gaborsomogyi/.m2/repository/commons-logging/commons-logging/1.1.3/commons-logging-1.1.3.jar:/Users/gaborsomogyi/.m2/repository/net/java/dev
/jets3t/jets3t/0.9.0/jets3t-0.9.0.jar:/Users/gaborsomogyi/.m2/repository/com/jamesmurty/utils/java-xmlbuilder/0.4/java-xmlbuilder-0.4.jar:/Users/gaborsomogyi/.m2/repository/commons-lang/commons-lang/2.6/commons-lang-2.6.jar:/Users/gaborsomogyi/.m2/repository/commons-configuration/commons-configuration/1.7/commons-configuration-1.7.jar:/Users/gaborsomogyi/.m2/repository/commons-digester/commons-digester/1.8.1/commons-digester-1.8.1.jar:/Users/gaborsomogyi/.m2/repository/commons-beanutils/commons-beanutils/1.8.3/commons-beanutils-1.8.3.jar:/Users/gaborsomogyi/.m2/repository/org/codehaus/jackson/jackson-core-asl/1.9.13/jackson-core-asl-1.9.13.jar:/Users/gaborsomogyi/.m2/repository/org/codehaus/jackson/jackson-mapper-asl/1.9.13/jackson-mapper-asl-1.9.13.jar:/Users/gaborsomogyi/.m2/repository/org/apache/avro/avro/1.10.0/avro-1.10.0.jar:/Users/gaborsomogyi/.m2/repository/com/fasterxml/jackson/core/jackson-core/2.13.0/jackson-core-2.13.0.jar:/Users/gaborsomogyi/.m2/repository/com/fasterxml
/jackson/core/jackson-databind/2.13.0/jackson-databind-2.13.0.jar:/Users/gaborsomogyi/.m2/repository/com/fasterxml/jackson/core/jackson-annotations/2.13.0/jackson-annotations-2.13.0.jar:/Users/gaborsomogyi/.m2/repository/com/google/protobuf/protobuf-java/2.5.0/protobuf-java-2.5.0.jar:/Users/gaborsomogyi/.m2/repository/com/google/code/gson/gson/2.2.4/gson-2.2.4.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-auth/2.8.5/hadoop-auth-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/com/nimbusds/nimbus-jose-jwt/4.41.1/nimbus-jose-jwt-4.41.1.jar:/Users/gaborsomogyi/.m2/repository/com/github/stephenc/jcip/jcip-annotations/1.0-1/jcip-annotations-1.0-1.jar:/Users/gaborsomogyi/.m2/repository/net/minidev/json-smart/2.3/json-smart-2.3.jar:/Users/gaborsomogyi/.m2/repository/net/minidev/accessors-smart/1.2/accessors-smart-1.2.jar:/Users/gaborsomogyi/.m2/repository/org/ow2/asm/asm/5.0.4/asm-5.0.4.jar:/Users/gaborsomogyi/.m2/repository/org/apache/directory/server/apacheds-kerberos-codec
/2.0.0-M15/apacheds-kerberos-codec-2.0.0-M15.jar:/Users/gaborsomogyi/.m2/repository/org/apache/directory/server/apacheds-i18n/2.0.0-M15/apacheds-i18n-2.0.0-M15.jar:/Users/gaborsomogyi/.m2/repository/org/apache/directory/api/api-asn1-api/1.0.0-M20/api-asn1-api-1.0.0-M20.jar:/Users/gaborsomogyi/.m2/repository/org/apache/directory/api/api-util/1.0.0-M20/api-util-1.0.0-M20.jar:/Users/gaborsomogyi/.m2/repository/org/apache/curator/curator-framework/2.7.1/curator-framework-2.7.1.jar:/Users/gaborsomogyi/.m2/repository/com/jcraft/jsch/0.1.54/jsch-0.1.54.jar:/Users/gaborsomogyi/.m2/repository/org/apache/curator/curator-client/2.7.1/curator-client-2.7.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/curator/curator-recipes/2.7.1/curator-recipes-2.7.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/htrace/htrace-core4/4.0.1-incubating/htrace-core4-4.0.1-incubating.jar:/Users/gaborsomogyi/.m2/repository/org/apache/zookeeper/zookeeper/3.5.9/zookeeper-3.5.9.jar:/Users/gaborsomogyi/.m2/reposi
tory/org/apache/zookeeper/zookeeper-jute/3.5.9/zookeeper-jute-3.5.9.jar:/Users/gaborsomogyi/.m2/repository/org/apache/yetus/audience-annotations/0.5.0/audience-annotations-0.5.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/commons/commons-compress/1.21/commons-compress-1.21.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-client/2.8.5/hadoop-yarn-client-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-api/2.8.5/hadoop-yarn-api-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-minicluster/2.8.5/hadoop-minicluster-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-common/2.8.5/hadoop-common-2.8.5-tests.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-hdfs/2.8.5/hadoop-hdfs-2.8.5-tests.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server-tests/2.8.5/hadoop-yarn-server-tests-2.8.5-tests.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server
-common/2.8.5/hadoop-yarn-server-common-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server-nodemanager/2.8.5/hadoop-yarn-server-nodemanager-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server-resourcemanager/2.8.5/hadoop-yarn-server-resourcemanager-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server-applicationhistoryservice/2.8.5/hadoop-yarn-server-applicationhistoryservice-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/zookeeper/zookeeper/3.4.6/zookeeper-3.4.6-tests.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-jobclient/2.8.5/hadoop-mapreduce-client-jobclient-2.8.5-tests.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-common/2.8.5/hadoop-mapreduce-client-common-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-shuffle/2.8.5/hadoop-mapreduce-client-shuffle-2.8.5.jar:/Users/gabors
omogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-app/2.8.5/hadoop-mapreduce-client-app-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-yarn-server-web-proxy/2.8.5/hadoop-yarn-server-web-proxy-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-jobclient/2.8.5/hadoop-mapreduce-client-jobclient-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-mapreduce-client-hs/2.8.5/hadoop-mapreduce-client-hs-2.8.5.jar:/Users/gaborsomogyi/.m2/repository/org/apache/hadoop/hadoop-minikdc/3.2.0/hadoop-minikdc-3.2.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-simplekdc/1.0.1/kerb-simplekdc-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-client/1.0.1/kerb-client-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerby-config/1.0.1/kerby-config-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-core/1.0.1/kerb-core-1.0.1.jar:/Users/gaborsomogyi/.m2/rep
ository/org/apache/kerby/kerby-pkix/1.0.1/kerby-pkix-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerby-asn1/1.0.1/kerby-asn1-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerby-util/1.0.1/kerby-util-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-common/1.0.1/kerb-common-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-crypto/1.0.1/kerb-crypto-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-util/1.0.1/kerb-util-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/token-provider/1.0.1/token-provider-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-admin/1.0.1/kerb-admin-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-server/1.0.1/kerb-server-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerb-identity/1.0.1/kerb-identity-1.0.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/kerby/kerby-xdr/1.0.1/kerby-xdr-1.0.1.jar:/Users/gaborsomogy
i/.m2/repository/junit/junit/4.13.2/junit-4.13.2.jar:/Users/gaborsomogyi/.m2/repository/org/apache/flink/flink-shaded-force-shading/15.0/flink-shaded-force-shading-15.0.jar:/Users/gaborsomogyi/.m2/repository/org/slf4j/slf4j-api/1.7.32/slf4j-api-1.7.32.jar:/Users/gaborsomogyi/.m2/repository/com/google/code/findbugs/jsr305/1.3.9/jsr305-1.3.9.jar:/Users/gaborsomogyi/.m2/repository/org/junit/jupiter/junit-jupiter/5.8.1/junit-jupiter-5.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/junit/jupiter/junit-jupiter-api/5.8.1/junit-jupiter-api-5.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/opentest4j/opentest4j/1.2.0/opentest4j-1.2.0.jar:/Users/gaborsomogyi/.m2/repository/org/junit/platform/junit-platform-commons/1.8.1/junit-platform-commons-1.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/junit/jupiter/junit-jupiter-params/5.8.1/junit-jupiter-params-5.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/junit/jupiter/junit-jupiter-engine/5.8.1/junit-jupiter-engine-5.8.1.jar:/Users/gaborsomogyi/.m2
/repository/org/junit/vintage/junit-vintage-engine/5.8.1/junit-vintage-engine-5.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/junit/platform/junit-platform-engine/1.8.1/junit-platform-engine-1.8.1.jar:/Users/gaborsomogyi/.m2/repository/org/apiguardian/apiguardian-api/1.1.2/apiguardian-api-1.1.2.jar:/Users/gaborsomogyi/.m2/repository/org/assertj/assertj-core/3.21.0/assertj-core-3.21.0.jar:/Users/gaborsomogyi/.m2/repository/org/mockito/mockito-core/2.21.0/mockito-core-2.21.0.jar:/Users/gaborsomogyi/.m2/repository/net/bytebuddy/byte-buddy/1.8.15/byte-buddy-1.8.15.jar:/Users/gaborsomogyi/.m2/repository/net/bytebuddy/byte-buddy-agent/1.8.15/byte-buddy-agent-1.8.15.jar:/Users/gaborsomogyi/.m2/repository/org/objenesis/objenesis/2.1/objenesis-2.1.jar:/Users/gaborsomogyi/.m2/repository/org/powermock/powermock-module-junit4/2.0.9/powermock-module-junit4-2.0.9.jar:/Users/gaborsomogyi/.m2/repository/org/powermock/powermock-module-junit4-common/2.0.9/powermock-module-junit4-common-2.0.9.jar:/Us
ers/gaborsomogyi/.m2/repository/org/powermock/powermock-reflect/2.0.9/powermock-reflect-2.0.9.jar:/Users/gaborsomogyi/.m2/repository/org/powermock/powermock-core/2.0.9/powermock-core-2.0.9.jar:/Users/gaborsomogyi/.m2/repository/org/hamcrest/hamcrest-core/1.3/hamcrest-core-1.3.jar:/Users/gaborsomogyi/.m2/repository/org/powermock/powermock-api-mockito2/2.0.9/powermock-api-mockito2-2.0.9.jar:/Users/gaborsomogyi/.m2/repository/org/powermock/powermock-api-support/2.0.9/powermock-api-support-2.0.9.jar:/Users/gaborsomogyi/.m2/repository/org/hamcrest/hamcrest-all/1.3/hamcrest-all-1.3.jar:/Users/gaborsomogyi/.m2/repository/org/testcontainers/junit-jupiter/1.16.2/junit-jupiter-1.16.2.jar:/Users/gaborsomogyi/.m2/repository/org/testcontainers/testcontainers/1.16.2/testcontainers-1.16.2.jar:/Users/gaborsomogyi/.m2/repository/org/rnorth/duct-tape/duct-tape/1.0.8/duct-tape-1.0.8.jar:/Users/gaborsomogyi/.m2/repository/org/jetbrains/annotations/17.0.0/annotations-17.0.0.jar:/Users/gaborsomogyi/.m2/r
epository/com/github/docker-java/docker-java-api/3.2.12/docker-java-api-3.2.12.jar:/Users/gaborsomogyi/.m2/repository/com/github/docker-java/docker-java-transport-zerodep/3.2.12/docker-java-transport-zerodep-3.2.12.jar:/Users/gaborsomogyi/.m2/repository/com/github/docker-java/docker-java-transport/3.2.12/docker-java-transport-3.2.12.jar:/Users/gaborsomogyi/.m2/repository/net/java/dev/jna/jna/5.8.0/jna-5.8.0.jar:/Users/gaborsomogyi/.m2/repository/org/apache/logging/log4j/log4j-slf4j-impl/2.17.1/log4j-slf4j-impl-2.17.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/logging/log4j/log4j-api/2.17.1/log4j-api-2.17.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/logging/log4j/log4j-core/2.17.1/log4j-core-2.17.1.jar:/Users/gaborsomogyi/.m2/repository/org/apache/logging/log4j/log4j-1.2-api/2.17.1/log4j-1.2-api-2.17.1.jar
com.intellij.rt.junit.JUnitStarter -ideVersion5 -junit4
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase
Feb 15, 2022 2:32:18 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver as a
provider class
Feb 15, 2022 2:32:18 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices as a root
resource class
Feb 15, 2022 2:32:18 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a
provider class
Feb 15, 2022 2:32:18 PM
com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17
AM'
Feb 15, 2022 2:32:18 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding
org.apache.hadoop.yarn.server.resourcemanager.webapp.JAXBContextResolver to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:19 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:19 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding
org.apache.hadoop.yarn.server.resourcemanager.webapp.RMWebServices to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:20 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating
that you have more than one GuiceFilter running in your web application. If
this is deliberate, you may safely ignore this message. If this is NOT
deliberate however, your application may not work as expected.
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root
resource class
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a
provider class
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a
provider class
Feb 15, 2022 2:32:20 PM
com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17
AM'
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding
org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:20 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices
to GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:21 PM com.google.inject.servlet.GuiceFilter setPipeline
WARNING: Multiple Servlet injectors detected. This is a warning indicating
that you have more than one GuiceFilter running in your web application. If
this is deliberate, you may safely ignore this message. If this is NOT
deliberate however, your application may not work as expected.
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices as a root
resource class
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering org.apache.hadoop.yarn.webapp.GenericExceptionHandler as a
provider class
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory register
INFO: Registering
org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver as a
provider class
Feb 15, 2022 2:32:21 PM
com.sun.jersey.server.impl.application.WebApplicationImpl _initiate
INFO: Initiating Jersey application, version 'Jersey: 1.9 09/02/2011 11:17
AM'
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding
org.apache.hadoop.yarn.server.nodemanager.webapp.JAXBContextResolver to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding org.apache.hadoop.yarn.webapp.GenericExceptionHandler to
GuiceManagedComponentProvider with the scope "Singleton"
Feb 15, 2022 2:32:21 PM
com.sun.jersey.guice.spi.container.GuiceComponentProviderFactory
getComponentProvider
INFO: Binding org.apache.hadoop.yarn.server.nodemanager.webapp.NMWebServices
to GuiceManagedComponentProvider with the scope "Singleton"
java.lang.RuntimeException: Runner failed
at
org.apache.flink.yarn.YarnTestBase.runWithArgs(YarnTestBase.java:1071)
at
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.lambda$perJobYarnCluster$1(YARNSessionCapacitySchedulerITCase.java:194)
at org.apache.flink.yarn.YarnTestBase.runTest(YarnTestBase.java:288)
at
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.perJobYarnCluster(YARNSessionCapacitySchedulerITCase.java:190)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.InvokeMethod.evaluate(InvokeMethod.java:17)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)
Caused by: java.lang.AssertionError: The YARN session returned with
unexpected value=1 expected=0
at org.junit.Assert.fail(Assert.java:89)
at org.apache.flink.yarn.YarnTestBase$Runner.run(YarnTestBase.java:1154)
java.lang.AssertionError: Found a file
/Users/gaborsomogyi/flink/flink-yarn-tests/target/flink-yarn-tests-capacityscheduler/flink-yarn-tests-capacityscheduler-logDir-nm-0_0/application_1644931936445_0001/container_1644931936445_0001_01_000001/jobmanager.log
with a prohibited string (one of [Exception, Started
[email protected]:8081]). Excerpts:
[
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
2022-02-15 14:33:24,855 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,859 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,882 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - Calculating tasks to restart to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,885 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - 3 tasks should be restarted to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,901 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:740)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1114)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1054)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:755)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SharedSlot.lambda$release$4(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010)
~[?:1.8.0_292]
at
org.apache.flink.runtime.scheduler.SharedSlot.release(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:464)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:456)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:427)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:249)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:230)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:505)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_292]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_292]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_292]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_292]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
Caused by: org.apache.flink.util.FlinkException: TaskExecutor
akka.tcp://[email protected]:58760/user/rpc/taskmanager_0 has no more
allocated slots for job aa0e1a4455348519fa7403114ec684e3.
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnectionIfNoAllocatedResources(TaskExecutor.java:1971)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.freeSlotInternal(TaskExecutor.java:1952)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.timeoutSlot(TaskExecutor.java:1985)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.access$3200(TaskExecutor.java:183)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor$SlotActionsImpl.lambda$timeoutSlot$1(TaskExecutor.java:2413)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
... 21 more
2022-02-15 14:33:24,914 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from DEPLOYING to CANCELING.
2022-02-15 14:33:24,917 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from DEPLOYING to
CANCELING.
2022-02-15 14:33:24,920 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from CANCELING to
CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 551d9c50ec7e7597cdea0b3291ae41fe.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from CANCELING to CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
]
at org.junit.Assert.fail(Assert.java:89)
at
org.apache.flink.yarn.YarnTestBase.ensureNoProhibitedStringInLogFiles(YarnTestBase.java:591)
at
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents(YARNSessionCapacitySchedulerITCase.java:791)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.RunAfters.invokeMethod(RunAfters.java:46)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)
java.lang.AssertionError: Found a file
/Users/gaborsomogyi/flink/flink-yarn-tests/target/flink-yarn-tests-capacityscheduler/flink-yarn-tests-capacityscheduler-logDir-nm-0_0/application_1644931936445_0001/container_1644931936445_0001_01_000001/jobmanager.log
with a prohibited string (one of [Exception, Started
[email protected]:8081]). Excerpts:
[
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
2022-02-15 14:33:24,855 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,859 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,882 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - Calculating tasks to restart to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,885 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - 3 tasks should be restarted to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,901 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:740)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1114)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1054)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:755)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SharedSlot.lambda$release$4(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010)
~[?:1.8.0_292]
at
org.apache.flink.runtime.scheduler.SharedSlot.release(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:464)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:456)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:427)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:249)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:230)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:505)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_292]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_292]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_292]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_292]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
Caused by: org.apache.flink.util.FlinkException: TaskExecutor
akka.tcp://[email protected]:58760/user/rpc/taskmanager_0 has no more
allocated slots for job aa0e1a4455348519fa7403114ec684e3.
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnectionIfNoAllocatedResources(TaskExecutor.java:1971)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.freeSlotInternal(TaskExecutor.java:1952)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.timeoutSlot(TaskExecutor.java:1985)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.access$3200(TaskExecutor.java:183)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor$SlotActionsImpl.lambda$timeoutSlot$1(TaskExecutor.java:2413)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
... 21 more
2022-02-15 14:33:24,914 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from DEPLOYING to CANCELING.
2022-02-15 14:33:24,917 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from DEPLOYING to
CANCELING.
2022-02-15 14:33:24,920 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from CANCELING to
CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 551d9c50ec7e7597cdea0b3291ae41fe.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from CANCELING to CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
]
at org.junit.Assert.fail(Assert.java:89)
at
org.apache.flink.yarn.YarnTestBase.ensureNoProhibitedStringInLogFiles(YarnTestBase.java:591)
at
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents(YARNSessionCapacitySchedulerITCase.java:791)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.RunAfters.invokeMethod(RunAfters.java:46)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)
java.lang.AssertionError: Found a file
/Users/gaborsomogyi/flink/flink-yarn-tests/target/flink-yarn-tests-capacityscheduler/flink-yarn-tests-capacityscheduler-logDir-nm-0_0/application_1644931936445_0001/container_1644931936445_0001_01_000001/jobmanager.log
with a prohibited string (one of [Exception, Started
[email protected]:8081]). Excerpts:
[
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
2022-02-15 14:33:24,855 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,859 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 35720098cae23e81ac507fee73d7b07b.
2022-02-15 14:33:24,882 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - Calculating tasks to restart to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,885 INFO
org.apache.flink.runtime.executiongraph.failover.flip1.RestartPipelinedRegionFailoverStrategy
[] - 3 tasks should be restarted to recover the failed task
fb78c8369b7b22ec97f530eea2341c09_0.
2022-02-15 14:33:24,901 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state RUNNING to FAILING.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.handleTaskFailure(DefaultScheduler.java:301)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.maybeHandleTaskFailure(DefaultScheduler.java:291)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.DefaultScheduler.updateTaskExecutionStateInternal(DefaultScheduler.java:282)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SchedulerBase.updateTaskExecutionState(SchedulerBase.java:740)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.UpdateSchedulerNgOnInternalFailuresListener.notifyTaskFailure(UpdateSchedulerNgOnInternalFailuresListener.java:51)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.DefaultExecutionGraph.notifySchedulerNgAboutInternalTaskFailure(DefaultExecutionGraph.java:1536)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1114)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.processFail(Execution.java:1054)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.Execution.fail(Execution.java:755)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.signalPayloadRelease(SingleLogicalSlot.java:195)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.SingleLogicalSlot.release(SingleLogicalSlot.java:182)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.scheduler.SharedSlot.lambda$release$4(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683)
~[?:1.8.0_292]
at
java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010)
~[?:1.8.0_292]
at
org.apache.flink.runtime.scheduler.SharedSlot.release(SharedSlot.java:271)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.AllocatedSlot.releasePayload(AllocatedSlot.java:152)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releasePayload(DefaultDeclarativeSlotPool.java:464)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.freeAndReleaseSlots(DefaultDeclarativeSlotPool.java:456)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DefaultDeclarativeSlotPool.releaseSlots(DefaultDeclarativeSlotPool.java:427)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.internalReleaseTaskManager(DeclarativeSlotPoolService.java:249)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.slotpool.DeclarativeSlotPoolService.releaseTaskManager(DeclarativeSlotPoolService.java:230)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.jobmaster.JobMaster.disconnectTaskManager(JobMaster.java:505)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
~[?:1.8.0_292]
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
~[?:1.8.0_292]
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
~[?:1.8.0_292]
at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_292]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRpcInvocation$1(AkkaRpcActor.java:304)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:83)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcInvocation(AkkaRpcActor.java:302)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:217)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.FencedAkkaRpcActor.handleRpcMessage(FencedAkkaRpcActor.java:78)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleMessage(AkkaRpcActor.java:163)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:24)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.apply(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse(PartialFunction.scala:123)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction.applyOrElse$(PartialFunction.scala:122)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.japi.pf.UnitCaseStatement.applyOrElse(CaseStatements.scala:20)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:171)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at scala.PartialFunction$OrElse.applyOrElse(PartialFunction.scala:172)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive(Actor.scala:537)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.Actor.aroundReceive$(Actor.scala:535)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.AbstractActor.aroundReceive(AbstractActor.scala:220)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.receiveMessage(ActorCell.scala:580)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.actor.ActorCell.invoke(ActorCell.scala:548)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:270)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.run(Mailbox.scala:231)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at akka.dispatch.Mailbox.exec(Mailbox.scala:243)
[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at java.util.concurrent.ForkJoinTask.doExec(ForkJoinTask.java:289)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1056)
[?:1.8.0_292]
at java.util.concurrent.ForkJoinPool.runWorker(ForkJoinPool.java:1692)
[?:1.8.0_292]
at
java.util.concurrent.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:175)
[?:1.8.0_292]
Caused by: org.apache.flink.util.FlinkException: TaskExecutor
akka.tcp://[email protected]:58760/user/rpc/taskmanager_0 has no more
allocated slots for job aa0e1a4455348519fa7403114ec684e3.
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.closeJobManagerConnectionIfNoAllocatedResources(TaskExecutor.java:1971)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.freeSlotInternal(TaskExecutor.java:1952)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.timeoutSlot(TaskExecutor.java:1985)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor.access$3200(TaskExecutor.java:183)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.taskexecutor.TaskExecutor$SlotActionsImpl.lambda$timeoutSlot$1(TaskExecutor.java:2413)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.lambda$handleRunAsync$4(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.concurrent.akka.ClassLoadingUtils.runWithContextClassLoader(ClassLoadingUtils.java:68)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRunAsync(AkkaRpcActor.java:443)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.rpc.akka.AkkaRpcActor.handleRpcMessage(AkkaRpcActor.java:213)
~[flink-rpc-akka_ac9379dd-9b4d-4d05-964a-b32db2a72309.jar:1.15-SNAPSHOT]
... 21 more
2022-02-15 14:33:24,914 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from DEPLOYING to CANCELING.
2022-02-15 14:33:24,917 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from DEPLOYING to
CANCELING.
2022-02-15 14:33:24,920 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - DataSink
(collect()) (1/1) (551d9c50ec7e7597cdea0b3291ae41fe) switched from CANCELING to
CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 551d9c50ec7e7597cdea0b3291ae41fe.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - CHAIN
DataSource (at getDefaultTextLineDataSet(WordCountData.java:70)
(org.apache.flink.api.java.io.CollectionInputFormat)) -> FlatMap (FlatMap at
main(WordCount.java:84)) -> Combine (SUM(1), at main(WordCount.java:87) (1/1)
(3f9bfdb7db4819c39bb8186f8f9548f7) switched from CANCELING to CANCELED.
2022-02-15 14:33:24,921 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Discarding
the results produced by task execution 3f9bfdb7db4819c39bb8186f8f9548f7.
2022-02-15 14:33:24,922 INFO
org.apache.flink.runtime.executiongraph.ExecutionGraph [] - Job Flink
Java Job at Tue Feb 15 14:32:22 CET 2022 (aa0e1a4455348519fa7403114ec684e3)
switched from state FAILING to FAILED.
org.apache.flink.runtime.JobException: Recovery is suppressed by
NoRestartBackoffTimeStrategy
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.handleFailure(ExecutionFailureHandler.java:138)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at
org.apache.flink.runtime.executiongraph.failover.flip1.ExecutionFailureHandler.getFailureHandlingResult(ExecutionFailureHandler.java:82)
~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
]
at org.junit.Assert.fail(Assert.java:89)
at
org.apache.flink.yarn.YarnTestBase.ensureNoProhibitedStringInLogFiles(YarnTestBase.java:591)
at
org.apache.flink.yarn.YARNSessionCapacitySchedulerITCase.checkForProhibitedLogContents(YARNSessionCapacitySchedulerITCase.java:791)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at
sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at
sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at
org.junit.runners.model.FrameworkMethod$1.runReflectiveCall(FrameworkMethod.java:59)
at
org.junit.internal.runners.model.ReflectiveCallable.run(ReflectiveCallable.java:12)
at
org.junit.runners.model.FrameworkMethod.invokeExplosively(FrameworkMethod.java:56)
at
org.junit.internal.runners.statements.RunAfters.invokeMethod(RunAfters.java:46)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:33)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at
org.apache.flink.util.TestNameProvider$1.evaluate(TestNameProvider.java:45)
at org.junit.rules.TestWatcher$1.evaluate(TestWatcher.java:61)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at
org.junit.runners.BlockJUnit4ClassRunner$1.evaluate(BlockJUnit4ClassRunner.java:100)
at org.junit.runners.ParentRunner.runLeaf(ParentRunner.java:366)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:103)
at
org.junit.runners.BlockJUnit4ClassRunner.runChild(BlockJUnit4ClassRunner.java:63)
at org.junit.runners.ParentRunner$4.run(ParentRunner.java:331)
at org.junit.runners.ParentRunner$1.schedule(ParentRunner.java:79)
at org.junit.runners.ParentRunner.runChildren(ParentRunner.java:329)
at org.junit.runners.ParentRunner.access$100(ParentRunner.java:66)
at org.junit.runners.ParentRunner$2.evaluate(ParentRunner.java:293)
at
org.junit.internal.runners.statements.RunBefores.evaluate(RunBefores.java:26)
at
org.junit.internal.runners.statements.RunAfters.evaluate(RunAfters.java:27)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.ExternalResource$1.evaluate(ExternalResource.java:54)
at org.junit.rules.RunRules.evaluate(RunRules.java:20)
at org.junit.runners.ParentRunner$3.evaluate(ParentRunner.java:306)
at org.junit.runners.ParentRunner.run(ParentRunner.java:413)
at org.junit.runner.JUnitCore.run(JUnitCore.java:137)
at
com.intellij.junit4.JUnit4IdeaTestRunner.startRunnerWithArgs(JUnit4IdeaTestRunner.java:69)
at
com.intellij.rt.junit.IdeaTestRunner$Repeater.startRunnerWithArgs(IdeaTestRunner.java:33)
at
com.intellij.rt.junit.JUnitStarter.prepareStreamsAndStart(JUnitStarter.java:235)
at com.intellij.rt.junit.JUnitStarter.main(JUnitStarter.java:54)
Process finished with exit code 130 (interrupted by signal 2: SIGINT)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
