Из по этой ссылке Я понимаю, что порядок событий, поступающих из некоторого inDataStream,...
Я читаю данные JSON из файла. Образцы данных {"name":"user1"...
Я пишу несколько кодов, которые должны работать (как jar) на платформах flink и spark.Однако эти...
Я новичок в Apache Flink, и я изучал примеры Apache Flink.Я обнаружил, что в случае сбоя Flink...
Когда я использую RabbitMQ в качестве источника данных Flink DataStream, как сказано в документации...
Фон При запуске Flink я получаю немедленный сбой в журналах, и все последующие попытки запустить...
Я новичок, чтобы моргнуть и пытаюсь развернуть мой jar на кластере EMR.Я использовал 3 узла...
Я новичок и пытаюсь развернуть это на кластере EMR. Я использовал 3 узла кластера (1 ведущий и 2...
У меня есть кластер типа https://ci.apache.org/projects/flink/flink-docs-release-1
Задача Локальная обработка внутри узла: Есть ли способ в конвейере потока данных Flink обеспечить,...
Я не могу заставить свою команду cURL работать в Почтальоне. Я заблудился от того, как работает...
Я пытаюсь создать Потребитель Кафки в Apache Flink.Я следил за настройкой, а также за руководством...
Из документации видно, что SQL Флинка может анализировать метки времени только в определенном...
Я работаю с кафкой и апачем флинк. Я пытаюсь использовать записи (которые в формате avro) из темы...
Я создал автономный кластер Flink с 1 менеджером заданий и 2 диспетчером задач. Когда отправляется...
Я выполняю одно задание Flink на Yarn, как описано здесь . flink run -m yarn-cluster -yn 3 -ytm...
У меня есть Dataset<Tuple3<String,String,Double>> values, который имеет следующие...
Я читаю из темы Кафки data, которая разделена на основе поля equipmentId. Всего 15 разделов, по...
Я использую Flink 1.4.1 для обработки транзакционных событий и HDFS для хранения информации о...
Я хочу три значения, они aggValueInLastHour aggValueInLastDay aggValueInLastThreeDay. Я пробовал,...
Мне нужно проверить производительность flink с CEPH-хранилищем. Но я не получаю конфигурацию flink...
Я сталкиваюсь со следующим исключением ввода-вывода при выполнении простого wordcount приложение...
Проблема: приложение Flink не получает и не обрабатывает события от соединителя Kinesis,...
У меня есть 2 проекта, каждый из которых должен использовать один кластер, но я не знаю, как...
Вопрос В автономном кластере Flink, работающем на сервере, я разрабатываю потоковое задание Flink в...