Я следовал рекомендациям https://github.com/abajwa-hw/ambari-flink-service.git.. Я подтвердил в...

Мы работаем с кластером из пяти узлов с тремя менеджерами задач (TM1, TM2, TM3) и двумя менеджерами...

Мне нужно разработать PoC приложения, которое динамически идентифицирует и отслеживает положение...

У меня есть сценарий, в котором мне нужно запустить одно Java-задание Apache Beam в двух разных...

Я планирую развернуть задание с помощью Docker через Кластер заданий Flink , и я не вижу способа...

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

Вот случай, у нас есть 3 темы кафки (у каждого по 50 разделов), у них разные сообщения, в то время...

Flink Web UI имеет блестящую секцию противодавления. Но я не вижу никаких метрик, предоставленных...

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

Я читаю сообщения от Кафки в оболочку Flink Scala. Я хочу прочитать несколько сообщений, сохранить...

Я использовал приведенную ниже команду для получения рабочих мест . / Bin / flink list -r Но я хочу...

В соответствии с документацией Flink при считывании данных с S3 конфигурация устанавливается на...

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

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

Моя программа хочет объединить два потока без Flink Window. Я соединяю два потока и определяю, что...

Фон У нас есть 2 потока, назовем их A и B.Они производят элементы a и b соответственно. Поток A...

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

В веб-интерфейсе Flink я могу получить метрики каждого параллелизма, для параллелизма 0, ему...

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

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

Я хочу рассчитать время восстановления контрольной точки при обработке потока с контролем состояния...

Я пытаюсь настроить очень простую работу Flink.Когда я пытаюсь запустить, получаю следующую ошибку:...

У меня есть неупорядоченный DataStream<Event>, который я хочу отсортировать так, чтобы...

Я использовал соединитель AMQSource Apache Bahir, который слушает ActiveMQ, но когда я запускаю...

Я собираюсь создать пользовательский источник FLINK с коллекцией файлов SFTP.Могу ли я узнать,...