У меня есть событие типа {"hostname": "abc.com", "data": {}} в теме kafka.События являются...

У меня есть DataStream, в котором есть разные поля, которые я хочу, чтобы keyBy выполнял...

Я использую ProcessWindowFunction в своей работе и сохраняю StateValue.Моя цель - сохранить...

Использование Flink для получения данных из AWS Kinesis. Мои коды: public class kinesisConsumer {...

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

У меня есть события с ключами, поступающие в поток, который я хотел бы накапливать по ключу, вплоть...

У меня есть приложение Flink с высоким параллелизмом (400), работающее в AWS EMR.Он получает Kafka...

Я пытаюсь реализовать редукцию WindowedStream, например, так: .keyBy(t -> t.key)

Я впервые играю с flink (1.6, 1.7) и использую данные из архива github на https://www.gharchive

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

У меня есть поток данных от Kafka: stream .keyBy("key") .window(<tumbling window of 5...

Я заметил, что Apache Flink не оптимизирует порядок объединения таблиц.На данный момент он...

Я использую Zeppelin 0.7.3 с Flink 1.4.2 в режиме кластера.Мое задание Flink зависит от сторонних...

Совершенно новый, чтобы мигать. пытался реализовать простое bucketingSink файл создан, но остается...

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

У меня есть DataStream от Kafka, который имеет 2 возможных значения для поля в MyModel.MyModel -...

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

Я тестирую время события и водяной знак во Флинке.Ниже мой код. object WatermarkTest { def...

Если я запускаю пример приложения flink, как показано ниже: DataStream ds; ds.map(new...

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

Я пытаюсь использовать ProcessWindowFunction в моем проекте Apache Flink с использованием Scala.К...

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

для (пусть i = 0; i

У меня задание flink, в котором в качестве основы ведения журнала используется logback, поскольку...

Я пытаюсь записать файл паркета как сток, используя AvroParquetWriter.Файл создан, но имеет длину 0...