Локальный конфиг Flink работает автономно от IDE
Если я хочу запустить приложение Flink локально, напрямую из Intellij, но мне нужно указать параметры конфигурации (например, fs.hdfs.hdfssite для настройки доступа S3), есть ли другой способ предоставить эти параметры конфигурации помимоExecutionEnvironment.createLocalEnvironment(conf)
? Что делать, если я хочу использоватьStreamExecutionEnvironment.getExecutionEnvironment
? Могу ли я иметь конфигурацию Flink в моем проекте и указать на нее локальное приложение?
Это правильный способ сделать это? Или вы бы настроили свою IDE для отправки приложения в настоящий локальный экземпляр Flink?