Я работаю с Apache flink потоками.Я хотел написать собственный коннектор / источник для извлечения...
После переноса моей среды из автономного кластера в кластер EMR с нитями у меня возникли проблемы с...
У меня есть работа Flink, в которой я использую logback в качестве основы для логирования.Помимо...
У меня задание flink (выполняется на AWS EMR), которое использует другую зависимость maven, и эта...
Мы развернули кластер заданий Flink (1 менеджер заданий и 1 менеджер задач) в нашей среде K8s и...
Я исследую Флинк больше недели.Мы потребляем события от Kafka и хотим, чтобы события принадлежали...
Мы запускаем Flink на кластере из 3 ВМ.Каждая виртуальная машина имеет около 40 Go оперативной...
Я выполняю эксперимент по распределенной обработке данных с использованием контейнеров, управляемых...
У меня есть база данных с таблицами T1 (идентификатор, имя, возраст) и T2 (идентификатор, тема)
У меня есть непрерывные данные JSONArray, созданные для темы Kafka, и я хочу обработать записи с...
У меня возникают проблемы с использованием OrcTableSource для извлечения файла Orc из облачного...
Установлено соединение с базой данных Mysql с помощью JDBC, но не удалось сохранить эти данные в...
Я использую Flink локально на моей машине, я получаю исключение ниже при чтении из темы Кафки.при...
Я использую функцию IntervalJoin для объединения двух потоков в течение 10 минут.Как показано ниже:...
Я использую Apache Flink в проекте фондового рынка для расчета текущего изменения цены.Формула:...
Я пытаюсь собрать метрики из Apache Flink в Prometheus. В документации Flink говорится, что мне...
Я вижу, что есть коннектор для DataSet API для mongoDB, но нет Streaming API. Есть ли планы...
Мне нужно реализовать ниже поток данных. У меня есть одна тема Кафка, которая имеет 9 разделов. Я...
У меня есть исключение, когда я запускаю свой код в кластере flink. Я считаю, что проблема...
Вариант использования: с использованием EventTime и извлеченной метки времени из записей из Kafka....
Я начинаю экспериментировать с Apache Flink и достиг некоторых очень простых вещей.Теперь я с...
Я видел эту строку в документации Flink , но не могу понять, что означает «режим отсоединения»....
Я только начал читать о Flink и хотел узнать больше о том, как Flink обрабатывает противодавление и...
Из того, что я могу сказать, с помощью десериализации Flink AVRO вы можете создать поток...
Предположим, я получаю 1000 записей в потоке и хочу сжать их до 10 или 100 записей в качестве...