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

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

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

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

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

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

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

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

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

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

Я успешно использую JsonRowSerializationSchema из артефакта flink-json для создания...

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

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

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

Я пытаюсь использовать Flink's StreamingFileSink для записи элементов в потоке данных в коллекцию...

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

Могу ли я знать, что происходит с состоянием, хранящимся в диспетчере задач Flink, когда происходит...

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

С maven я создаю толстую банку для моего потокового приложения. Нужно развернуть банку в кластер k8

У меня есть следующий код: val stateUri = "file:///tmp/" new RocksDBStateBackend(stateUri...

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

Я устанавливаю конвейер flink, который читает из Kafka и опускается в HDFS. Я хочу обработать...

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

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

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