Я хочу, чтобы потоковое задание Flink работало в течение длительного времени.Логика вычислений сложна и динамична.Я могу использовать другой поток конфигурации и состояние широковещания для динамического обновления логики.Однако иногда необходимая логика может быть чрезвычайно сложной, что означает, что сложно создать шаблон конфигурации.
Поэтому я рассматриваю возможность использования скриптов (groovy, python, ruby и т. Д.) Для реализации логики обработки и отправки ее в поток конфигурации.Flink затем вызывает parser для выполнения такой логики для вычисления результата.
Работает ли мой план в этом случае?Есть идеи об альтернативных подходах?Большое спасибо!