Я играю с разметкой Graph, используя библиотеку Gelly от Apache Flink (версия 1.7.2). Тем не менее,...

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

Официальная документация Flink обеспечивает решение высокой доступности для менеджеров по работе с...

Я читаю сообщения от Кафки в Flink Shell (Scala) следующим образом: scala> val stream = senv

Я пытаюсь настроить проект с использованием BroadcastState, но по какой-то причине я получаю эту...

Мы используем Flink 1.2.1, и мы потребляем от 2 потоков kafka путем объединения одного потока в...

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

У меня есть jar задания, который зависит от flink-json-1.7.2.jar, flink-table_2.11-1.7.2.jar.Это...

Q1: в асинхронном режиме контрольной точки, я думаю, что значение потребления ЦП накладывается на...

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

Чем отличаются CLI и REST API?О зависимостях? одно задание содержит распределенный кэш с hdfs ，...

Когда я использую Распределенный кэш с hdfs ， отправить задание с Flink, запустите xxxxx xxx.jar...

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

Flink версия: 1.7.2. не удалось запустить задание в оболочке (./ flink run -c com.cnc.fink

Я сейчас пишу программу "Flink" на Python. Для этой программы мне нужны некоторые библиотеки,...

У меня есть игрушка Flink, которая читает 3 темы кафки, а затем объединяет все эти 3 потока.Вот и...

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

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

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

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

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

Для первой попытки я хочу прочитать данные JSON из файла и передать их Flink.Я определил источник...

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

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

Я уже установил зафиксированное смещение на: properties.setProperty("auto.commit.interval