Из того, что я могу сказать, с помощью десериализации Flink AVRO вы можете создать поток...

Предположим, я получаю 1000 записей в потоке и хочу сжать их до 10 или 100 записей в качестве...

Flink выбрасывает «java.lang.IllegalStateException: буферный пул уничтожается», когда я использую...

Я подключаю Flink и Elastic Search.С помощью документации .Я создал приемник с использованием Scala

Необходимо ли использовать MapState.put() для обновления состояния вручную или автоматически...

У меня задание flink (scala), которое в основном читает из kafka-topic (1.0), агрегирует данные...

Я использую автономный кластер Flink, состоящий из 3 серверов. Я добавил "env.java.opts: '-Dmykey =...

Я загружаю код Flink-stream-demo, в https://github.com/dataArtisans/flink-streaming-demo Версия...

Я хочу получать и обрабатывать три потока в одном операторе. Например, код, реализованный в Storm ,...

Можно ли удалить текущий водяной знак в DataStream? Пример ввода для водяного знака длиной в месяц...

Я хочу использовать Operator State API в No-Keyed Stream для сохранения состояния count в примере...

Я хочу знать, как проверить окно. Например, окно wordcount ： DataStream<Tuple3<String, Long,...

Работа My Flink (1.6) прослушивает поток и выполняет некоторую агрегацию. Я хочу собрать показатели...

У меня есть потоковое приложение Flink, которому требуется возможность «приостановить» и «отменить»...

Что я делаю, это: 1. Скачайте flink-1.6.1-bin-scala_2.11.tgz и распакуйте 2.открыть затмение,...

Я хочу знать некоторые механизмы, связанные с keyedstream.Код выглядит следующим образом:...

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

Разве невозможно сериализовать классы, которые не являются POJO в apache flink?У меня есть...

У меня есть 2 потока данных (например) ts | device | custId | temp 1 | 'device1'| 1 | 10...

У меня есть потоковое задание с использованием windows . Моя цель - сгруппировать записи по их...

Мне нужно выполнить задание Flink для извлечения записей из базы данных с заданным интервалом и...

Каков разумно ожидаемый прирост производительности при использовании окон обработки во Flink? У...

Я записываю поток данных Kafka в ведущий приемник по пути HDFS.Кафка выдает строковые данные

Я реализую функцию SourceFunction, которая считывает данные из базы данных.Задание должно быть в...

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