Github user yanghua commented on a diff in the pull request: https://github.com/apache/flink/pull/6297#discussion_r202381490 --- Diff: flink-yarn/src/main/java/org/apache/flink/yarn/cli/FlinkYarnSessionCli.java --- @@ -500,11 +501,11 @@ protected Configuration applyCommandLineOptionsToConfiguration(CommandLine comma } if (commandLine.hasOption(jmMemory.getOpt())) { - effectiveConfiguration.setString(JobManagerOptions.JOB_MANAGER_HEAP_MEMORY, commandLine.getOptionValue(jmMemory.getOpt())); + effectiveConfiguration.setString(JobManagerOptions.JOB_MANAGER_HEAP_MEMORY, commandLine.getOptionValue(jmMemory.getOpt()) + "m"); --- End diff -- you are right, I have update the PR, please review, thanks.
---