提交 b674fd57 编写于 作者: M Maximilian Michels

[FLINK-3937] allow -yid without -m yarn-cluster

上级 cfd48a6f
......@@ -456,7 +456,8 @@ public class FlinkYarnSessionCli implements CustomCommandLine<YarnClusterClient>
public boolean isActive(CommandLine commandLine, Configuration configuration) {
String jobManagerOption = commandLine.getOptionValue(ADDRESS_OPTION.getOpt(), null);
boolean yarnJobManager = ID.equals(jobManagerOption);
return yarnJobManager || resumeFromYarnProperties(commandLine, configuration);
boolean yarnAppId = commandLine.hasOption(APPLICATION_ID.getOpt());
return yarnJobManager || yarnAppId || resumeFromYarnProperties(commandLine, configuration);
}
@Override
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册