[KYLIN-3876] Fix flink config option wrong key mapping

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: v3.1.0
• Component/s: Flink Engine
• Assignee: vinoyang
• Reporter: vinoyang
• Created: 15/Mar/19 12:21
• Updated: 31/Jul/20 12:04
• Resolved: 23/Dec/19 03:41

Description

There is a wrong key mapping, it would cause critical exception : 

java.lang.IllegalArgumentException: Unsupported Flink configuration pair : key[taskmanager.heap.size], value[1G] at org.apache.kylin.engine.flink.FlinkExecutable.doWork(FlinkExecutable.java:193) at org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:165) at org.apache.kylin.job.execution.DefaultChainedExecutable.doWork(DefaultChainedExecutable.java:70) at org.apache.kylin.job.execution.AbstractExecutable.execute(AbstractExecutable.java:165) at org.apache.kylin.job.impl.threadpool.DefaultScheduler$JobRunner.run(DefaultScheduler.java:114) at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1142) at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:617) at java.lang.Thread.run(Thread.java:745)

Issue Links

• links to: GitHub Pull Request #521