Вопросы с тегом apache--флинк

0 голосов

1 ответ

Я хочу сделать стриминг в Apache Flink для Kafka -> Flink -> HIVE

patel akash / 09 июля 2020

0 голосов

1 ответ

Как вставить в втягивающуюся раковину из втягивающего потока с помощью планировщика мерцания

johnm / 20 июня 2020

0 голосов

2 ответов

Подключение BroadcastConnectedStream к AsyncIO

Fil Karnicki / 19 июня 2020

1 голос

0 ответов

Apache Flink: Как вызвать один поток из другого потока

Azhagesan / 19 июня 2020

0 голосов

1 ответ

Принудительно Apache Flink сбой и восстановление его состояния с контрольной точки

Alex Sergeenko / 19 июня 2020

5 голосов

1 ответ

Flink Kafka EXACTLY_ONCE, вызывающий исключение KafkaException ByteArraySerializer, не является экземпляром Serializer

Wiggy Lindholm / 19 июня 2020

1 голос

1 ответ

Как узнать статус флинк-задания из Java?

Alejandro Deulofeu / 19 июня 2020

1 голос

3 ответов

Поведение хранилища состояний с ключами в ProcessWindowFunction (Apache Flink Java)

343GuiltySpark / 18 июня 2020

0 голосов

0 ответов

Исключение тайм-аута Flink и нет доступного объединенного слота, и запрос к ResourceManager для нового слота завершился неудачно

sunh / 18 июня 2020

0 голосов

0 ответов

Спуск балочного трубопровода с сеансом прямой пряжи на EMR

Jesse Lord / 18 июня 2020

0 голосов

2 ответов

APACHE FLINK AggregateFunction с tumblingWindow для подсчета событий, но также для отправки 0, если событие не произошло

skydivin4ng3l / 17 июня 2020

0 голосов

1 ответ

Appache Flink - настраиваемое хранилище доверенных сертификатов

Jano333 / 17 июня 2020

0 голосов

0 ответов

Как завершить sh задание Flink, чтобы последние смещения в Kafka были равны последним смещениям в контрольном указании (прочитанные и написанные сообщения)

Vlad / 17 июня 2020

1 голос

2 ответов

Равномерное потребление событий с помощью коннектора Flink-Kafka

EyalP / 16 июня 2020

0 голосов

0 ответов

Flink 1.10.0 - Истекло время ожидания ResourceManager с идентификатором xxxx

Anand Shaw / 16 июня 2020

0 голосов

1 ответ

В чем разница между StreamExecutionEnvironment и StreamTableEnvironment во Flink

Yves / 30 мая 2020

0 голосов

1 ответ

PARTITION BY с TUMBLE вызывает исключение в FlinkSQL

bottaio / 29 мая 2020

0 голосов

1 ответ

В Flink WebUI нет логов и стандартного вывода

Dennis Lee / 29 мая 2020

1 голос

0 ответов

Оптимизация производительности записи flink s3

VSK / 28 мая 2020

0 голосов

2 ответов

JSONDeserializationSchema () устарел во Flink?

RAJAT TANWAR / 28 мая 2020

1 голос

1 ответ

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

Tim Josefsson / 28 мая 2020

0 голосов

0 ответов

LAST_VALUE над окном в FlinkSQL

bottaio / 27 мая 2020

1 голос

1 ответ

Экземпляр объекта, относящегося к flink Parallelism & Apply Method

monstereo / 27 мая 2020

1 голос

1 ответ

Переверните добавление перебалансировки в поток, причину сбоя задания, когда StreamExecutionEnvironment установлен с использованием TimeCharacteristi c .IngestionTime

Mgreg / 26 мая 2020

0 голосов

2 ответов

Запуск нескольких вариантов использования потоковых данных

Venkata Phani Vadapalli / 25 мая 2020