Я использую Flink, и я использую пользовательскую функцию на карте.Эта пользовательская функция...

В чем отличие Apache Flink (например, v1.8) между менеджером заданий и мастером заданий? Диспетчер...

У меня есть требование генерировать событие CEP, если мы обнаружили, что строковое сообщение...

Мы рассматриваем возможность использования flink для использования, но не уверены, подходит ли ему...

Редактировать: я обнаружил этот другой вопрос несколько лет назад ( Как заполнить кэш в...

Я реализую функцию RichParallelSourceFunction, которая читает файлы через SFTP....

Я пытаюсь реализовать ИТ для конвейера, который использует службу времени. Конвейер должен...

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

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

У меня есть несколько рабочих процессов Apache Flink (пакетных, не потоковых), и моя цель -...

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

Я использую Flink 1.8.0 и пытаюсь запросить состояние своей работы. val descriptor = new...

В документации Flink для RichAsyncFunction указано: API-интерфейсы, относящиеся к состоянию в...

Кто-нибудь знает, как проверить оконные функции в Flink?Я использую зависимость flink-test-utils_2

Предоставляет ли flink способ периодически запрашивать API и создавать из него объект потока данных...

Я пытаюсь создать простой многоузловой кластер Flink (1 ведущий 1 ведомый). Когда я запускаю свой...

Я полагаю, что Флинк ведет себя странно, когда два разделения делаются последовательно. У меня...

Сначала я загружаю файл CSV в тему Kafka и могу напечатать тему через программу Flink. Код...

C: 4, g: 3, h: 1, L: 4 данные поступают каждые 2 секунды. ч: 1 это значение, которое не имеет...

Я работаю над окном, основанным на времени события Flink. Но когда я посылаю сообщение Кафки,...

Наша задача flink использует iot-данные, и мы хотели бы сохранить накопительные и некоторые события...

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

Я работаю над приложением , которое загружает некоторые файлы в корзину s3 , а позже читает файлы...

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

вопрос довольно простой, но я не смог найти ответа в интернете. У меня есть запрос Flink SQL,...