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

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

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

В Apache Flink с помощью CassandraSink легко вставить строку в Cassandra. Но я не смог найти способ...

user3640028 / 09 ноября 2019
1 голос
1 ответ

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

Sparkle8 / 07 ноября 2019
0 голосов
0 ответов

Я пытаюсь преобразовать столбец (с именем result) из CSV-файла в двойной тип данных в Java Apache...

user7432713 / 16 октября 2019
0 голосов
1 ответ

У меня есть MapState во флинке. И я установил ttl на 10 минут. Это ttl для всего экземпляра...

Liangde Chen / 15 октября 2019
0 голосов
0 ответов

Есть ли у Flink конфигурации, позволяющие избежать загрузки jar-файлов экстентов при каждой...

hsming / 14 октября 2019
0 голосов
0 ответов

Нам необходимо периодически интегрировать некоторые таблицы в базе данных (потенциально эластичный...

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

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

Jeff / 13 июня 2019
0 голосов
0 ответов

Используя Flink 1.7.2 и YARN 2.8, я тестирую функцию восстановления кластера Flink, и кластер Flink...

kmoti / 20 мая 2019
1 голос
0 ответов

Я использую Flink1.6.1 и Hadoop2.7.5. сначала я начинаю моргать bin/yarn-session.sh -n 2 -jm 1024...

Z.Lun / 19 мая 2019
0 голосов
1 ответ

Возможно ли взаимодействие с таблицей с помощью клиентского интерфейса командной строки Flink SQL,...

salc2 / 09 мая 2019
3 голосов
1 ответ

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

yaarix / 19 марта 2019
0 голосов
0 ответов

У меня кластер из 3 узлов (1 менеджер ресурсов, 2 менеджера узлов по 32 ГБ каждый). Я просто следую...

Fred / 15 марта 2019
0 голосов
1 ответ

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

snakie yu / 13 марта 2019
0 голосов
2 ответов

Я пытаюсь обновить нашу работу с flink 1.4.2 до 1.7.1, но я продолжаю сталкиваться с таймаутами...

Xeli / 19 февраля 2019
0 голосов
1 ответ

Возможно ли запустить задание Apache Flink (потоковая обработка) в течение некоторого заданного...

Kspace / 30 января 2019
0 голосов
1 ответ

Я работаю с обработкой Scala Stream, у меня есть список событий, и я пытаюсь подсчитать вхождения...

S. N / 09 января 2019
0 голосов
1 ответ

Я хочу получать информацию о метриках flink через REST api, мой flink управляется YARN, но после...

debugman / 02 января 2019
0 голосов
0 ответов

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

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

Я пытаюсь прочитать CSV-файл из облачного хранилища Google в Flink REPL.Поскольку я не очень опытен...

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

Пример обработки потока в учебнике - программа подсчета слов с меткой времени.Со следующей выборкой...

edu / 16 декабря 2018
0 голосов
0 ответов

Я ищу Query и использую потоковую обработку для моего собственного формата.хотя я все еще проверяю,...

Hanan Yehudai / 05 декабря 2018
0 голосов
1 ответ

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

user826955 / 02 ноября 2018
0 голосов
0 ответов

Я не хочу настраивать автономный кластер Flink, также не нужно конвертировать сеанс Flink для...

bronzels / 18 октября 2018
0 голосов
1 ответ

моя команда строит вычислительную платформу в реальном времени на основе Flink.Мы представляем...

lycbug666 / 10 октября 2018
0 голосов
1 ответ

Я новичок в Финке и Гелли.У нас есть требование выполнять вычисление графа, в то время как сам граф...

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