Я пытался отправить задание Flink в кластер: ./bin/flink run -m <ip>:8081...
Прежде чем вызвать execute на StreamExecutionEnvironment и запустить потоковое задание, есть ли...
Когда я хочу обновить состояние значения (queueState.update (queue)), перехватите это исключение:...
Мне нужно посчитать, сколько раз в день происходит A и за 15 минут - B。 Поток может быть A1, A2, B1...
Я пытаюсь следовать документации и создать табличную функцию для "выравнивания" некоторых данных....
Проблема, связанная с данной: https://issues.apache.org/jira/browse/FLINK-14380 При принятии...
Я запускаю задание flink emr и получаю следующие результаты: at org.apache.flink.client.program
Итак, я создаю JAR с приложениями Storm и Flink, где я регистрирую сообщения следующим образом:...
Это таблица: val res: Table = tenv.sqlQuery( """ |select event.ID,event.locationID,...
Я использую следующий скрипт для отправки приложения flink, flink run -m yarn-cluster -c com.my
У меня проблемы с записью потока с ключами из подзадач приемника в тему вывода kafka. Задание имеет...
Можно ли создавать несколько сред ExecutionEnvironments в программе Flink? В частности, создать...
Прежде всего, я очень новичок в потоковой обработке, не стесняйтесь поправлять меня, если я...
У меня есть SingleOutputStreamOperator, на котором я выполняю некоторую обработку и для которой мне...
Я пытаюсь реализовать конвейер пакетной обработки данных на пороге, где мне нужно Чтение файла с...
Я пытаюсь прочитать конфигурацию JobManager из моей работы Flink, но не могу найти, как получить к...
Я реализовал Flink RichFunction, который имеет следующую структуру: public class MyFunction extends...
У меня есть сценарий поддержки конфигурации во Flink, который я не знаю, как с этим справиться....
Мне просто интересно, есть ли способ скрыть пользовательские конфигурации из панели мониторинга...
Могу ли я сравнить keyedDataStream с keyedPatternStream? Если это так, пожалуйста, кратко,...
в клиенте kafka или Spark они могут использовать ConsumerRecord для получения имени темы или...
Я пытаюсь проверить / сохранить точку моего состояния флинка, работающего на EMR, в корзину s3 на...
Требования довольно просты. У меня есть поступающие данные, которые состоят из следующего: long id;...
Я пытаюсь интегрировать prometheus с flink в intellij. Документация по ссылке говорит, что мне...
val a = keyedPatStream.map(_._1)//String val b = keyedStream.map(_._1)//String val c =...