[
https://issues.apache.org/jira/browse/FLINK-16921?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17081840#comment-17081840
]
Zhijiang commented on FLINK-16921:
----------------------------------
Another instance for this test failure, but not given specific reason, I guess
not finish within expected time. The log is
[https://api.travis-ci.org/v3/job/673786844/log.txt]
> "kubernetes session test" is unstable
> -------------------------------------
>
> Key: FLINK-16921
> URL: https://issues.apache.org/jira/browse/FLINK-16921
> Project: Flink
> Issue Type: Bug
> Components: Deployment / Kubernetes, Tests
> Affects Versions: 1.11.0
> Reporter: Robert Metzger
> Assignee: Yang Wang
> Priority: Blocker
> Labels: pull-request-available, test-stability
> Fix For: 1.11.0
>
> Time Spent: 1h
> Remaining Estimate: 0h
>
> CI:
> https://dev.azure.com/rmetzger/Flink/_build/results?buildId=6915&view=logs&j=c88eea3b-64a0-564d-0031-9fdcd7b8abee&t=1e2bbe5b-4657-50be-1f07-d84bfce5b1f5
> I assume some services didn't come up?
> {code}
> Caused by: java.util.concurrent.CompletionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> {code}
> Full log
> {code}
> 2020-04-01T09:13:59.0673858Z Successfully built ba628fa7af0d
> 2020-04-01T09:13:59.0726818Z Successfully tagged
> test_kubernetes_session:latest
> 2020-04-01T09:13:59.2547709Z
> clusterrolebinding.rbac.authorization.k8s.io/flink-role-binding-default
> created
> 2020-04-01T09:14:00.0586087Z 2020-04-01 09:14:00,055 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:14:00.0608876Z 2020-04-01 09:14:00,060 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:14:00.0611236Z 2020-04-01 09:14:00,060 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:14:00.0613869Z 2020-04-01 09:14:00,061 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:14:00.0616344Z 2020-04-01 09:14:00,061 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:14:00.0619384Z 2020-04-01 09:14:00,061 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:14:00.0624467Z 2020-04-01 09:14:00,062 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:14:00.9838038Z 2020-04-01 09:14:00,983 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
> 2020-04-01T09:14:00.9922554Z 2020-04-01 09:14:00,991 INFO
> org.apache.flink.kubernetes.utils.KubernetesUtils [] - Kubernetes
> deployment requires a fixed port. Configuration blob.server.port will be set
> to 6124
> 2020-04-01T09:14:00.9927409Z 2020-04-01 09:14:00,992 INFO
> org.apache.flink.kubernetes.utils.KubernetesUtils [] - Kubernetes
> deployment requires a fixed port. Configuration taskmanager.rpc.port will be
> set to 6122
> 2020-04-01T09:14:01.0587014Z 2020-04-01 09:14:01,058 WARN
> org.apache.flink.kubernetes.kubeclient.decorators.HadoopConfMountDecorator []
> - Found 0 files in directory null/etc/hadoop, skip to mount the Hadoop
> Configuration ConfigMap.
> 2020-04-01T09:14:01.0592498Z 2020-04-01 09:14:01,059 WARN
> org.apache.flink.kubernetes.kubeclient.decorators.HadoopConfMountDecorator []
> - Found 0 files in directory null/etc/hadoop, skip to create the Hadoop
> Configuration ConfigMap.
> 2020-04-01T09:14:01.8684880Z 2020-04-01 09:14:01,868 INFO
> org.apache.flink.kubernetes.KubernetesClusterDescriptor [] - Create
> flink session cluster flink-native-k8s-session-1 successfully, JobManager Web
> Interface: http://10.1.0.4:30095
> 2020-04-01T09:14:03.2952029Z Executing WordCount example with default input
> data set.
> 2020-04-01T09:14:03.2955365Z Use --input to specify file input.
> 2020-04-01T09:15:31.5606577Z
> 2020-04-01T09:15:31.5610358Z
> ------------------------------------------------------------
> 2020-04-01T09:15:31.5610913Z The program finished with the following
> exception:
> 2020-04-01T09:15:31.5611114Z
> 2020-04-01T09:15:31.5611772Z
> org.apache.flink.client.program.ProgramInvocationException: The main method
> caused an error: java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:31.5617073Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335)
> 2020-04-01T09:15:31.5629389Z at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205)
> 2020-04-01T09:15:31.5665671Z at
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:143)
> 2020-04-01T09:15:31.5667385Z at
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:659)
> 2020-04-01T09:15:31.5668074Z at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:210)
> 2020-04-01T09:15:31.5668537Z at
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:890)
> 2020-04-01T09:15:31.5670148Z at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:963)
> 2020-04-01T09:15:31.5670582Z at
> java.security.AccessController.doPrivileged(Native Method)
> 2020-04-01T09:15:31.5671095Z at
> javax.security.auth.Subject.doAs(Subject.java:422)
> 2020-04-01T09:15:31.5671703Z at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
> 2020-04-01T09:15:31.5672240Z at
> org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> 2020-04-01T09:15:31.5672717Z at
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:963)
> 2020-04-01T09:15:31.5673439Z Caused by: java.lang.RuntimeException:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:31.5674090Z at
> org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:276)
> 2020-04-01T09:15:31.5674589Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:969)
> 2020-04-01T09:15:31.5675154Z at
> org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:85)
> 2020-04-01T09:15:31.5675704Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
> 2020-04-01T09:15:31.5676202Z at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:93)
> 2020-04-01T09:15:31.5676842Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
> 2020-04-01T09:15:31.5677375Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> 2020-04-01T09:15:31.5677862Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> 2020-04-01T09:15:31.5678271Z at
> java.lang.reflect.Method.invoke(Method.java:498)
> 2020-04-01T09:15:31.5678675Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> 2020-04-01T09:15:31.5679004Z ... 11 more
> 2020-04-01T09:15:31.5679444Z Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:31.5679993Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> 2020-04-01T09:15:31.5680572Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> 2020-04-01T09:15:31.5681024Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:964)
> 2020-04-01T09:15:31.5681359Z ... 19 more
> 2020-04-01T09:15:31.5681666Z Caused by:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:31.5682177Z at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:359)
> 2020-04-01T09:15:31.5682684Z at
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> 2020-04-01T09:15:31.5683158Z at
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> 2020-04-01T09:15:31.5683794Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-04-01T09:15:31.5684288Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> 2020-04-01T09:15:31.5684849Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:287)
> 2020-04-01T09:15:31.5685376Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> 2020-04-01T09:15:31.5685893Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> 2020-04-01T09:15:31.5686503Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> 2020-04-01T09:15:31.5687195Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> 2020-04-01T09:15:31.5688323Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> 2020-04-01T09:15:31.5688868Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> 2020-04-01T09:15:31.5689573Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> 2020-04-01T09:15:31.5690170Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> 2020-04-01T09:15:31.5690741Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> 2020-04-01T09:15:31.5691310Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> 2020-04-01T09:15:31.5691854Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> 2020-04-01T09:15:31.5692416Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> 2020-04-01T09:15:31.5693043Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> 2020-04-01T09:15:31.5693711Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> 2020-04-01T09:15:31.5694327Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> 2020-04-01T09:15:31.5695684Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> 2020-04-01T09:15:31.5696348Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> 2020-04-01T09:15:31.5696964Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> 2020-04-01T09:15:31.5697862Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> 2020-04-01T09:15:31.5698916Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> 2020-04-01T09:15:31.5700726Z at java.lang.Thread.run(Thread.java:748)
> 2020-04-01T09:15:31.5701197Z Caused by:
> org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not
> complete the operation. Number of retries has been exhausted.
> 2020-04-01T09:15:31.5701923Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:284)
> 2020-04-01T09:15:31.5702265Z ... 21 more
> 2020-04-01T09:15:31.5702770Z Caused by:
> java.util.concurrent.CompletionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:31.5703655Z at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> 2020-04-01T09:15:31.5704266Z at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> 2020-04-01T09:15:31.5704736Z at
> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:957)
> 2020-04-01T09:15:31.5705194Z at
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
> 2020-04-01T09:15:31.5705520Z ... 19 more
> 2020-04-01T09:15:31.5705931Z Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:31.5706441Z Caused by: java.net.ConnectException: Connection
> refused
> 2020-04-01T09:15:31.5706773Z at
> sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
> 2020-04-01T09:15:31.5707130Z at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:714)
> 2020-04-01T09:15:31.5707650Z at
> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
> 2020-04-01T09:15:31.5708275Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
> 2020-04-01T09:15:31.5708890Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> 2020-04-01T09:15:31.5709552Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> 2020-04-01T09:15:31.5710126Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> 2020-04-01T09:15:31.5710661Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> 2020-04-01T09:15:31.5711214Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> 2020-04-01T09:15:31.5711842Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> 2020-04-01T09:15:31.5712263Z at java.lang.Thread.run(Thread.java:748)
> 2020-04-01T09:15:31.6868426Z error: filespec must match the canonical format:
> [[namespace/]pod:]file/path
> 2020-04-01T09:15:31.6921059Z sort: cannot read:
> '/home/vsts/work/1/s/flink-end-to-end-tests/test-scripts/temp-test-directory-37181306061/out/wc_out*':
> No such file or directory
> 2020-04-01T09:15:31.6929489Z FAIL WordCount: Output hash mismatch. Got
> d41d8cd98f00b204e9800998ecf8427e, expected e682ec6622b5e83f2eb614617d5ab2cf.
> 2020-04-01T09:15:31.6930063Z head hexdump of actual:
> 2020-04-01T09:15:31.6944131Z head: cannot open
> '/home/vsts/work/1/s/flink-end-to-end-tests/test-scripts/temp-test-directory-37181306061/out/wc_out*'
> for reading: No such file or directory
> 2020-04-01T09:15:31.7805615Z deployment.apps "flink-native-k8s-session-1"
> deleted
> 2020-04-01T09:15:31.8726196Z clusterrolebinding.rbac.authorization.k8s.io
> "flink-role-binding-default" deleted
> 2020-04-01T09:15:31.8752534Z Stopping minikube ...
> 2020-04-01T09:15:31.9416557Z * Stopping "minikube" in none ...
> 2020-04-01T09:15:52.2656905Z * Node "" stopped.
> 2020-04-01T09:15:52.2698505Z [FAIL] Test script contains errors.
> 2020-04-01T09:15:52.2708182Z Checking for errors...
> 2020-04-01T09:15:52.2952618Z Found error in log files:
> 2020-04-01T09:15:52.2985933Z 2020-04-01 09:14:02,666 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> --------------------------------------------------------------------------------
> 2020-04-01T09:15:52.2987997Z 2020-04-01 09:14:02,681 INFO
> org.apache.flink.client.cli.CliFrontend [] - Starting
> Command Line Client (Version: 1.11-SNAPSHOT, Rev:f97b1b5, Date:01.04.2020 @
> 08:00:52 UTC)
> 2020-04-01T09:15:52.2989547Z 2020-04-01 09:14:02,681 INFO
> org.apache.flink.client.cli.CliFrontend [] - OS current
> user: vsts
> 2020-04-01T09:15:52.2990871Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - Current
> Hadoop/Kerberos user: vsts
> 2020-04-01T09:15:52.2992274Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - JVM:
> OpenJDK 64-Bit Server VM - Azul Systems, Inc. - 1.8/25.242-b20
> 2020-04-01T09:15:52.2993652Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - Maximum
> heap size: 1545 MiBytes
> 2020-04-01T09:15:52.2995282Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - JAVA_HOME:
> /usr/lib/jvm/zulu-8-azure-amd64
> 2020-04-01T09:15:52.2996609Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] - Hadoop
> version: 2.8.3
> 2020-04-01T09:15:52.2997906Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] - JVM
> Options:
> 2020-04-01T09:15:52.2999338Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog.file=/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/log/flink-vsts-client-fv-az510.log
> 2020-04-01T09:15:52.3001044Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog4j.configuration=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/log4j-cli.properties
> 2020-04-01T09:15:52.3003113Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog4j.configurationFile=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/log4j-cli.properties
> 2020-04-01T09:15:52.3004826Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlogback.configurationFile=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/logback.xml
> 2020-04-01T09:15:52.3008292Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - Program
> Arguments:
> 2020-04-01T09:15:52.3009068Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - run
> 2020-04-01T09:15:52.3009777Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - -e
> 2020-04-01T09:15:52.3010534Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> kubernetes-session
> 2020-04-01T09:15:52.3011388Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dkubernetes.cluster-id=flink-native-k8s-session-1
> 2020-04-01T09:15:52.3012467Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/examples/batch/WordCount.jar
> 2020-04-01T09:15:52.3013382Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - --output
> 2020-04-01T09:15:52.3014112Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> /tmp/wc_out
> 2020-04-01T09:15:52.3017725Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - Classpath:
> /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-zookeeper-3.4.10.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-table_2.11-1.11-SNAPSHOT.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-table-blink_2.11-1.11-SNAPSHOT.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-1.2-api-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-api-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-core-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-slf4j-impl-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-dist_2.11-1.11-SNAPSHOT.jar:::
> 2020-04-01T09:15:52.3020796Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> --------------------------------------------------------------------------------
> 2020-04-01T09:15:52.3021831Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3023145Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3024241Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3025360Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3026692Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3027826Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3028887Z 2020-04-01 09:14:03,064 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3030033Z 2020-04-01 09:14:03,177 WARN
> org.apache.flink.runtime.util.HadoopUtils [] - Could not
> find Hadoop configuration via any of the supported methods (Flink
> configuration, environment variables).
> 2020-04-01T09:15:52.3031153Z 2020-04-01 09:14:03,212 INFO
> org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user
> set to vsts (auth:SIMPLE), credentials check status: true
> 2020-04-01T09:15:52.3032320Z 2020-04-01 09:14:03,220 INFO
> org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file
> will be created as /tmp/jaas-7188653955626299344.conf.
> 2020-04-01T09:15:52.3033214Z 2020-04-01 09:14:03,234 INFO
> org.apache.flink.client.cli.CliFrontend [] - Running
> 'run' command.
> 2020-04-01T09:15:52.3034045Z 2020-04-01 09:14:03,237 INFO
> org.apache.flink.client.cli.CliFrontend [] - Building
> program from JAR file
> 2020-04-01T09:15:52.3034933Z 2020-04-01 09:14:03,261 INFO
> org.apache.flink.client.ClientUtils [] - Starting
> program (detached: false)
> 2020-04-01T09:15:52.3035967Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3037022Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3038072Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3039296Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3041949Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3043066Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3044219Z 2020-04-01 09:14:03,348 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3045394Z 2020-04-01 09:14:03,368 INFO
> org.apache.flink.api.java.ExecutionEnvironment [] - The job has
> 0 registered types and 0 default Kryo serializers
> 2020-04-01T09:15:52.3046417Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3049389Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3050540Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3051673Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3052795Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3053986Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3055413Z 2020-04-01 09:14:03,462 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3056750Z 2020-04-01 09:14:04,660 INFO
> org.apache.flink.kubernetes.KubernetesClusterDescriptor [] - Retrieve
> flink cluster flink-native-k8s-session-1 successfully, JobManager Web
> Interface: http://10.1.0.4:30095
> 2020-04-01T09:15:52.3057873Z 2020-04-01 09:15:31,546 WARN
> org.apache.flink.runtime.rest.RestClient [] - Rest
> endpoint shutdown failed.
> 2020-04-01T09:15:52.3058365Z java.util.concurrent.TimeoutException: null
> 2020-04-01T09:15:52.3058810Z at
> java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3059467Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3060544Z at
> org.apache.flink.runtime.rest.RestClient.shutdown(RestClient.java:164)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3061513Z at
> org.apache.flink.client.program.rest.RestClusterClient.close(RestClusterClient.java:230)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3062683Z at
> org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$1(AbstractSessionClusterExecutor.java:70)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3063436Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3064136Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3064698Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3065240Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3066208Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:287)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3066967Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3067535Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3068095Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3068638Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3069566Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3070612Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3071704Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3072819Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3074044Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3075163Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3076270Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3077570Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3078751Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3079959Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3081073Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3082179Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3083283Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3084307Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3085519Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3086646Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3187864Z at java.lang.Thread.run(Thread.java:748)
> [?:1.8.0_242]
> 2020-04-01T09:15:52.3189080Z 2020-04-01 09:15:31,555 ERROR
> org.apache.flink.client.cli.CliFrontend [] - Error while
> running the command.
> 2020-04-01T09:15:52.3189903Z
> org.apache.flink.client.program.ProgramInvocationException: The main method
> caused an error: java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3191267Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3192332Z at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3193324Z at
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:143)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3194243Z at
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:659)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3195410Z at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:210)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3198847Z at
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:890)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3200010Z at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:963)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3200697Z at
> java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3201100Z at
> javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_242]
> 2020-04-01T09:15:52.3201940Z at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
> [flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:2.8.3-10.0]
> 2020-04-01T09:15:52.3202983Z at
> org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3203930Z at
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:963)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3204809Z Caused by: java.lang.RuntimeException:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3205945Z at
> org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:276)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3206942Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:969)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3208379Z at
> org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:85)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3209348Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3209966Z at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:93)
> ~[?:?]
> 2020-04-01T09:15:52.3210430Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3210892Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3211450Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3211928Z at
> java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3212768Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3213234Z ... 11 more
> 2020-04-01T09:15:52.3213655Z Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3214257Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3214762Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3215792Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:964)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3216980Z at
> org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:85)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3218146Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3218898Z at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:93)
> ~[?:?]
> 2020-04-01T09:15:52.3219352Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3219842Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3220414Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3221028Z at
> java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3221872Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3222323Z ... 11 more
> 2020-04-01T09:15:52.3222672Z Caused by:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3223573Z at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:359)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3224254Z at
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3224957Z at
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3225655Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3226387Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3227451Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:287)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3228386Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3228959Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3229505Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3230062Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3230970Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3232014Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3233131Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3234243Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3235329Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3236416Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3237484Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3238684Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3239858Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3241058Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3242193Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3243300Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3244396Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3245562Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3246695Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3248100Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3248952Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3249625Z Caused by:
> org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not
> complete the operation. Number of retries has been exhausted.
> 2020-04-01T09:15:52.3250701Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:284)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3251409Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3251984Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3252687Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3253248Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3254138Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3255329Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3256458Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3257610Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3258847Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3265212Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3266873Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3268469Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3269732Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3271223Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3272704Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3274160Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3275736Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3277139Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3278277Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3279634Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3280542Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3281187Z Caused by:
> java.util.concurrent.CompletionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:52.3281922Z at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3282620Z at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3283173Z at
> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:957)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3283721Z at
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3284395Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3284966Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3285962Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3288624Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3289888Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3292603Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3294053Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3295689Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3297327Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3298930Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3300350Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3301801Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3303015Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3304138Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3305238Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3306280Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3307360Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3311829Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3312625Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3313166Z Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:52.3313713Z Caused by: java.net.ConnectException: Connection
> refused
> 2020-04-01T09:15:52.3314200Z at
> sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3314670Z at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:714)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3315824Z at
> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3317043Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3318317Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3319437Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3320530Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3321573Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3322667Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3323770Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3324462Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3324746Z Checking for exceptions...
> 2020-04-01T09:15:52.3325554Z Found exception in log files:
> 2020-04-01T09:15:52.3326685Z 2020-04-01 09:14:02,666 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> --------------------------------------------------------------------------------
> 2020-04-01T09:15:52.3328690Z 2020-04-01 09:14:02,681 INFO
> org.apache.flink.client.cli.CliFrontend [] - Starting
> Command Line Client (Version: 1.11-SNAPSHOT, Rev:f97b1b5, Date:01.04.2020 @
> 08:00:52 UTC)
> 2020-04-01T09:15:52.3330018Z 2020-04-01 09:14:02,681 INFO
> org.apache.flink.client.cli.CliFrontend [] - OS current
> user: vsts
> 2020-04-01T09:15:52.3331320Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - Current
> Hadoop/Kerberos user: vsts
> 2020-04-01T09:15:52.3332433Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - JVM:
> OpenJDK 64-Bit Server VM - Azul Systems, Inc. - 1.8/25.242-b20
> 2020-04-01T09:15:52.3333528Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - Maximum
> heap size: 1545 MiBytes
> 2020-04-01T09:15:52.3334583Z 2020-04-01 09:14:03,057 INFO
> org.apache.flink.client.cli.CliFrontend [] - JAVA_HOME:
> /usr/lib/jvm/zulu-8-azure-amd64
> 2020-04-01T09:15:52.3335779Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] - Hadoop
> version: 2.8.3
> 2020-04-01T09:15:52.3336775Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] - JVM
> Options:
> 2020-04-01T09:15:52.3338100Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog.file=/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/log/flink-vsts-client-fv-az510.log
> 2020-04-01T09:15:52.3339830Z 2020-04-01 09:14:03,058 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog4j.configuration=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/log4j-cli.properties
> 2020-04-01T09:15:52.3341541Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlog4j.configurationFile=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/log4j-cli.properties
> 2020-04-01T09:15:52.3343299Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dlogback.configurationFile=file:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/conf/logback.xml
> 2020-04-01T09:15:52.3344445Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - Program
> Arguments:
> 2020-04-01T09:15:52.3345528Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - run
> 2020-04-01T09:15:52.3346389Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - -e
> 2020-04-01T09:15:52.3347283Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> kubernetes-session
> 2020-04-01T09:15:52.3348540Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> -Dkubernetes.cluster-id=flink-native-k8s-session-1
> 2020-04-01T09:15:52.3349699Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/examples/batch/WordCount.jar
> 2020-04-01T09:15:52.3350737Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - --output
> 2020-04-01T09:15:52.3351626Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> /tmp/wc_out
> 2020-04-01T09:15:52.3361051Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] - Classpath:
> /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-shaded-zookeeper-3.4.10.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-table_2.11-1.11-SNAPSHOT.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-table-blink_2.11-1.11-SNAPSHOT.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-1.2-api-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-api-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-core-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/log4j-slf4j-impl-2.12.1.jar:/home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/lib/flink-dist_2.11-1.11-SNAPSHOT.jar:::
> 2020-04-01T09:15:52.3364232Z 2020-04-01 09:14:03,059 INFO
> org.apache.flink.client.cli.CliFrontend [] -
> --------------------------------------------------------------------------------
> 2020-04-01T09:15:52.3365566Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3366807Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3368271Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3369634Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3370825Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3372118Z 2020-04-01 09:14:03,063 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3373353Z 2020-04-01 09:14:03,064 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3374802Z 2020-04-01 09:14:03,177 WARN
> org.apache.flink.runtime.util.HadoopUtils [] - Could not
> find Hadoop configuration via any of the supported methods (Flink
> configuration, environment variables).
> 2020-04-01T09:15:52.3376309Z 2020-04-01 09:14:03,212 INFO
> org.apache.flink.runtime.security.modules.HadoopModule [] - Hadoop user
> set to vsts (auth:SIMPLE), credentials check status: true
> 2020-04-01T09:15:52.3377729Z 2020-04-01 09:14:03,220 INFO
> org.apache.flink.runtime.security.modules.JaasModule [] - Jaas file
> will be created as /tmp/jaas-7188653955626299344.conf.
> 2020-04-01T09:15:52.3378950Z 2020-04-01 09:14:03,234 INFO
> org.apache.flink.client.cli.CliFrontend [] - Running
> 'run' command.
> 2020-04-01T09:15:52.3379870Z 2020-04-01 09:14:03,237 INFO
> org.apache.flink.client.cli.CliFrontend [] - Building
> program from JAR file
> 2020-04-01T09:15:52.3380849Z 2020-04-01 09:14:03,261 INFO
> org.apache.flink.client.ClientUtils [] - Starting
> program (detached: false)
> 2020-04-01T09:15:52.3381930Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3383077Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3384370Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3385900Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3387186Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3388807Z 2020-04-01 09:14:03,347 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3390194Z 2020-04-01 09:14:03,348 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3391542Z 2020-04-01 09:14:03,368 INFO
> org.apache.flink.api.java.ExecutionEnvironment [] - The job has
> 0 registered types and 0 default Kryo serializers
> 2020-04-01T09:15:52.3392828Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.address, localhost
> 2020-04-01T09:15:52.3393971Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.rpc.port, 6123
> 2020-04-01T09:15:52.3395271Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.heap.size, 1024m
> 2020-04-01T09:15:52.3396555Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.memory.process.size, 1728m
> 2020-04-01T09:15:52.3398209Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: taskmanager.numberOfTaskSlots, 1
> 2020-04-01T09:15:52.3399361Z 2020-04-01 09:14:03,461 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: parallelism.default, 1
> 2020-04-01T09:15:52.3400532Z 2020-04-01 09:14:03,462 INFO
> org.apache.flink.configuration.GlobalConfiguration [] - Loading
> configuration property: jobmanager.execution.failover-strategy, region
> 2020-04-01T09:15:52.3401870Z 2020-04-01 09:14:04,660 INFO
> org.apache.flink.kubernetes.KubernetesClusterDescriptor [] - Retrieve
> flink cluster flink-native-k8s-session-1 successfully, JobManager Web
> Interface: http://10.1.0.4:30095
> 2020-04-01T09:15:52.3403009Z 2020-04-01 09:15:31,546 WARN
> org.apache.flink.runtime.rest.RestClient [] - Rest
> endpoint shutdown failed.
> 2020-04-01T09:15:52.3403583Z java.util.concurrent.TimeoutException: null
> 2020-04-01T09:15:52.3404081Z at
> java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1784)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3404660Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1928)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3405761Z at
> org.apache.flink.runtime.rest.RestClient.shutdown(RestClient.java:164)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3406940Z at
> org.apache.flink.client.program.rest.RestClusterClient.close(RestClusterClient.java:230)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3409294Z at
> org.apache.flink.client.deployment.executors.AbstractSessionClusterExecutor.lambda$execute$1(AbstractSessionClusterExecutor.java:70)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3410159Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3410814Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3411424Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3412195Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3413269Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:287)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3414024Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3414663Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3415283Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3415891Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3416902Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3418264Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3419529Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3420893Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3422099Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3423435Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3424622Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3425999Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3427512Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3429041Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3430416Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3431633Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3432844Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3433968Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3435325Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3438421Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3440525Z at java.lang.Thread.run(Thread.java:748)
> [?:1.8.0_242]
> 2020-04-01T09:15:52.3441936Z 2020-04-01 09:15:31,555 ERROR
> org.apache.flink.client.cli.CliFrontend [] - Error while
> running the command.
> 2020-04-01T09:15:52.3442974Z
> org.apache.flink.client.program.ProgramInvocationException: The main method
> caused an error: java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3444417Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:335)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3445820Z at
> org.apache.flink.client.program.PackagedProgram.invokeInteractiveModeForExecution(PackagedProgram.java:205)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3447222Z at
> org.apache.flink.client.ClientUtils.executeProgram(ClientUtils.java:143)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3448568Z at
> org.apache.flink.client.cli.CliFrontend.executeProgram(CliFrontend.java:659)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3449585Z at
> org.apache.flink.client.cli.CliFrontend.run(CliFrontend.java:210)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3450619Z at
> org.apache.flink.client.cli.CliFrontend.parseParameters(CliFrontend.java:890)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3451668Z at
> org.apache.flink.client.cli.CliFrontend.lambda$main$10(CliFrontend.java:963)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3452297Z at
> java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3452790Z at
> javax.security.auth.Subject.doAs(Subject.java:422) [?:1.8.0_242]
> 2020-04-01T09:15:52.3453709Z at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1836)
> [flink-shaded-hadoop-2-uber-2.8.3-10.0.jar:2.8.3-10.0]
> 2020-04-01T09:15:52.3455135Z at
> org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3456472Z at
> org.apache.flink.client.cli.CliFrontend.main(CliFrontend.java:963)
> [flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3457371Z Caused by: java.lang.RuntimeException:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3458731Z at
> org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:276)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3459788Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:969)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3460900Z at
> org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:85)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3462004Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3462709Z at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:93)
> ~[?:?]
> 2020-04-01T09:15:52.3463368Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3463940Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3464579Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3465327Z at
> java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3466338Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3466952Z ... 11 more
> 2020-04-01T09:15:52.3467434Z Caused by:
> java.util.concurrent.ExecutionException:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3468465Z at
> java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3469056Z at
> java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3470049Z at
> org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:964)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3471154Z at
> org.apache.flink.client.program.ContextEnvironment.executeAsync(ContextEnvironment.java:85)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3472261Z at
> org.apache.flink.client.program.ContextEnvironment.execute(ContextEnvironment.java:54)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3472979Z at
> org.apache.flink.examples.java.wordcount.WordCount.main(WordCount.java:93)
> ~[?:?]
> 2020-04-01T09:15:52.3473500Z at
> sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3474037Z at
> sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3474646Z at
> sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3475335Z at
> java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3476317Z at
> org.apache.flink.client.program.PackagedProgram.callMainMethod(PackagedProgram.java:321)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3477038Z ... 11 more
> 2020-04-01T09:15:52.3477420Z Caused by:
> org.apache.flink.runtime.client.JobSubmissionException: Failed to submit
> JobGraph.
> 2020-04-01T09:15:52.3478522Z at
> org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$7(RestClusterClient.java:359)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3482227Z at
> java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3482954Z at
> java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:866)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3483494Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3485230Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3486484Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:287)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3487452Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3488172Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3488823Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3489353Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3490255Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3491238Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3492283Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3493697Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3494905Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3496161Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3497231Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3498387Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3499488Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3500681Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3501760Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3502984Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3504078Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3505121Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3506222Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3507551Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3508111Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3509743Z Caused by:
> org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not
> complete the operation. Number of retries has been exhausted.
> 2020-04-01T09:15:52.3510944Z at
> org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$8(FutureUtils.java:284)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3511681Z at
> java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:774)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3512360Z at
> java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:750)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3512896Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3513423Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3514270Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3515389Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3516479Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3517595Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3518789Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3519950Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3520969Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3521976Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3523062Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3524214Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3525427Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3526519Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3527981Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3529281Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3530553Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3531723Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3532670Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3533291Z Caused by:
> java.util.concurrent.CompletionException:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:52.3534014Z at
> java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:292)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3534558Z at
> java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:308)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3535104Z at
> java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:957)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3535656Z at
> java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:940)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3536195Z at
> java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:488)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3536752Z at
> java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1990)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3537746Z at
> org.apache.flink.runtime.rest.RestClient.lambda$submitRequest$1(RestClient.java:342)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3538735Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListener0(DefaultPromise.java:500)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3539769Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners0(DefaultPromise.java:493)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3540803Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListenersNow(DefaultPromise.java:472)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3541944Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.notifyListeners(DefaultPromise.java:413)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3543105Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setValue0(DefaultPromise.java:538)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3544172Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.setFailure0(DefaultPromise.java:531)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3545249Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.DefaultPromise.tryFailure(DefaultPromise.java:111)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3546404Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.fulfillConnectPromise(AbstractNioChannel.java:323)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3547716Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:339)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3548788Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3549808Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3550843Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3551818Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3552932Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3553987Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3554697Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3555491Z Caused by:
> org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel$AnnotatedConnectException:
> Connection refused: /10.1.0.4:30095
> 2020-04-01T09:15:52.3556071Z Caused by: java.net.ConnectException: Connection
> refused
> 2020-04-01T09:15:52.3556462Z at
> sun.nio.ch.SocketChannelImpl.checkConnect(Native Method) ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3556945Z at
> sun.nio.ch.SocketChannelImpl.finishConnect(SocketChannelImpl.java:714)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3557986Z at
> org.apache.flink.shaded.netty4.io.netty.channel.socket.nio.NioSocketChannel.doFinishConnect(NioSocketChannel.java:327)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3559245Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.AbstractNioChannel$AbstractNioUnsafe.finishConnect(AbstractNioChannel.java:336)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3560565Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKey(NioEventLoop.java:685)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3561808Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized(NioEventLoop.java:632)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3562902Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.processSelectedKeys(NioEventLoop.java:549)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3563948Z at
> org.apache.flink.shaded.netty4.io.netty.channel.nio.NioEventLoop.run(NioEventLoop.java:511)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3565340Z at
> org.apache.flink.shaded.netty4.io.netty.util.concurrent.SingleThreadEventExecutor$5.run(SingleThreadEventExecutor.java:918)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3566520Z at
> org.apache.flink.shaded.netty4.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74)
> ~[flink-dist_2.11-1.11-SNAPSHOT.jar:1.11-SNAPSHOT]
> 2020-04-01T09:15:52.3567401Z at java.lang.Thread.run(Thread.java:748)
> ~[?:1.8.0_242]
> 2020-04-01T09:15:52.3567942Z Checking for non-empty .out files...
> 2020-04-01T09:15:52.3568852Z grep:
> /home/vsts/work/1/s/flink-dist/target/flink-1.11-SNAPSHOT-bin/flink-1.11-SNAPSHOT/log/*.out:
> No such file or directory
> 2020-04-01T09:15:52.3570198Z No non-empty .out files.
> 2020-04-01T09:15:52.3570364Z
> 2020-04-01T09:15:52.3571052Z [FAIL] 'Run kubernetes session test' failed
> after 3 minutes and 15 seconds! Test exited with exit code 1 and the logs
> contained errors, exceptions or non-empty .out files
> {code}
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
