yarn模式，1.5分支 about chunjun

[yangsishu]

你把你flink启动的方式发下

[TdzWork]

我在standalone模式下也遇到这个问题了
Exception in thread "main" org.apache.flink.client.program.ProgramInvocationException: Could not submit job 44c89c27eed1b64d974e164efc2c9454.
at org.apache.flink.client.program.rest.RestClusterClient.submitJob(RestClusterClient.java:247)
at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:464)
at org.apache.flink.client.program.DetachedEnvironment.finalizeExecute(DetachedEnvironment.java:77)
at org.apache.flink.client.program.ClusterClient.run(ClusterClient.java:410)
at com.dtstack.flinkx.launcher.Launcher.main(Launcher.java:100)
Caused by: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph.
at org.apache.flink.client.program.rest.RestClusterClient.lambda$submitJob$8(RestClusterClient.java:370)
at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:870)
at java.util.concurrent.CompletableFuture$UniExceptionally.tryFire(CompletableFuture.java:852)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.completeExceptionally(CompletableFuture.java:1977)
at org.apache.flink.runtime.concurrent.FutureUtils.lambda$retryOperationWithDelay$5(FutureUtils.java:213)
at java.util.concurrent.CompletableFuture.uniWhenComplete(CompletableFuture.java:760)
at java.util.concurrent.CompletableFuture$UniWhenComplete.tryFire(CompletableFuture.java:736)
at java.util.concurrent.CompletableFuture.postComplete(CompletableFuture.java:474)
at java.util.concurrent.CompletableFuture.postFire(CompletableFuture.java:561)
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:929)
at java.util.concurrent.CompletableFuture$Completion.run(CompletableFuture.java:442)
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
at java.lang.Thread.run(Thread.java:748)
Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Exception is not retryable.
at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
at java.util.concurrent.CompletableFuture$UniRelay.tryFire(CompletableFuture.java:899)
... 12 more
Caused by: org.apache.flink.runtime.concurrent.FutureUtils$RetryException: Could not complete the operation. Exception is not retryable.
... 10 more
Caused by: java.util.concurrent.CompletionException: org.apache.flink.runtime.rest.util.RestClientException: [Job submission failed.]
at java.util.concurrent.CompletableFuture.encodeRelay(CompletableFuture.java:326)
at java.util.concurrent.CompletableFuture.completeRelay(CompletableFuture.java:338)
at java.util.concurrent.CompletableFuture.uniRelay(CompletableFuture.java:911)
at java.util.concurrent.CompletableFuture.uniCompose(CompletableFuture.java:953)
at java.util.concurrent.CompletableFuture$UniCompose.tryFire(CompletableFuture.java:926)
... 4 more

[Horrypotter]

楼上的兄弟，解决了吗

[zhouyunlong]

楼上的兄弟，解决了吗

能解决的

[simenliuxing]

请问解决了吗？我在代码里加上env.setStateBackend(rockdb或者fs),就不报上名的错，如果不加就没问题，不知道哪里的原因。

[zhouyunlong]

解决了

…

------------------ 原始邮件 ------------------ 发件人: "simenliuxing"<[email protected]>; 发送时间: 2019年6月25日(星期二) 下午3:19 收件人: "DTStack/flinkx"<[email protected]>; 抄送: "651334919"<[email protected]>;"Author"<[email protected]>; 主题: Re: [DTStack/flinkx] yarn模式，1.5分支 (#17) 请问解决了吗？我在代码里加上env.setStateBackend(rockdb或者fs),就不报上名的错，如果不加就没问题，不知道哪里的原因。 — You are receiving this because you authored the thread. Reply to this email directly, view it on GitHub, or mute the thread.

[simenliuxing]

能告诉怎么解决的吗？非常感谢

[zhouyunlong]

拉的是Master（V1.4.5版本）代码，flink集群版本是1.4，standlone 的HA方式部署的，提交方式时候standlone 。