标签：flink java Flink util 源码 apache org runtime 进斗经

2022-01-04 配置加载

org.apache.flink.kubernetes.entrypoint.KubernetesSessionClusterEntrypoint#main  //K8sSession模式启动入口
org.apache.flink.runtime.util.EnvironmentInformation#logEnvironmentInfo  //加载环境信息
org/apache/flink/runtime/util/EnvironmentInformation.java: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标准解析

标签：flink,java,Flink,util,源码,apache,org,runtime,进斗经
来源： https://www.cnblogs.com/tyxuanCX/p/15761498.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。