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

Я использую Apache Flink v1.6.0 и пытаюсь записать в Elasticsearch v6.4.0, который размещен в...

Я пытаюсь получить доступ к одной или нескольким темам Kafka с помощью Python Streaming API в Flink...

У меня есть данные, размер которых не превышает 10 ГБ, и мне нужно поместить их в распределенный...

Я пытаюсь использовать flink как в потоковом, так и в пакетном режиме, чтобы добавить много данных...

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

Я прочитал технический документ, но о Data Artisans Streaming Ledger, но обнаружил, что он содержит...

Мне нужно написать модульный тест для топологии потоковой передачи Flink. Это в основном...

У меня кластер Flink с 5 узлами. И у каждого узла есть 8 слотов. Я использую Flink 1.5.2. Если...

Из документации Flink я вижу два разных оконных объекта: timeWindow(Time.seconds(5)), а также...

Я хочу запустить задание по быстрому на kubernetes, используя (постоянный) бэкэнд состояния, похоже...

Мы запускаем Flink в 5-узловом кластере Flink с двумя менеджерами заданий и тремя менеджерами задач

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

Предположим, у нас есть такая структура данных: Tuple2<ArryaList<Long>, Integer> Первое...

Если я установлю номер ТМ = 6, номер слота каждый ТМ = 8, память каждого ТМ = 4G, задание будет...

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

Я пытаюсь настроить S3 как бэкэнд моего состояния с Flink 1.6.0. flink-conf.yaml state.backend:...

Я использую Flink версии 1.5.0. Официальный доктор говорит: Timeout Handling When an async I/O...

У меня есть события DataStream of Kafka (соответствующие показаниям с устройства), поданные в...

я использую flink sql api, и у меня есть sql как Table result2 = tableEnv.sqlQuery("SELECT...

Цитата из Javadoc на StreamExecutionEnvironment.setMaxParallelism: Максимальная степень...

У меня есть простая ProcessFunction, которая принимает String в качестве входных данных и дает...

В автономном кластере Flink в кластере запущено много приложений. Как вы знаете, диспетчер задач и...

например. У меня есть два DataStream<Tuple4<String, String, Date, String>> с именами...

Используя Apache Flink 1.4.2, я получаю следующее исключение com.esotericsoftware.kryo