В Эмре работает мой кувшин Флинк.У меня logback.xml установлен в /mnt/var/flink.log как путь к нему...

У меня есть поток, содержащий события Event(Id, Type, Date), и я хочу обработать эти события,...

выяснилось, когда мы использовали ReducingState RecordStore.add (r), производительность колеблется,...

У меня есть функция процесса, реализованная в задании Flink, когда вводится большой объем...

Я хотел бы понять, как окно влияет на производительность в задании Flink. Я выполняю задание flink,...

У меня есть два потоковых источника nifi в Flink, мне нужно выполнить соединения на этих двух...

Я пытаюсь создать элементы, используя FlinkKafkaProducer010, однако, когда я открываю окно консоли...

Я запутался из-за разницы между «широковещательным состоянием» и оператором broadcast (), и,...

Я попытался выполнить тест, чтобы получить запись Кафки с минимальным полем Частота по следующему...

Я отправляю задание Flink в кластер с тремя менеджерами задач через панель управления Flink.Когда я...

Я читаю csv-файл в задании flink, используя env.readCsvFile(input).ignoreFirstLine()

Я не могу увидеть статистику, которая была отправлена ​​с flink на statsd.Уже размещены...

Я использую Flink 1.4.0 Я пытаюсь сохранить результаты запроса API таблицы в файл CSV, но получаю...

Я получил следующее заявление: "В зависимости от вашего внутреннего состояния, Flink может также...

Flink 1.5 имеет методы broadcast() и partitionCustom(), которые позволяют отправить элемент либо на...

Я разработал коннектор Apache Flink для чтения данных из источника OrientDB.Он работает нормально,...

Из объявления о выпуске Flink 1.5 мы знаем, что Flink теперь поддерживает «состояние широковещания»...

Мы находимся в процессе тестирования способности Flink к масштабированию.Но мы обнаружили, что...

Я учу все это.Пожалуйста, поделитесь своими идеями и помощью. Я пытаюсь увидеть метрики мерцания с...

У меня проблемы с пониманием того, как состояние оператора распределяется между экземплярами...

Я настроил обработку времени события и у меня есть связанный поток с CoFlatMapFunction.Я пишу...

У меня есть поток данных, например: DataStream[myTuple(topic, value)] И я хотел отправить...

Я пытаюсь создать универсальный AvroSerde в Scala.Я буду использовать этот serde в сочетании с...

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

У меня всегда одно приложение, слушающее поток Кафки и обрабатывающее события.События являются...