flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "yangping wu (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-5058) taskManagerMemory attribute set wrong value in FlinkShell
Date Mon, 14 Nov 2016 10:04:59 GMT
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)

Mime
View raw message