What happened?
Hi, team!
When there is a configuration item xxx.metrics.filter.includes: *RSS:*:*;Heap:Used,Max:* in the Flink-ConF.YAML file, starting the Flink optimizer will result in an error:
Failed to handle request org.yaml.snakeyaml.composer.ComposerException: found undered alias RSS.
The code location is
|
configDocument = new Yaml().load(Files.newInputStream(flinkConfPath)); |
I don't think this is a standard YAML file. Should we refer to the Flink implementation for parsing?
https://github.com/apache/flink/blob/448d5ccf432fa4af043c3fc5bd977eea1fbc74a1/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java#L179
At present, this configuration can be added to the optimizer group and enclosed in single quotes to avoid this issue.
Affects Versions
master
What table formats are you seeing the problem on?
Iceberg
What engines are you seeing the problem on?
Flink, Optimizer
How to reproduce
No response
Relevant log output
Anything else
No response
Are you willing to submit a PR?
Code of Conduct
What happened?
Hi, team!
When there is a configuration item
xxx.metrics.filter.includes: *RSS:*:*;Heap:Used,Max:*in the Flink-ConF.YAML file, starting the Flink optimizer will result in an error:Failed to handle request org.yaml.snakeyaml.composer.ComposerException: found undered alias RSS.The code location is
amoro/amoro-ams/src/main/java/org/apache/amoro/server/manager/FlinkOptimizerContainer.java
Line 282 in cf8ff05
I don't think this is a standard YAML file. Should we refer to the Flink implementation for parsing?
https://github.com/apache/flink/blob/448d5ccf432fa4af043c3fc5bd977eea1fbc74a1/flink-core/src/main/java/org/apache/flink/configuration/GlobalConfiguration.java#L179
At present, this configuration can be added to the optimizer group and enclosed in single quotes to avoid this issue.
Affects Versions
master
What table formats are you seeing the problem on?
Iceberg
What engines are you seeing the problem on?
Flink, Optimizer
How to reproduce
No response
Relevant log output
Anything else
No response
Are you willing to submit a PR?
Code of Conduct