Вопросы с тегом апач-Flink - PullRequest

Вопросы с тегом апач-Flink

0 голосов
1 ответ

Я написал простое приложение для подсчета слов, используя Flink 1.7.2 с Kafka 2.2 как для...

MoeHoss / 05 июля 2019
0 голосов
1 ответ

Я определяю определенные переменные в одном Java-классе и обращаюсь к нему с помощью другого класса...

Kspace / 05 июля 2019
0 голосов
1 ответ

У нас есть AsyncFunction, асинхронная операция выполняется с использованием akka http client class...

igx / 04 июля 2019
0 голосов
0 ответов

У нас есть приложение, которое содержит несколько модулей (один для основного приложения с...

roh / 04 июля 2019
0 голосов
0 ответов

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

Nakeuh / 04 июля 2019
0 голосов
0 ответов

Мы ищем решение для мониторинга нашего потока данных - отслеживание хода входящих сообщений во...

roh / 04 июля 2019
0 голосов
1 ответ

Я использую код Flink, который хорошо работает при локальном выполнении (в IntelliJ), но вызывает...

Nakeuh / 04 июля 2019
0 голосов
0 ответов

Я хочу развернуть мое приложение flink в локальном кластере.Я начал свой локальный узел с

Cihan Kara / 03 июля 2019
0 голосов
0 ответов

У меня проблемы с прохождением операции объединения.Похоже, поток данных останавливается после...

Sibendu / 03 июля 2019
0 голосов
0 ответов

Контрольные точки с источником в качестве EventHub с поддержкой kafka имеют тенденцию к превышению...

g. arshad / 03 июля 2019
0 голосов
1 ответ

KeyedProcessFunction требует, чтобы предыдущий оператор был оператором keyedBy Когда я пытаюсь...

g. arshad / 02 июля 2019
0 голосов
1 ответ

В качестве одного из моих последних шагов в потоковом приложении я хочу отсортировать...

James / 01 июля 2019
0 голосов
0 ответов

Я недавно столкнулся с проектом Joinery от Yelp: https://engineeringblog.yelp

Stephen Haberman / 01 июля 2019
0 голосов
1 ответ

У меня есть приложение Flink, которое запускается внутри приложения Spring Boot.Приложение не может...

matano / 30 июня 2019
0 голосов
0 ответов

Я намерен зарегистрировать таблицу с БД и информацией о таблице соответственно как: tableEnv

KAs / 30 июня 2019
0 голосов
1 ответ

Я пытаюсь сохранить свои контрольные точки в хранилище больших двоичных объектов.Согласно...

g. arshad / 29 июня 2019
0 голосов
1 ответ

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

madhusudhan / 29 июня 2019
0 голосов
0 ответов

Задание Flink успешно выполняется, но не создается метрика mbean в jconsole в среде EMR. То же...

Garima / 28 июня 2019
1 голос
1 ответ

Итак, у меня есть случай использования, когда у меня есть соединитель kafka, который использует...

Jicaar / 28 июня 2019
0 голосов
1 ответ

Флинк работает над кафкой для разных скоплений.Один из потоков, который мы анализируем, это...

swik / 28 июня 2019
0 голосов
0 ответов

Чтобы записать данные в hdfs, я добавил flink-connector-filesystem_2.11 в свой pom, чтобы я мог...

xingbin / 28 июня 2019
1 голос
1 ответ

Может ли кто-нибудь помочь проверить условия для следующих предметов? Продолжительность между...

Chen Jiang / 28 июня 2019
0 голосов
1 ответ

Рассмотрим FlatMapFunction во Флинке. Требуется, чтобы любая реализация этого была сериализуемой. Я...

eansn / 27 июня 2019
0 голосов
0 ответов

Обучение использованию Flink (1.8.0) с Python, попытка прочитать тему Кафки. Использование кода из...

Phil / 27 июня 2019
0 голосов
0 ответов

У меня есть четыре физических узла с установленным докером на каждом из них. Я настроил Mesos,...

M_Gh / 27 июня 2019
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...