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

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

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

Я хотел бы сделать count (0) в Flink SQL, но он выдает исключение как org.apache.flink.client

johnny chou / 05 ноября 2019
2 голосов
1 ответ

Я пытаюсь настроить простой автономный кластер Flink. Я следовал этим инструкциям. У меня есть два...

Thanos / 18 октября 2019
0 голосов
0 ответов

Я работаю над добавлением URL в журналы на сервере истории hadoop для выполненных заданий flink

yuyang / 28 сентября 2019
0 голосов
0 ответов

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

pratama / 10 июля 2019
6 голосов
0 ответов

До сих пор я следовал инструкциям, документированным для разъема кинезиса Флинка, чтобы...

Jack Tuck / 04 июля 2019
1 голос
1 ответ

У меня есть приложение с мгновенным зажиганием. Я получаю сообщения от Кафки и обрабатываю...

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

Невозможно использовать StreamingFileSink и сохранять входящие события в сжатом виде. Я пытаюсь...

Nischit / 16 мая 2019
0 голосов
1 ответ

Я пытаюсь запустить пример подсчета слов Apache Beam Python на Apache's Flink, используя...

Anjana / 09 мая 2019
0 голосов
0 ответов

Я использую пул соединений Redis в моей работе Flink. Мне нужно разорвать все соединения, когда...

xingbin / 22 апреля 2019
1 голос
1 ответ

Я пытался запустить пример луча Python-SDK, но у меня были проблемы с чтением ввода. https://cwiki

Yue Zhuo / 11 апреля 2019
0 голосов
1 ответ

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

Akhil KM / 05 марта 2019
0 голосов
1 ответ

Мне нужно использовать kafka через flink, к сожалению, сообщение kafka использует protobuf в serde,...

gfytd / 28 февраля 2019
0 голосов
1 ответ

В RxJava и Reactor существует понятие виртуального времени для тестирования операторов, которые...

user3139545 / 24 февраля 2019
0 голосов
1 ответ

Я записываю записи protobuf в наши сегменты s3.И я хочу использовать api набора данных flink для...

Hu Guang / 15 февраля 2019
0 голосов
1 ответ

Я собираю Apache Flink из исходного кода, используя Gitlab CI с изображением java:8u111-jdk, и...

Paul Lam / 15 февраля 2019
0 голосов
0 ответов

Из-за ограничений я могу использовать только Flink v 1.4.2.Я просматриваю оконные объединения....

hyvbug / 04 февраля 2019
0 голосов
0 ответов

У меня высокодоступный кластер Flink с 3 узлами, на которых выполняются указанные ниже процессы. 1)...

Akhil KM / 01 февраля 2019
0 голосов
1 ответ

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

Jac / 31 января 2019
0 голосов
1 ответ

Мы хотим использовать паркетный файл из s3 Мой фрагмент кода такой.Мои входные файлы - это...

Hu Guang / 21 января 2019
0 голосов
1 ответ

Описание проблемы 2 компьютера (203 204) создали автономный режим кластера HA Flink v1.6.1 и...

william / 28 декабря 2018
0 голосов
1 ответ

Предположим, у меня есть поток торговых событий на фондовом рынке, например: technical1, ALXN,...

devinbost / 09 октября 2018
0 голосов
1 ответ
0 голосов
2 ответов

У меня есть простая ProcessFunction, которая принимает String в качестве входных данных и дает...

Harshith Bolar / 02 июля 2018
0 голосов
0 ответов

Я пытаюсь написать пользовательскую скалярную функцию во Flink, которая принимает несколько...

Rakesh Chalasani / 10 мая 2018
0 голосов
0 ответов

Я реализую алгоритм подключенных компонентов, используя API-интерфейс DataStream от Flink,...

Henrique / 10 мая 2018
Для получения более полной информации посмотрите в списке вопросов или в популярных тегах.
Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...