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)
