[kylin] branch engine-flink updated: KYLIN-3876 Fix flink config option wrong key mapping

[shaofengshi]

This is an automated email from the ASF dual-hosted git repository.

shaofengshi pushed a commit to branch engine-flink
in repository https://gitbox.apache.org/repos/asf/kylin.git


The following commit(s) were added to refs/heads/engine-flink by this push:
     new 9faa880  KYLIN-3876 Fix flink config option wrong key mapping
9faa880 is described below

commit 9faa880dddb33bdeed938f30d8d7630ab5de0dd1
Author: yanghua <yanghua1...@gmail.com>
AuthorDate: Fri Mar 15 20:24:08 2019 +0800

    KYLIN-3876 Fix flink config option wrong key mapping
---
 .../java/org/apache/kylin/engine/flink/FlinkOnYarnConfigMapping.java    | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkOnYarnConfigMapping.java
 
b/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkOnYarnConfigMapping.java
index 105e9ec..721b9a9 100644
--- 
a/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkOnYarnConfigMapping.java
+++ 
b/engine-flink/src/main/java/org/apache/kylin/engine/flink/FlinkOnYarnConfigMapping.java
@@ -47,7 +47,7 @@ public class FlinkOnYarnConfigMapping {
         }
 
         //mapping task manager heap size -> -ytm
-        ConfigOption<String> tmHeapSizeOption = 
TaskManagerOptions.MANAGED_MEMORY_SIZE;
+        ConfigOption<String> tmHeapSizeOption = 
TaskManagerOptions.TASK_MANAGER_HEAP_MEMORY;
         flinkOnYarnConfigMap.put(tmHeapSizeOption.key(), "-ytm");
         if (tmHeapSizeOption.hasDeprecatedKeys()) {
             Iterator<String> deprecatedKeyIterator = 
tmHeapSizeOption.deprecatedKeys().iterator();