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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

как пример в flink doc: input .keyBy(<key selector>) .window(TumblingEventTimeWindows.of(Time

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

У меня есть 2 DataStream s, которые я подключаю и передаю в функцию CoFlatMap.Мне нужно иметь...

В следующем простом коде Flink у меня есть 3 события с временными событиями, по 1 секунде между...

Я пытаюсь использовать запрашиваемое состояние на Flink (версия 1.4.2), но, к сожалению, я получаю...

У меня есть конвейер обработки времени-события. Что-то вроде: env.keyBy(_.key)

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

давайте предположим, что у нас есть этот JSON { "Account Informations": { "User...

Таким образом, это принимает строки JSON -> Java ObjectNode. final DataStream<ObjectNode>...

Например, за A должно следовать B в течение 10 секунд. Я знаю, как отследить, произошел ли этот DID...