[ https://issues.apache.org/jira/browse/FLINK-5058?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
ASF GitHub Bot updated FLINK-5058: ---------------------------------- Labels: pull-request-available (was: ) > 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: iteblog > Priority: Major > Labels: pull-request-available > Fix For: 1.1.4, 1.2.0 > > Original Estimate: 8h > Remaining Estimate: 8h > > In FlinkShell.scala, someone mistakenly set {{slots}} value to > {{taskManagerMemory}} 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 {{slots}} value to {{-ytm}} > attribute, the right code should be: > {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 (v8.20.1#820001)