Я опрашиваю папку, в которой есть несколько CSV-файлов, через задание Flink. После прочтения файла...

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

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

У меня есть следующий метод, который вычисляет вероятность значения в DataSet: /** * Compute the...

Когда я хочу записать сжатые строковые данные в hdfs, я обнаружил, что flink предоставляет только...

Я хочу создать часы времени для моих событий в Apache flink. Я делаю это следующим образом public...

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

Когда я запускаю приложение flink в журналах, я вижу это предупреждение: improper use of...

В настоящее время я использую Flink версии 1.6 и столкнулся с проблемой AsyncIO, из-за которой...

Я ищу решение, основанное на Flink, ситуация в том, что у меня есть транс-поток и некоторые правила...

У меня есть продолжительный кластер Flink на Yarn. Это команда для запуска sudo -E flink run -m...

Я использую Flink в Amazon EMR. В flink-conf.yaml у меня metrics.reporter.prom.port: 9249-9250 В...

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

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

Я пытаюсь повторить этот код Python: cond_entropy_x = np.array([entropy(x[y == v]) for v in uy])...

Я планирую выполнить обновление с Flink 1.5.2 до 1.6.0, а затем выполнить миграцию заданий. Чтобы...

Я написал код flink, который читает файл csv из папки и топит данные по теме kafka. Вот моя работа...

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

Я пытаюсь разработать простой процесс мониторинга с помощью библиотеки CEP Flink. Я создаю csv файл...

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

То, что я делал до сих пор, читается как CSV следующим образом: val data = env

У меня есть следующая конфигурация: Одна тема кафки с 2 разделами Один экземпляр Zookeeper Один...

Я потратил около пары часов, чтобы найти способ для потоковой передачи из Google Pub / Sub с...

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

Прямо сейчас мой код flink обрабатывает файл и переносит данные по теме кафки с 1 разделом. Теперь...