search

DTStack / flinkStreamSQL

基于开源的flink，对其实时sql进行扩展；主要实现了流与维表的join，支持原生flink SQL所有的语法
Apache License 2.0
2.02k stars 926 forks source link

Standalone模式提交怎么会调用异常？ #402

Open jiaenqiu opened 3 years ago

jiaenqiu commented 3 years ago

Exception in thread "main" org.apache.flink.client.program.ProgramInvocationException: Could not run job in detached mode. (JobID: bda69dcfcf4c7257870f762a0230c40d) at org.apache.flink.client.ClientUtils.submitJob(ClientUtils.java:88) at com.dtstack.flink.sql.launcher.executor.StandaloneExecutor.exec(StandaloneExecutor.java:67) at com.dtstack.flink.sql.launcher.LauncherMain.main(LauncherMain.java:149) Caused by: java.util.concurrent.ExecutionException: org.apache.flink.runtime.client.JobSubmissionException: Failed to submit JobGraph. at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1908) at org.apache.flink.client.ClientUtils.submitJob(ClientUtils.java:85)

Feral-Jas commented 3 years ago

是不是没写classpath，只有yarn集群支持ship file，之前也遇到过这个问题

FlechazoW commented 3 years ago

需要有完整的报错信息，这部分信息看不出具体问题的。