Всем доброго времени суток, Я запускаю Flink на AWS EMR с источником файла S3 и получаю следующую...

У меня есть сценарий, в котором мне нужно переместить записи из улья в кафку.Я не мог найти способ,...

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

Я попытался подключить Flink 1.5.2 от zeppelin. Кластер Flink запущен на локальном хосте.flink-conf

У меня есть опыт UnsatisfiedLinkError, когда я пытался использовать flink-s3-fs-hadoop, чтобы...

У меня есть процесс, который должен отправить определенные данные на кластер Flink (через kafka),...

Я использую Apache Flink v1.6.0 и пытаюсь записать в Elasticsearch v6.4.0, который размещен в...

в данный момент я пытаюсь запустить свое первое приложение flink. Я уже протестировал java-файл...

Я пытаюсь развернуть Apache Flink 1.6 на kubernetes. Следуя инструкциям менеджер по работе с...

Вот код Java с использованием flink 1.4, отладка его на intelij StreamExecutionEnvironment env =...

Я пытаюсь получить доступ к одной или нескольким темам Kafka с помощью Python Streaming API в Flink...

Согласно потоковой документации Flink: Функция окна может быть одной из: ReduceFunction,...

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

Я создаю систему flink на Java для чтения и записи в MongoDB. Я использую ядро ​​mongo-hadoop...

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

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

Я ищу эквивалент функции from_unixtime (bigint unixtime) , которая существует в Spark-SQL, в...

Я использую API набора данных с Flink и пытаюсь разбить файлы паркета по ключу в моем POJO,...

Прежде чем кто-либо закроет вопрос или пометит его как повторяющийся, я должен сказать, что я...

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

Мы собираем данные о вождении от тысяч пользователей, каждое транспортное средство связано с IMEI...

например: Существует журнал воспроизведения видео в формате: user_id, video_id, play_duration,...

Предположим, мы определили пользовательский TableSource и TableSink, тогда как интегрировать с SQL...

Я прочитал технический документ, но о Data Artisans Streaming Ledger, но обнаружил, что он содержит...

Я пытаюсь отправить некоторые данные из DataSet в эластичный поиск с помощью нового соединителя...