[jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell

["yangping wu (JIRA)" <ji...@apache.org>]

yangping wu created FLINK-5058:
----------------------------------

             Summary: taskManagerMemory attribute set wrong value in FlinkShell
                 Key: FLINK-5058
                 URL: https://issues.apache.org/jira/browse/FLINK-5058
             Project: Flink
          Issue Type: Bug
          Components: Scala Shell
    Affects Versions: 1.1.3
            Reporter: yangping wu


In FlinkShell.scala, someone mistakenly set  {{taskManagerMemory}} value to {{slots}} attribute as follow:
{code}
// set configuration from user input
yarnConfig.jobManagerMemory.foreach((jmMem) => args ++= Seq("-yjm", jmMem.toString))
yarnConfig.slots.foreach((tmMem) => args ++= Seq("-ytm", tmMem.toString))
yarnConfig.name.foreach((name) => args ++= Seq("-ynm", name.toString))
yarnConfig.queue.foreach((queue) => args ++= Seq("-yqu", queue.toString))
yarnConfig.slots.foreach((slots) => args ++= Seq("-ys", slots.toString))
{code}
Note on the third line: {{yarnConfig.slots.foreach((tmMem) => args ++= Seq("-ytm", tmMem.toString))}} , we set {{taskManagerMemory}} value to {{slots}} attribute, the right code is as follow:
{code}
// set configuration from user input
yarnConfig.jobManagerMemory.foreach((jmMem) => args ++= Seq("-yjm", jmMem.toString))
yarnConfig.taskManagerMemory.foreach((tmMem) => args ++= Seq("-ytm", tmMem.toString))
yarnConfig.name.foreach((name) => args ++= Seq("-ynm", name.toString))
yarnConfig.queue.foreach((queue) => args ++= Seq("-yqu", queue.toString))
yarnConfig.slots.foreach((slots) => args ++= Seq("-ys", slots.toString))
{code}
 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)