[
https://issues.apache.org/jira/browse/FLINK-20645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17251491#comment-17251491
]
Li Wang commented on FLINK-20645:
---------------------------------
Thanks [~karmagyz] for the reference, we will look into converting to this more
k8s native way to deploy our job cluster.
Also thank you [~fly_in_gis] for pointing out the root cause. I tried another
flink app without any arguments, TM is able to be started without any issue.
This proves those unrecognized arguments is the killer. Just curious how to
pass in jar arguments in Flink 1.11 since the same scripts we're using works
for Flink 1.6 and 1.7. Or maybe I have to make them as system properties and
pass in using "-D"?
> Extra space typo when assembling dynamic configs
> ------------------------------------------------
>
> Key: FLINK-20645
> URL: https://issues.apache.org/jira/browse/FLINK-20645
> Project: Flink
> Issue Type: Bug
> Reporter: Li Wang
> Priority: Major
> Labels: pull-request-available
> Attachments: jm.log, tm.log
>
>
> while starting task manager, I got the error below
> {code:java}
> "Caused by: org.apache.flink.configuration.IllegalConfigurationException: The
> required configuration option Key: 'taskmanager.cpu.cores' , default: null
> (fallback keys: []) is not set
> {code}
>
> Checking TM starting command I got something like
> {code:java}
> -D taskmanager.memory.framework.off-heap.size=134217728b -D
> taskmanager.memory.network.max=67108864b -D
> taskmanager.memory.network.min=67108864b -D
> taskmanager.memory.framework.heap.size=134217728b -D
> taskmanager.memory.managed.size=57346620b -D taskmanager.cpu.cores=1.0 -D
> taskmanager.memory.task.heap.size=1518663108b -D
> taskmanager.memory.task.off-heap.size=0b
> {code}
> Looks like the extra spaces between "-D" and parameters causes those dynamic
> options can't be passed in correctly.
> Related code is
> [here|https://github.com/apache/flink/blob/2ad92169a4a4ffc92d32783f8777a132e1dac7c4/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java#L180]
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
