Я запустил задание сначала с Параллелизмом 1, а затем с Параллелизмом 3. С Параллелизмом = 1...
Я пытаюсь собрать Apache Flink из исходного кода. Я строго следую инструкции, приведенные @github...
Как назначить идентификатор окну сеанса в Apache Flink? В конечном итоге я хочу обогатить события...
Мне нужна помощь по мониторингу задержки (миг 1.8.0). Допустим, у меня есть простой поток потоковых...
У меня есть 2 потока событий, один из которых является результатом flatmap.Я хочу присоединиться ко...
Я использую dbcp2.BasicDataSource как пул соединений с базой данных. Запрос к базе данных...
Я хочу знать, как Flink перезапускается после сбоя, и как продолжить операцию на основе последнего...
Я пытаюсь отправить задание Flink, созданное в Scala 2.11, которое использует потоковый API Twitter...
У меня вопрос по поводу Флинка.Я запускаю приложение в локальном кластере с 1 TaskManager и 4...
Как обрабатываются временные метки в итеративном цикле DataStream в Flink? Например, вот пример...
Я пытаюсь найти популярное направление, куда большее количество людей обращалось с помощью API...
Я пытаюсь создать источник таблицы потоков с некоторыми фиктивными данными. Когда дело доходит до...
Попытка использовать Flink для чтения потока Kafka сериализованных данных "avro", например:...
Flink выполняет значительное сканирование во время предполетной фазы приложения Flink (https://ci
Мы используем kafka как источник нашего конвейера.Я хочу перенести существующее состояние из...
Я бы хотел, чтобы последняя контрольная точка была загружена во Flink, но это не так. Я написал...
У меня есть запрос SQL, подобный этому String ipdetailsSql = "select sid, _zpsbd6 as...
Я пытаюсь обновить документы в Elasticsearch, используя сообщения Kafka (как StreamSource). Запись...
Я работаю над проектом в реальном времени с Flink, и мне нужно дополнить состояние каждой карты...
У нас есть приложение для потоковой передачи сообщений kafka -> flink -> MongoDB в режиме реального...
Я хочу использовать aws s3 в качестве приемника для потока данных в flink.Я использую класс...
Флинк имеет следующий комментарий в LeaderElectionService.java https://github
при условии, что у меня есть это class FooProcess extends ProcessAllWindowFunction[String,String,...
У меня есть поток - я хочу сравнить количество событий в текущем окне с предыдущим окном. Это можно...
Ошибка компилятора при использовании примера, приведенного в документации Flink.Документация Flink...