Мы читаем данные из kafka, сообщение можно упростить до Tuple2, здесь String - это ключ, а Integer...
Я пытаюсь обработать некоторые файлы в HDFS и записать результаты обратно в HDFS. Файлы уже...
Сейчас я читаю строки из файла и сохраняю в базе данных, используя следующий код: String strQuery =...
При использовании Flink Table SQL в моем проекте я обнаружил, что если бы в моем SQL-запросе было...
Я пытаюсь представить свою банку с аргами.Я использую Flink Rest Api для отправки моих аргументов в...
Слот задач изолирует память, но не изолирует процессор. Flink может делить слоты задач с...
Я пытаюсь скомпилировать Flink 1.7.2 для Scala 2.12, чтобы получить коннектор AWS Kinesis, который...
в этом коде, я должен использовать transient? когда я могу использовать transient? в чем разница?...
У меня есть сервер Flink, работающий в кластере Kubernetes. У меня есть фляга работы, которая...
Я следовал рекомендациям https://github.com/abajwa-hw/ambari-flink-service.git.. Я подтвердил в...
Мы работаем с кластером из пяти узлов с тремя менеджерами задач (TM1, TM2, TM3) и двумя менеджерами...
Я использую flink 1.7.2 в Debian Slim, и kubernetes в качестве моего менеджера ресурсов. Но когда я...
Нет бэкэнда состояния RocksDB: состояние широковещания сохраняется в памяти во время выполнения, и...
Я запускаю приложение Flink (через Yarn), и иногда кажется, что случайно диспетчер задач...
С помощью этого ответа https://stackoverflow.com/a/1759565/11217621, Я знаю, что в Java можно...
При использовании состояния оператора (или состояния без ключа) каждое состояние оператора...
У меня проблема с использованием стратегии пропуска при разработке на FLink CEP 1.7.1. Вот мой код,...
Мне нужно разработать PoC приложения, которое динамически идентифицирует и отслеживает положение...
Я испытываю трудности в стажировке, и мне сказали внедрить систему для отслеживания агрегации...
Ниже приведен мой потоковый код. Я хочу, чтобы метод map получил метод customer из внешнего jarfile...
Если я брошу исключение времени выполнения в оператор flink, как оно будет обработано? Я просто...
Я планирую развернуть задание с помощью Docker через Кластер заданий Flink , и я не вижу способа...
Я пытаюсь обновить наш кластер Flink с 1.4.2 до 1.7.2 Когда я запускаю кластер, менеджеры задач...
Вот случай, у нас есть 3 темы кафки (у каждого по 50 разделов), у них разные сообщения, в то время...
Flink Web UI имеет блестящую секцию противодавления. Но я не вижу никаких метрик, предоставленных...