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

Dmitriy Linevich updated FLINK-37250:
-------------------------------------
    Affects Version/s:     (was: 1.19.1)
                           (was: 1.20.1)

> 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, 1.20.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.
>  
> Example for application run:
> {code:java}
> ./flink run-application \
>     --parallelism 4 \
>     --target kubernetes-application \
> ...
>     -Dstate.backend=rocksdb \
>     -Dstate.backend.rocksdb.use-bloom-filter=true \ {code}
>  
> Test Example in YamlParserUtilsTest:
> {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)

Reply via email to