Я написал простое приложение для подсчета слов, используя Flink 1.7.2 с Kafka 2.2 как для...

Я определяю определенные переменные в одном Java-классе и обращаюсь к нему с помощью другого класса...

У нас есть AsyncFunction, асинхронная операция выполняется с использованием akka http client class...

У нас есть приложение, которое содержит несколько модулей (один для основного приложения с...

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

Мы ищем решение для мониторинга нашего потока данных - отслеживание хода входящих сообщений во...

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

Я хочу развернуть мое приложение flink в локальном кластере.Я начал свой локальный узел с

У меня проблемы с прохождением операции объединения.Похоже, поток данных останавливается после...

Контрольные точки с источником в качестве EventHub с поддержкой kafka имеют тенденцию к превышению...

KeyedProcessFunction требует, чтобы предыдущий оператор был оператором keyedBy Когда я пытаюсь...

В качестве одного из моих последних шагов в потоковом приложении я хочу отсортировать...

Я недавно столкнулся с проектом Joinery от Yelp: https://engineeringblog.yelp

У меня есть приложение Flink, которое запускается внутри приложения Spring Boot.Приложение не может...

Я намерен зарегистрировать таблицу с БД и информацией о таблице соответственно как: tableEnv

Я пытаюсь сохранить свои контрольные точки в хранилище больших двоичных объектов.Согласно...

Когда я запустил простое приложение Flink с KeyedStream, я заметил, что время задержки события...

Задание Flink успешно выполняется, но не создается метрика mbean в jconsole в среде EMR. То же...

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

Флинк работает над кафкой для разных скоплений.Один из потоков, который мы анализируем, это...

Чтобы записать данные в hdfs, я добавил flink-connector-filesystem_2.11 в свой pom, чтобы я мог...

Может ли кто-нибудь помочь проверить условия для следующих предметов? Продолжительность между...

Рассмотрим FlatMapFunction во Флинке. Требуется, чтобы любая реализация этого была сериализуемой. Я...

Обучение использованию Flink (1.8.0) с Python, попытка прочитать тему Кафки. Использование кода из...

У меня есть четыре физических узла с установленным докером на каждом из них. Я настроил Mesos,...