Вопросы с тегом FLiNK-потоковый - PullRequest

Вопросы с тегом FLiNK-потоковый

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

Я использую Flink версии 1.8. Основная конфигурация следующая: env.java.opts: -Djavax.net.ssl

Gaurav Kumar / 03 ноября 2019
1 голос
2 ответов

TL; DR: Какое на данный момент лучшее решение для гарантии порядка событий во времени во Flink? Я...

wind / 24 октября 2019
0 голосов
1 ответ

Я использую Flink, и в мою систему поступает поток строк JSON с динамически изменяющимися и...

user286806 / 02 октября 2019
0 голосов
0 ответов

Я получаю следующее исключение при запуске моей маленькой программы flink. Приложение имеет два...

Denorm / 01 октября 2019
0 голосов
1 ответ
0 голосов
1 ответ

Мне нужно объединить два источника событий на основе ключа. Разрыв между событиями может составлять...

Abhishek / 01 октября 2019
0 голосов
1 ответ

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

Mohammad Hossein Gerami / 29 сентября 2019
0 голосов
1 ответ

У меня есть несколько рабочих мест для слияния.Потому что их источник данных одинаков.Поэтому я...

Brutal_JL / 27 сентября 2019
0 голосов
2 ответов

Я пытаюсь написать приложение Flink, которое читает события из Kafka, обогащает эти события из...

frodo / 26 сентября 2019
0 голосов
1 ответ

Я выполняю запрос для объединения потока и таблицы, как показано ниже.Это исчерпывает пространство...

Nishant Gupta / 26 сентября 2019
0 голосов
0 ответов

Я пытаюсь построить конвейер Flink, который читает из API Twitter в реальном времени и пишет в...

Viktor Ershov / 25 сентября 2019
0 голосов
1 ответ

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

EyalP / 25 сентября 2019
0 голосов
1 ответ

У меня есть приложение Flink, которое продолжает выдавать ошибку с этой ошибкой. com.org.ads

frodo / 25 сентября 2019
2 голосов
1 ответ

Я планирую перенести одно из наших приложений Spark в Apache Flink.Я пытаюсь понять его функцию...

lalala / 23 сентября 2019
0 голосов
1 ответ

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

Gaurav Kumar / 23 сентября 2019
0 голосов
0 ответов

Я пытаюсь отправить задание flink (версия 1.8.2) с бэкэндом RocksDB в свой собственный кластер...

Russell Bie / 22 сентября 2019
0 голосов
0 ответов

На основе flink1.5 я запускаю задание flink stream и записываю метрику в Prometheus, которая...

jianxu ren / 22 сентября 2019
0 голосов
1 ответ

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

Joe / 21 сентября 2019
1 голос
2 ответов

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

Hegemon / 19 сентября 2019
1 голос
0 ответов
0 голосов
1 ответ

Попытка запустить пример учебного пособия SocketWindowWordCount, найденного на сайте flink здесь ....

marathon / 10 июля 2019
0 голосов
1 ответ

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

user3361149 / 09 июля 2019
0 голосов
1 ответ

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

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