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)