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.


---

Reply via email to