apache-flink

0зной

1ответ

Как получить/прочитать данные кафки из флинка?

Я пытаюсь читать данные кафки из флинка, и поскольку я новичок в kafka и flink, я не знаю, как их соединить.

2зной

2ответ

Как использовать потоковое время FlinkWindow с метками метки и водяного знака?

Я работаю над потоковым процессором Flink, который читает события от Kafka. Эти события подкрепляются одним из полей и должны быть окончены в течение определенного периода времени, прежде чем быть уме

0зной

1ответ

Fink: Потеря данных KafkaProducer

Наш потоковый поток Flink публикует сообщения в Kafka. Механизм «повторения» KafkaProducer не срабатывает до тех пор, пока в его внутренний буфер не добавится сообщение. Если перед этим существует иск

2зной

2ответ

Флинк не совершает смещения в kafka

У меня есть работа по потоку flink, которая считывает данные с kafka и просто регистрирует ее. Я включил контрольно-пропускные пункты. Я не вижу замеченных смещений в kafka, вместо этого я становлюсь

0зной

1ответ

Flink TaskManager не может подключиться к JobManager в задаче старта docker

Мне не удается заставить диспетчер задач взаимодействовать с JobManager в стеке стаи докеров. Содержание stack.yml файла я использую для docker stack deploy является: version: "3" services: jobm

4зной

1ответ

Отмена задания Apache Flink по коду

Я в ситуации, когда хочу остановить/отменить работу flink из кода. Это в моем интеграционном тесте, где я отправляю задачу на работу с flink и проверяю результат. По мере того, как задание выполняется

0зной

1ответ

Flink streaming - декартовый продукт и окно поверх потоков

Предположим, что у меня есть поток с ключами и метками времени. Я хочу создать декартово произведение этих ключей в каждом окне (скользящее окно). Если у меня есть ключи 1,2,3,4 и я поставил параллель