Не ошибка, но я вижу эту строку, которая в соответствии с сообщением может повлиять на...

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

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

Flink версия 1.6.1 В следующем примере я хочу соединить два потока без ключей.Но кажется, что два...

Мы новички в Apache Flink и Scala.Вот наш пример использования, как будто мы высеиваем данные с...

У нас есть работа Flink, которая содержит довольно большое состояние.Так что время восстановления...

Мой вопрос очень похож на Как поддерживать несколько KeyBy во Flink , просто этот вопрос для Java,...

Когда я использую данные процесса flink sql api. Перезапуск приложения ， sum результат не...

Я строю конвейер в Apache flink sql api.Конвейер выполняет простой проекционный запрос.Тем не менее...

Я использую log4j2 в качестве журнала моего приложения flink (1.4.x), затем я обнаружил, что...

В этом случае создается около 30000 экземпляров класса грузило, есть ли какая-то причина

Попытка использовать поток твиттера с помощью Apache Flink и flatMap его в классе дел, как только...

Я использую Flink (1.4.2) для пряжи.Я использую Flink Yarn Client для отправки работы в Yarn...

Flink 1.5.3, Когда я отправляю задание flink для кластера flink (на пряже), всегда выдается...

У меня есть пользовательский источник, который испускает пользовательский тип данных BaseEvent

Я запускаю несколько заданий на одном и том же TaskManager на одном компьютере.Они оба записывают в...

В HDFS есть данные 4mc.Когда я использую Flink env.readTextFile ("hdfs: //127.0.0.1: 8020 /...

Мы тестируем опцию локального восстановления Flink, чтобы обеспечить быстрое восстановление для...

Мне нужно знать способ реализации пользовательских метрик в моей программе flink.В настоящее время...

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

Класс события Wikipedia Edit имеет 6 флагов: 1. isBotEdit 2. isMinor 3. isNew 4. isSpecial 5....

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

У нас есть временная работа, которая сохранит состояние большого ключа в бэкэнде rocksdb.Мы...

У меня есть DataStream, который состоит из событий со свойством, которое представляет пакет...

В нашем случае мы хотели бы иметь возможность сравнивать потоковые данные при подписке с сервера...