You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Dmitriy Linevich (Jira)" <ji...@apache.org> on 2025/02/04 07:30:00 UTC

[jira] [Updated] (FLINK-37250) The flink application does not start because of an error in the configs

     [ https://issues.apache.org/jira/browse/FLINK-37250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Dmitriy Linevich updated FLINK-37250:
-------------------------------------
    Environment:     (was: ./flink run-application \
    --parallelism 4 \
    --target kubernetes-application \

...
    -Dstate.backend=rocksdb \
    -Dstate.backend.rocksdb.use-bloom-filter=true \)

> The flink application does not start because of an error in the configs
> -----------------------------------------------------------------------
>
>                 Key: FLINK-37250
>                 URL: https://issues.apache.org/jira/browse/FLINK-37250
>             Project: Flink
>          Issue Type: Bug
>          Components: Command Line Client
>    Affects Versions: 1.19.0
>            Reporter: Dmitriy Linevich
>            Priority: Minor
>
> If run flink kubernetes application with dynamic properties (including deprecated keys), it fails because of
> {code:java}
> java.lang.ClassCastException: class java.lang.String cannot be cast to class java.util.Map (java.lang.String and java.util.Map are in module java.base of loader 'bootstrap'){code}
> An error occurs because the value of an option key matches the connection of another option key
> Test Example inYamlParserUtilsTest:
> {code:java}
> @Test
> void testDumpNestedYamlFromFlatMapEqualSubkeyAndValue() {
>     Map<String, Object> flattenMap = new HashMap<>();
>     flattenMap.put("nested.key1.subKey1", "value1");
>     flattenMap.put("nested.key2.subKey1", "value2");
>     flattenMap.put("nested.key2", "subKey1");
>     flattenMap.put("nested.key3", "value3");
>     List<String> values = YamlParserUtils.convertAndDumpYamlFromFlatMap(flattenMap);
> } {code}
> In [ConfigurationUtils#convertConfigToWritableLines|https://github.com/apache/flink/blob/ea72d7f5ddf832329959ff78b5658748e2d689b0/flink-core/src/main/java/org/apache/flink/configuration/ConfigurationUtils.java#L247] exists flag _flattenYaml,_ I think we need to use it by cli option in client



--
This message was sent by Atlassian Jira
(v8.20.10#820010)