Я пишу схему сериализации для производителя Flink Kafka.Вот мой исходный код....

Я использую GroupCombine и GroupReduce с примером WordCount.Но в отличие от исходного примера, я не...

Я пытаюсь передать поток в корзину s3 и реализует интерфейс Encoder. case class Info(vecId: Long,...

Я хотел бы знать, почему мне действительно нужно создать свою собственную функцию RichSinkFunction...

Моя цель - собрать / накопить список строк в потоковом контексте с помощью операции со скользящим...

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

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

Я запустил локальный сервер Flink (./bin/start-cluster.sh) и отправил задание.У меня есть следующий...

Я определил приложение Flink, которое читает из 2 входных потоков, объединяет их и агрегирует...

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

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

Ниже приведен слайд об оптимизаторе Флинка из моей презентации, которую я смотрел.Меня особенно...

1) Невозможно запустить задание Flink с несколькими заданиями (> 500 заданий в одном задании)....

В Apache Flink я использую функцию RichAsync для обогащения данных. В случае ошибок / исключений я...

У меня есть один поток, который постоянно передает последние значения некоторых ключей. Поток A:...

1) Я установил Apache Flink на свой локальный компьютер (Ubuntu 16.04). Разработал java-программы,...

Я пытаюсь понять, что означает "Получено / отправлено байтов", как показано на панели инструментов...

В следующем фрагменте я пытаюсь отсортировать таблицу по «значению»;однако сортировка происходит...

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

Я установил Apache Flink 1.4 и реализовал несколько задач с использованием API набора данных....

У меня есть приложение flink с 1 входным источником, оно проходит через несколько карт и...

После обновления Flink до 1.7.2, когда я пытаюсь отправить задание с панели мониторинга и возникает...

Я написал программу Flink для анализа потоковых данных.Я могу запустить его без проблем.Но когда я...

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

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