flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fhue...@apache.org
Subject [2/2] flink git commit: [FLINK-5058] [scala-shell] Set correct value for TaskManager memory parameter.
Date Thu, 17 Nov 2016 22:48:27 GMT
[FLINK-5058] [scala-shell] Set correct value for TaskManager memory parameter.

This closes #2799.


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/68585d14
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/68585d14
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/68585d14

Branch: refs/heads/release-1.1
Commit: 68585d145178beb103ae95f0a80580e8786ee176
Parents: 3d31311
Author: iteblog <wyphao.2007@163.com>
Authored: Mon Nov 14 19:04:28 2016 +0800
Committer: Fabian Hueske <fhueske@apache.org>
Committed: Thu Nov 17 23:47:19 2016 +0100

----------------------------------------------------------------------
 .../src/main/scala/org/apache/flink/api/scala/FlinkShell.scala     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/68585d14/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
----------------------------------------------------------------------
diff --git a/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
b/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
index b2ec626..f00013e 100644
--- a/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
+++ b/flink-scala-shell/src/main/scala/org/apache/flink/api/scala/FlinkShell.scala
@@ -242,7 +242,7 @@ object FlinkShell {
 
     // set configuration from user input
     yarnConfig.jobManagerMemory.foreach((jmMem) => args ++= Seq("-yjm", jmMem.toString))
-    yarnConfig.slots.foreach((tmMem) => args ++= Seq("-ytm", tmMem.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))


Mime
View raw message