Appache Flink - настраиваемое хранилище доверенных сертификатов - PullRequest
Новая
       11

Appache Flink - настраиваемое хранилище доверенных сертификатов

0 голосов
/ 17 июня 2020

Привет, я использую версию 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"

Но, чем в коде моего класса, который является дочерним для RichFlatMapFunction в flatMap запуск метода 

LOG.info("> javax.net.ssl.trustStore ${System.getProperty("javax.net.ssl.trustStore")}")

Я получил null. Итак, это свойство не установлено.

Подскажите, пожалуйста, почему оно не работает?

Спасибо

1 Ответ

0 голосов
/ 17 июня 2020

проблема в порядке запуска сервисов. Мне нужно сначала запустить службу диспетчера задач на всех трех экземплярах flink a, чем я могу отправить задание. Надеюсь, это кому-то поможет: -)

...