Я реализую программу Flink на Java для обработки состояний, используя MapStateDescriptor.Я...

У меня высокодоступный кластер Flink с 3 узлами, на которых выполняются указанные ниже процессы. 1)...

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

Мое приложение flink выполняет следующий источник: чтение данных в виде записей из Kafka split: на...

Я новичок на пороге и пытаюсь применить управление окнами.Мой источник - kafka, и моя модель не...

Я читаю документацию о функции однократного мигания здесь .И я не совсем понимаю некоторые из...

Я использую GlobalWindow с пользовательским Trigger для своего приложения.Согласно требованию, в...

Я хочу использовать поток с ключами, мне было интересно, какой подход лучше с высокой пропускной...

У меня есть два потребителя kafka для одной и той же темы, и я хочу присоединиться ко второму...

Я читаю простую строку JSON в качестве ввода и набираю поток на основе двух полей A и B.Но KeyBy...

У меня есть источник Kafka DataStream, который содержит идентификаторы.У меня также есть база...

Мы создаем приложение, которое имеет два потока: Поток сообщений большого объема Большой...

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

Из официального документа Flink мы знаем, что мы можем «запустить одно задание Flink по YARN» с...

Это изображение плана Flink, которое появляется на приборной панели при развертывании моей работы....

В Flink v-1.4 был API для отдыха, чтобы получить все законченные / завершенные задания: /...

Я использую потоки мерцания в микросервисной архитектуре для передачи данных ETL из сервисов в базы...

В задании Flink я хочу удалить состояние в памяти через 24 часа после его создания. Я проверил это...

Можно ли выполнить обновление версии работы с нулевым временем простоя? Может быть, с конфигурацией...

Я прочитал документацию для 1.7 по процессу для AWS, который использует EMR в качестве...

В моем приложении Flink я полагаюсь на состояние Запроса Flink для запроса результатов вычислений....

В моем случае я использую только запрашиваемое состояние Флинка.В частности, мне нет дела до...

У меня есть задание Flink, в котором я читаю файлы из папки и выгружаю их в базу данных. Новые...

Флинк имеет MemoryStateBackend и FsStateBackend (и RocksDBStateBackend).Кажется, что оба расширяют...

Это оказалось проблемой для нижеприведенного вопроса Apache Flink - проблема простого оконного...