[
https://issues.apache.org/jira/browse/FLINK-37250?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dmitriy Linevich updated FLINK-37250:
-------------------------------------
Description:
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
was:
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
> 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.
>
> 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)
