在互联网上,我总是看到概念分支,但当我查看JobManager的源代码时(最新的代码来自master分支) Interface: JobManagerRunner JobMaster implementation.The job master is responsible for the execution of a single 我想问代码中的
Scala二进制版本: 2.12,
错误出现在这里;
Caused by: org.apache.flink.runtime.client.JobExecutionException: Could not set up JobManagerat org.apache.flink.runtime.jobmaster.JobManagerRunnerImpl.(JobMaster.java:278