Я собираюсь создать пользовательский источник FLINK с коллекцией файлов SFTP.Могу ли я узнать,...

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

Я следовал этому примеру и реализовал с такими же образцами данных kafka json. Данные...

У меня есть задание Flink, которое я тестирую интеграцией, используя описанный здесь подход:...

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

У нас есть 2 источника. В источнике памяти от объекта Источник подписки потока Кафки Они оба...

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

ParameterTool parameterTool = ParameterTool.fromArgs(args); Properties kafkaProperties = new...

Я использую Flink v1.7.1.Когда я закончил потоковое задание Flink с tableSource, SQL и tableSink, я...

При использовании исторических данных в операторе соединения с eventTime чтение данных из одного...

Напишите программу flink, требуется сертификацию Kerberos, запишите данные в hdfs Ошибка локальной...

Когда я открываю веб-интерфейс flink -> Submit new Job в браузере, jobManager часто копирует и...

Я просмотрел документацию Athena Doc Но я не могу настроить его для регистрации моих запросов sql.Я...

Я хочу знать текущее смещение FlinkKafkaConsumer010 в режиме реального времени для мониторинга.В...

Я реализовал это Flink Kafka - Данные пользовательских классов всегда равны нулю . Я прошел по...

У меня есть сложный оконный оператор, который выглядит примерно так: stream =...

Мы запускаем Flink на отдельном кластере из пяти узлов.Каталог /tmp/ продолжает заполняться...

ниже - псевдокод обработки моего потока. Datastream env = StreamExecutionEnvironment

Я хочу установить Flink kafka продюсер semantic. EXACTLY_ONCE, я использую код scala следующим...

В источнике Fink есть flink-stream-java и flink-stream-scala модули.Зачем нам два модуля для...

Я пытаюсь подключить Flink к потребителю Kafka Я использую Docker Compose для создания 4...

Я планирую собрать следующий конвейер данных для одного из требований. IBM MQ -> Kafka Connect ->...

У меня есть без ключа FilterFunction, в котором хранится набор элементов, которые он должен...

У меня есть вариант использования, и я думаю, что мне нужна помощь, как к нему подойти.Поскольку я...

Работа с окнами происходит в бесконечном цикле или что-то в этом роде, я печатаю поток данных после...