[
https://issues.apache.org/jira/browse/FLINK-20645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17250994#comment-17250994
]
Li Wang commented on FLINK-20645:
---------------------------------
Thanks for your confirmation. I tried on my local as yours and can see it works.
I reran a test application in my own dev env and able to get JM & TM logs. I've
attached here for your reference. It's really weird why I got this error. FYI,
I'm running flink job cluster in kubernetes, so the log is from JM pod and TM
pod. Let me know if you need anything else from me.
[^jm.log][^tm.log]
> 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: 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)
