Apache Flink: использовать YAML-файл в качестве файла свойств

Я использую Apache Flink 1.7.1.

У меня есть некоторые свойства в файле YAML, такие как:

cassandra:
  host:
   - "host1"
   - "host2"
  port: PORT_NUMBER
  username: "[USER_NAME]"
  password: "[PASSWORD]"

В соответствии с рекомендациями по адресу: https://ci.apache.org/projects/flink/flink-docs-release-1.7/dev/best_practices.html было рекомендовано использовать "ParameterTool" для совместного использования параметров во всех задачах. менеджеры (рабочие). К сожалению, файл YAML был проанализирован как файл.prroperties.

Есть ли способ использовать файл YAML и разобрать, чтобы получить объект карты?

0 ответов

Другие вопросы по тегам