Вопросы с тегом flink-streaming

0 голосов

2 ответов

Есть ли способ гарантировать, что все CheckpointListeners уведомлены о завершении контрольной точки на Flink при отмене задания с помощью точки сохранения?

Mikalai Lushchytski / 07 августа 2020

0 голосов

1 ответ

FLINK - будет SQL окно гриппа sh элемент на регулярной основе для обработки

Ashutosh / 07 августа 2020

0 голосов

1 ответ

Flink Logging не работает в кластерном режиме

Mayank Damani / 05 августа 2020

0 голосов

1 ответ

FLINK - как обработать logi c по результату запроса sql

Ashutosh / 04 августа 2020

0 голосов

0 ответов

получение ошибок после обновления до Flnk 1.11.1

Raj Das / 04 августа 2020

0 голосов

0 ответов

apache контрольная точка флинка завершена, но не завершена

wu susu / 14 июля 2020

0 голосов

1 ответ

Проблема с Flink StreamingFileSink <GenericRecord>и Azure Datalake Gen 2

Marra / 14 июля 2020

0 голосов

1 ответ

RemoteEnvironment нельзя использовать при отправке программы через клиента или при запуске в контексте TestEnvironment.

Akul Sharma / 13 июля 2020

1 голос

2 ответов

Flink statsD интеграция

justlikethat / 13 июля 2020

0 голосов

0 ответов

Обработка сообщений Kafka через Flink SQL Python

Rajat Gupta / 12 июля 2020

1 голос

1 ответ

платформа верверика | Flink Несоответствие требуемых свойств контекста

ayoub hamaoui / 12 июля 2020

1 голос

1 ответ

Как обрабатывать исключения в Apache flink KeyedBroadCastProcessFunction

user13906258 / 10 июля 2020

1 голос

1 ответ

FLINK, событие запуска на основе JSON динамики c входных данных (например, данных объекта карты)

Ashutosh / 10 июля 2020

0 голосов

1 ответ

Apache Флинк в Kubernetes

testbg testbg / 10 июля 2020

0 голосов

1 ответ

Я хочу записать файл OR C с помощью Flink Streaming File Sink, но он неправильно записывает файлы

patel akash / 10 июля 2020

0 голосов

0 ответов

Проблема с Flink State при размещении работы в производственной инфраструктуре

Jesus Zuñiga / 21 июня 2020

0 голосов

2 ответов

Apache Состояние функции процесса мигания не удерживает состояние

BlameMe / 21 июня 2020

0 голосов

1 ответ

У меня ошибка flink k8s ha. задание 00000000000000000000000000000000 находится не в состоянии РАБОТАЕТ, а в состоянии ПО РАСПИСАНИЮ. Прерывание контрольной точки

Jeff / 19 июня 2020

0 голосов

1 ответ

Как использовать Apache Flink DataStream API для вывода потока пар событий?

Nilesh / 18 июня 2020

0 голосов

1 ответ

фильтр по максимуму в поле кортежа в Apache Flink

ekth0r / 18 июня 2020

0 голосов

1 ответ

Мокинг ListState в Apache Flink 1.4

BlameMe / 18 июня 2020

0 голосов

1 ответ

Отправка задания Flink в кластер EMR: не удалось инициализировать точку входа кластера YarnJobClusterEntrypoint

Sateesh Kommineni / 18 июня 2020

0 голосов

1 ответ

Таблица потоковой передачи Flink с использованием источника kafka и использованием flink sql для запроса

Ivan Barrios / 17 июня 2020

0 голосов

1 ответ

Не удается подключиться к kinesis local_stack с помощью FlinkKinesis Producer

user3693309 / 17 июня 2020

0 голосов

1 ответ

Flink ValueState будет удален из хранилища по истечении срока его действия при использовании Rocksdb?

monstereo / 16 июня 2020