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

0 голосов

2 ответов

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

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

2 голосов

1 ответ

Flink - Присоединяйтесь к тому же потоку, чтобы отфильтровать некоторые события

Marco / 07 августа 2020

0 голосов

1 ответ

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

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

0 голосов

1 ответ

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

Ashutosh / 04 августа 2020

0 голосов

0 ответов

доставить данные заказа (FIFO), прочитанные из S3 - Python

Vijay / 04 августа 2020

0 голосов

0 ответов

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

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

0 голосов

1 ответ

Apache -Flink 1.11 Невозможно использовать от Python UDF до SQL Функция DDL в Java Задание потоковой передачи Flink

Jonathan Figueroa / 04 августа 2020

0 голосов

0 ответов

Размер состояния контрольной точки Flinks RocksDB растет и никогда не уменьшается

aditya kumar / 03 августа 2020

0 голосов

0 ответов

Тайм-аут запроса HttpAsyncClient HC5

Yulia / 02 августа 2020

1 голос

1 ответ

Одновременное обновление состояния Flink Statefun

Arif Ezberci / 14 июля 2020

0 голосов

1 ответ

Flink JDB C Пул приемников и соединений

Michal Kordas / 14 июля 2020

0 голосов

0 ответов

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

wu susu / 14 июля 2020

0 голосов

1 ответ

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

Marra / 14 июля 2020

1 голос

0 ответов

Операторы Flink Бенчмаркинг

Salvador Vigo / 13 июля 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 голосов

1 ответ

Источник и приемник пользовательской таблицы RabbitMQ для pyflink 1.11

Jonathan Figueroa / 10 июля 2020

0 голосов

1 ответ

Apache -Flink 1.11 Невозможно использовать Python UDF в SQL Function DDL

Jonathan Figueroa / 09 июля 2020

0 голосов

1 ответ

python Установка Flink Не удалось найти файл /flink-1.12-SNAPSHOT-bin/flink-1.12-SNAPSHOT/opt/flink-python_*.jar

Ajay Chinni / 09 июля 2020