[Bug] Error while trying to split key and value in configuration

[andystenhe]

Search before asking

• I had searched in the issues and found no similar issues.

Java Version

11

Scala Version

2.12.x

StreamPark Version

2.1.5

Flink Version

1.19

Deploy mode

kubernetes-session

What happened

Flink config.yaml Parsing Error​
When using Flink versions greater than 1.19, the config.yaml file adopts a nested format as shown below:

# Example YAML
flink:
  checkpoint:
    interval: 60000
    mode: EXACTLY_ONCE
  parallelism: 4
  state:
    backend: rocksdb
    savepoints.dir: hdfs:///savepoints

StreamPark encountered errors while parsing the config.yaml file. The error logs are as follows:

16:41:15.967 [streampark-k8s-watching-thread-18] WARN org.apache.streampark.common.util.PropertiesUtils - [StreamPark] Error while trying to split key and value in configuration. 39 : rpc:
16:41:15.967 [streampark-k8s-watching-thread-18] WARN org.apache.streampark.common.util.PropertiesUtils - [StreamPark] Error while trying to split key and value in configuration. 51 : memory:
16:41:15.968 [streampark-k8s-watching-thread-18] WARN org.apache.streampark.common.util.PropertiesUtils - [StreamPark] Error while trying to split key and value in configuration. 52 : process:
16:41:15.968 [streampark-k8s-watching-thread-18] WARN org.apache.streampark.common.util.PropertiesUtils - [StreamPark] Error while trying to split key and value in configuration. 56 : execution:
16:41:15.968 [streampark-k8s-watching-thread-18] WARN org.apache.streampark.common.util.PropertiesUtils - [StreamPark] Error while trying to split key and value in configuration. 62 : taskmanager:

Error Exception

Screenshots

Are you willing to submit PR?

• Yes I am willing to submit a PR!(您是否要贡献这个PR?)

Code of Conduct

• I agree to follow this project's Code of Conduct