flink命令行参数不生效问题

Mon, 11 Apr 2022 04:55:53 -0700 

我用命令提交作业：flink run -t yarn-per-job -ynm SocketWordCount -yqu root.root  -d 
-n SocketWindowWordCount.jar --hostname 10.199.0.97 --port 9878。结果作业提交成功之后发现 
-ynm和-yqu不生效。后来通过查看源码发现是因为如果指定了 
-t，那么-y开头的所有参数都不生效了，因为-y系列参数是在FlinkYarnSessionCli中解析的，而源码中：public 
CustomCommandLine validateAndGetActiveCommandLine(CommandLine commandLine) {
    LOG.debug("Custom commandlines: {}", customCommandLines);
    for (CustomCommandLine cli : customCommandLines) {
        LOG.debug(
                "Checking custom 
commandline {}, isActive: {}", cli, cli.isActive(commandLine));
        if (cli.isActive(commandLine)) {
            return cli;
        }
    }
    throw new IllegalStateException("No valid command-line found.");
}
这段代码返回的是GenericCLI。导致后面的：
final Configuration effectiveConfiguration =
        getEffectiveConfiguration(activeCommandLine, 
commandLine, programOptions, jobJars);
这行代码返回的命令行参数配置只包含了GenericCli中定义的参数。想请教一下，-t和-m设置参数时有啥区别？如何解决上述参数不生效的问题？这是一个bug么？

回复