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

Я использую Flink's FlinkKafkaConsumer010 и Kafka версии 1.1. Я хочу получить информацию о смещении...

List<Integer> lst = Stream.of(1, 2, 3, 4, 5, 6, 7, 8, 9, 10) .collect(Collectors.toList());...

Я пишу приложение Flink на Kotlin, и классы данных (как и другие классы Kotlin) не определены как...

Привет, я просто пытаюсь выяснить, правильно ли я понимаю время потоковой передачи.В настоящее...

Apache Flink предоставляет множество различных потоковых источников, но мне было интересно,...

Я пытаюсь запустить простую работу в Apache Flink, используя Zeppelin. Я создал Docker-контейнер с...

I am reading a "ABC" topic which have 5 partitions но на самом деле, когда я создал группу...

Apache flink - задача простого оконного задания - java.lang.RuntimeException: сегмент освобожден...

Я просмотрел официальную документацию Flink, но не нашел, какой SQL поддерживает этот flink

Мы работаем с автономным кластером Flink с 2 менеджерами заданий и 3 менеджерами задач. Всякий раз,...

Я использую Global Windows для своего приложения с пользовательским триггером и пользовательским...

Я новичок в Apache Flink, поэтому сейчас пытаюсь провести несколько экспериментов. Я читаю тему из...

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

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

У меня есть кластер Apache Flink с автономным режимом, я хочу настроить Flink Metrics. config в...

Exception in thread "main" java.lang.NoSuchMethodError: scala.Predef$

У меня есть 4 менеджера задач и использующий бэкэнд состояния карты (RocksDB). используя...

При развертывании задания Flink я получаю следующую рекурсивную ошибку на ParserATNSimulator,...

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

Apache Flink позволяет мне использовать State в RichMapFunction. Я планирую создать постоянно...

Я пытаюсь добавить эластичный поиск в качестве приемника, и мой текущий эластичный поиск включил...

KeyedStream # max (строковое поле) Применяет агрегацию, которая дает текущий максимум данных поток...

У нас есть работа с 30 операторами. Когда мы запустим эту работу с параллелизмом в 12 мгновенных...

У меня есть топология Flink, которая использует ListState [MyAvroClass] в CoProcessFunction. В моей...