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

У меня есть приложение Flink, которое использует FlinkKafkaConsumer. Я заинтересован в получении...

Я внедряю приложение flink в Production, но в веб-интерфейсе flink есть кнопка «Отмена», которая...

Я пытаюсь использовать Apache Flink впервые для школьного проекта, но после установки у меня...

я получаю сообщение об ошибке "Причина: java.io.IOException: Недостаточное количество сетевых...

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

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

Я пытаюсь познакомиться с семантикой Flink после того, как начал с Spark. Я хотел бы записать...

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

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

Я использую кластер с 3 узлами пряжи на EMR (1 мастер 2 основных узла). Я использую 1.6.0. У меня...

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

Я хочу сделать функцию max, используя apache flink с Scala, которая возвращает максимальный элемент...

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

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

У меня есть поток данных, в котором важен порядок событий. Временной признак установлен на...

Я создал тему с помощью этой инструкции: C:\kafka_2.12-0.10.2.1>

Я использую Flink 1.6, я знаю, что могу использовать собственный приемник и куст jdbc для записи в...

Когда я использую flink и создаю объект Row, я сталкиваюсь с такой ошибкой: package scalatest...

Flink позволяет читать из темы Кафки, это узкое место в производительности, делающее Flink...

Написание программы Flink для записи потребляемых данных от Kafka до HDFS. HDFS работает нормально,...

Исключение тайм-аута возникает при запуске официальной демоверсии wiki-edits ! Кажется, что-то не...

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

После добавления некоторого управляемого состояния во время обработки мы обнаружили вызывающее...

Я хочу написать набор данных для улья. Я пробовал куст jdbc, но он не поддерживает batchExecute....