У меня есть сценарий поддержки конфигурации во Flink, который я не знаю, как с этим справиться....

в клиенте kafka или Spark они могут использовать ConsumerRecord для получения имени темы или...

Я пытаюсь проверить / сохранить точку моего состояния флинка, работающего на EMR, в корзину s3 на...

Требования довольно просты. У меня есть поступающие данные, которые состоят из следующего: long id;...

У меня есть приложение Flink, которое читает некоторые события из Kafka, выполняет некоторое...

Я пытаюсь понять, как интерпретировать показатели контрольных точек, отображаемые моим приложением...

Интересно, есть ли способ во флинке транслировать событие (или что-то в этом роде), если...

Я использую «keyby» в моем потоке данных. Я хочу, чтобы Flink обнаружил все разделы Кафки по ключам

Я разверну свой менеджер заданий и диспетчеров задач в openshift. это работает также. но в...

Я пытаюсь понять, как работает параллелизм во Flink. Этот документ https://ci.apache