Я использую Flink и пытаюсь сохранить данные в HDFS.Сценарий таков: сначала данные поступают с...
Я читаю https://ci.apache.org/projects/flink/flink-docs-release-1
Новые временные таблицы во Флинке выглядят потрясающе, но я пока не смог заставить их работать
Мое приложение flink выполняет следующий источник: чтение данных в виде записей из Kafka split: на...
Я новичок на пороге и пытаюсь применить управление окнами.Мой источник - kafka, и моя модель не...
Если я запускаю приложение blink для пряжи и число параллелизма больше 1 . Ниже приведена команда:
Оптимизация кода У меня есть приложение flink, которое считывает данные с URL / порта, выполняет их...
Я читаю документацию о функции однократного мигания здесь .И я не совсем понимаю некоторые из...
Я создал таблицу с одним полем типа Дата, а именно f_date .Одна часть желаемой строки таблицы...
У меня есть потоковое приложение на основе Flink, которое использует источники и приемники apache...
Я использую GlobalWindow с пользовательским Trigger для своего приложения.Согласно требованию, в...
У меня есть два потребителя kafka для одной и той же темы, и я хочу присоединиться ко второму...
Как показано в https://ci.apache.org/projects/flink/flink-docs-master/dev/scala_api_extensions.html...
Я читаю простую строку JSON в качестве ввода и набираю поток на основе двух полей A и B.Но KeyBy...
У меня есть источник Kafka DataStream, который содержит идентификаторы.У меня также есть база...
Мы создаем приложение, которое имеет два потока: Поток сообщений большого объема Большой...
Я боролся с особенностями мерцания, чтобы иметь возможность решить ниже подробную проблему;...
Я загрузил файл Avro в наборе данных Flink: AvroInputFormat<GenericRecord> test = new...
Я пытаюсь переписать SQL с помощью Apache Flink 1.7.1 CEP Java API, но вывод неожиданный.«Жадные...
У меня есть задание по быстрому чтению, которое читает данные из Kafka, выполняет определенные...
Apache Flink всегда должен быть установлен как автономный / кластерный сервер, или возможно ли...
Из официального документа Flink мы знаем, что мы можем «запустить одно задание Flink по YARN» с...
Я новичок во Flink, и вроде как запутался с Task и SubTask. Мне кажется, что Задача эквивалентна...
Flink SQL> describe Ticker; root |-- symbol: String |-- rowtime: Timestamp |-- price: Long Flink...
Я новичок во Flink, и у меня нет возможности прочитать исходный код Flink, чтобы понять JobManager,...