Dmitriy Linevich created FLINK-37250:
----------------------------------------
Summary: 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
Environment: ./flink run-application \
--parallelism 4 \
--target kubernetes-application \
...
-Dstate.backend=rocksdb \
-Dstate.backend.rocksdb.use-bloom-filter=true \
Reporter: Dmitriy Linevich
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)
