flink怎么在参数传入 classloader.resolve-order: parent-first 或在代码设置,用于覆盖flink默认的配置。-Dclassloader.resolve-orde=parent-first \ 这种不生效,咋办啊?我修改conf/flink-conf.yaml 是可以生效,我怕以后有的用child-first 才有用咋办?
楼主你好,如果在代码中设置 classloader.resolve-order
,可以在 StreamExecutionEnvironment
中使用方法 addGlobalJobParameters
实现:
StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();
Configuration config = new Configuration();
config.setString("classloader.resolve-order", "parent-first");
env.getConfig().setGlobalJobParameters(config);
这样可以覆盖 Flink 默认的配置。但是如果使用 -Dclassloader.resolve-order=parent-first
的方式传入参数不生效的情况下,可以尝试在启动 Flink 的脚本中加入以下设置:
export JVM_ARGS="$JVM_ARGS -Dclassloader.resolve-order=parent-first"
这样可以在启动 Flink 的时候将参数传递给 JVM。如果需要切换至 child-first
,只需要将 parent-first
修改为 child-first
即可。
版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。
实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。