Я использую потребитель Kafka с Flink 1.9 (в Scala 2.12) и сталкиваюсь со следующей проблемой...
У меня есть 2 потока kafka один (keyedStream) для DataStream позже (keyedPatStream) для Pattern...
У меня есть приложение Flink, которое читает некоторые события из Kafka, выполняет некоторое...
Я пытаюсь понять, как интерпретировать показатели контрольных точек, отображаемые моим приложением...
Интересно, есть ли способ во флинке транслировать событие (или что-то в этом роде), если...
Я пытаюсь создать свою собственную переменную метрики в соответствии с этим руководством С помощью...
У меня вопрос по поводу Flink-Kafka Источник: Когда приложение Flink запускается после...
Я использую «keyby» в моем потоке данных. Я хочу, чтобы Flink обнаружил все разделы Кафки по ключам
Я разверну свой менеджер заданий и диспетчеров задач в openshift. это работает также. но в...
У меня есть этот код, который дает locationID и temp, я хочу шаблон, который выдает предупреждение...
Я пытаюсь создать код, который создает предупреждение, когда температура превышает пороговую...
При использовании файла JSON от Кафки во мгновение ока я получаю эту ошибку: Причина: org.apache
Я пытаюсь понять, как работает параллелизм во Flink. Этот документ https://ci.apache
Я пробую простую программу, которая читает файл из S3 и записывает в другое ведро в S3. конечная...
У меня есть FlatMapFunction, которая перечисляет элементы в S3. Я хочу зарегистрировать каждый...
Я пробовал разные методы, но не смог получить права. что не так в этом коде? def main(args:...
Попытка использовать механизм контрольных точек во флинке с fs HDFS. При соединении с hdfs:...
Я делаю простую программу на flink, но она не печатает ни одной строки в выводе std. Я пытался...
Я использую Flink, и в мою систему поступает поток строк JSON с динамически изменяющимися и...
Я получаю следующее исключение при запуске моей маленькой программы flink. Приложение имеет два...
Флинк приводит здесь пример: https://www.ververica
Я использую Flink SQL API для обработки потока данных из Kafka. Для обработки этих данных я...
Я вижу приведенную ниже информацию в документации flink - чтобы скопировать соответствующий jar в...
Я использую Flink 1.9.0 и не могу импортировать или получить файлы таблиц Я пытался импортировать...
Мне нужно объединить два источника событий на основе ключа. Разрыв между событиями может составлять...