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

У меня есть кластер с: 1 TaskManager 1 Автономная работа / JobManager Конфиг: taskmanager

До сих пор мы использовали GraphiteReporter для мониторинга Flink. Недавно мы решили, что нам не...

Наше задание flink отлично работает в локальном режиме, но при попытке развернуть его в кластере...

Мы работаем с 5-узловым кластером Flink (1.6.3) над kubernetes с источником раздела Kafka из 5...

Есть ли в Flink способ использовать keyby (key1 или key2) (клавиши ORing) Я не имею в виду keyBy (0...

Я хочу создать новое развертывание k8s с заданием сеанса;и один taskmanager развернут с такой...

У меня есть jsons, как, { "name":"someone", "job":"doctor",...

Я использую панель управления Flink 1.7 и выбираю потоковое задание.Это должно показать мне...

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

В моем конвейере есть скользящее окно времени события, и оно прекрасно работает, за исключением...

У меня есть настройка checkpointing в моей работе Flink, и у нее есть 2 скользящих окна (это не...

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

Я использую кафку Flink's (1.7.2).Как десериализовать несколько классов дел, которые расширяют ту...

Когда я создаю 20 сообщений, я использую только 13 сообщений, остальные 7 не потребляются в режиме...

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

Я еще не выбрал потоковый фреймворк, но сейчас я возиться с Флинком. Но я открыт для использования...

У меня есть пример потокового WordCount примера, написанного на Flink (Scala).В нем я хочу...

У меня есть кластеризованный кластер Flink с автономным JobManager и 2 менеджерами задач.Все...

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

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

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

У меня есть сообщение для чтения кода от kafka, как показано ниже: def main(args: Array[String]):...

Я новичок во Флинке, нужна помощь с подходом.У меня есть поток событий со временем детализации 5...

Я применяю пользовательскую функцию flatMap к DataStream во Flink и хочу записать исключения,...