嗨，我正在使用 Flink 版本：1.6.0。 我需要为 java 设置自定义信任库，所以我添加到flink-conf.yaml属性
env.java.opts: "-Djavax.net.ssl.trustStore=/etc/pki/tls/certs/xxx -Djavax.net.ssl.trustStorePassword=zzz"
但是在我的类中比在代码中，它是flatMap方法运行中RichFlatMapFunction的孩子
LOG.info("> javax.net.ssl.trustStore ${System.getProperty("javax.net.ssl.trustStore")}")
我得到了空。因此未设置此属性。
你能给我一些提示为什么它不起作用吗？
谢谢
问题在于服务的启动顺序。我需要首先在 flink a 的所有 3 个实例上启动任务管理器服务，然后才能提交作业。 希望这对某人有所帮助：-(