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

У меня есть оконный почасовой агрегированный DataStream. DataStream <RawData> ds = ........

Я обнаружил, BucketingSink может делать все, что может StreamingFileSink , например записывать...

У меня есть две таблицы потоков Таблица id | data1 | ts ------------------------ 1 | xxxx | 1234...

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

Я пишу проект во Флинке, который предусматривает потоковую передачу набора точек запроса по...

Я использую Apache Beam 2.7.0, который я видел в Матрице возможностей (https://beam.apache

Я хочу использовать Session агрегирование окон, а затем запустить Tumble агрегацию окон поверх...

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

Я создал пользовательскую функцию Flink RichSinkFunction и попытался автоматически связать...

Я испытываю новый потоковый API-интерфейс от Flink и пытаюсь запустить мой скрипт с ./flink-1.6

Я пытаюсь настроить кластер (Apache Flink 1.6.1) с Kubernetes и получаю следующую ошибку при...

Мое использование конвейера больше похоже на обновление.Он начинается с Kafka, захватывает...

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

Я пытаюсь объединить два потока в Apache Flink, чтобы получить некоторые результаты. Текущее...

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

Я получаю следующую ошибку org.apache.flink.shaded.netty4.io.netty.channel.AbstractChannel $...

Я использую api таблицы flink, я получаю данные от kafka, затем регистрирую их как таблицу, затем...

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

Я пытаюсь применить очень простую оконную функцию к конечному потоку данных в Apache Flink (...

Я запрашиваю разъяснения о том, как именно Apache Flink (1.6.0) обрабатывает события из...

Скажем, у меня есть Флинк SourceFunction<String>, который называется RequestsSource. При...

При выполнении задания потока данных Flink (1.6.0) с RocksDB в качестве внутреннего хранилища и...

Я пытаюсь реализовать очень простой Apache Flink CEP для Kafka InputStream. Производитель Kafka...

У меня есть задание Flink, которое записывает данные в Kafka. В теме Kafka максимальный размер...