Github user GJL commented on a diff in the pull request:
https://github.com/apache/flink/pull/5227#discussion_r160112134
--- Diff:
flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala ---
@@ -253,16 +253,22 @@ object FlinkShell {
yarnConfig.queue.foreach((queue) => args ++= Seq("-yqu",
queue.toString))
yarnConfig.slots.foreach((slots) => args ++= Seq("-ys",
slots.toString))
- val options = CliFrontendParser.parseRunCommand(args.toArray)
+ val commandLine = CliFrontendParser.parse(
+ CliFrontendParser.getRunCommandOptions,
+ args.toArray,
+ true)
+
+ val options = new RunOptions(commandLine)
--- End diff --
Unused variable.
---
