Путь контрольной точки flink - это абсолютный путь hdfs, такой как hdfs://address:port/path, но...

Я не смог найти работающего примера использования соединителя Kafka вместе с Apache Flink Python...

Я обрабатываю поток Kafka с помощью Flink SQL, где каждое сообщение извлекается из Kafka,...

Я начал flink со следующего docker-compose.yml из официального хранилища flink. Я только добавил...

Я попытался установить некоторые тесты там.Наиболее включенным является yahoo streaming benchmark

Я новичок в Apache Flink и пытаюсь изучить потоки данных. Я читаю данные студента, которые имеют 3...

У меня есть один поток, который используется FlinkKafkaConsumer, который будет присоединен с другим...

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

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

У нас есть метод execute (), в котором мы используем FlinkKafkaConsumer08 в качестве источника...

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

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

Я пытаюсь использовать этот пример для подключения Nifi к Flink: StreamExecutionEnvironment env =...

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

Когда я запускаю сценарий flink scala REPL в java, я не могу скомпилировать. Я пробовал этот код...

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

import breeze.linalg.{*, Axis, DenseVector, argmax, convert, fliplr, flipud, kron, max} import...

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

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

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

Количество ядер ЦП на машину равно четырем.В автономном режиме Flink, как мне установить количество...

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

Я использую FlinkKafka для применения правил в потоке.Ниже приведен пример кода: ObjectMapper...

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

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