2022-01-04 配置加载
org.apache.flink.kubernetes.entrypoint.KubernetesSessionClusterEntrypoint#main //K8sSession模式启动入口
org.apache.flink.runtime.util.Environment@R_470_4045@ion#logEnvironmentInfo //加载环境信息
org/apache/flink/runtime/util/Environment@R_470_404[email protected]:404 //获取继承的环境配置 FLINK_INHERITED_LOGS
flink-dist/src/main/flink-bin/bin/config.sh:544 //配置环境变量 FLINK_INHERITED_LOGS
flink-dist/src/main/flink-bin/bin/config.sh:529 //配置 java_utils_output
flink-dist/src/main/flink-bin/bin/config.sh:478 //runBashJavaUtilsCmd 执行javaBean解析命令参数
flink-dist/src/main/flink-bin/bin/config.sh:485
org.apache.flink.runtime.util.bash.BashJavaUtils#main
org/apache/flink/runtime/util/bash/BashJavaUtils.java:56 // runcommand
org/apache/flink/runtime/util/bash/BashJavaUtils.java:64 // loadConfiguration
org.apache.flink.runtime.util.bash.FlinkConfigLoader#filterCmdArgs
org/apache/flink/runtime/util/bash/FlinkConfigLoader.java:42 // loadCommonConfiguration
org/apache/flink/runtime/util/ConfigurationParserUtils.java:135 // commandLineParser.parse(args)
org/apache/flink/runtime/entrypoint/parser/CommandLineParser.java:46 // commocommons-cli包解析命令行, 涉及CommandLine, Options, CommandLineParser
org/apache/flink/runtime/util/ConfigurationParserUtils.java:144 // loadConfiguration
org/apache/flink/configuration/GlobalConfiguration.java:135 // loadYAMLResource(yamlConfigFile)
org.apache.flink.configuration.GlobalConfiguration#loadYAMLResource // 仅使用yaml的k:v简化解析, 以后根据需要再引入yaml标准解析
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 [email protected] 举报,一经查实,本站将立刻删除。