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

0 голосов

1 ответ

Порядок операций между временным окном и конвейером стока

mark4284 / 19 марта 2020

1 голос

1 ответ

Контекст в processFunction для KeyedProcessFunction равен нулю

Fernie / 18 марта 2020

0 голосов

2 ответов

Как создать поток фальшивых данных, поступающих в Apache Beam конвейер через определенные промежутки времени?

Matt Welke / 18 марта 2020

0 голосов

1 ответ

Flink MapState очищает все значения ключа карты во время очистки TTL

Vinod.T.V / 18 марта 2020

2 голосов

1 ответ

Соединитель Flink-Cassandra выдает исключение (flink-connector-cassandra_2.11-1.10.0)

Monika X / 17 марта 2020

0 голосов

0 ответов

Ошибка задания мигания java .util.concurrent.ExecutionException: org. apache .flink.runtime.client.JobSubmissionException: Не удалось отправить JobGraph

vinsent paramanantham / 17 марта 2020

1 голос

1 ответ

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

user1870400 / 17 марта 2020

0 голосов

1 ответ

Количество слов всегда меняется, при использовании Flink

monstereo / 15 марта 2020

0 голосов

1 ответ

моргнуть на кубернетес загрузить внешние баночки в кластер

ShemTov / 14 марта 2020

0 голосов

0 ответов

Почему нельзя добавить proctime с помощью вызова addColumns?

xiemeilong / 13 марта 2020

1 голос

1 ответ

Как Flink решает, когда пройти контрольно-пропускной пункт?

David Anderson / 13 марта 2020

0 голосов

0 ответов

Scala файл application.conf не загружает переменную из среды flink

Kallz / 12 марта 2020

0 голосов

1 ответ

Как контрольные точки flink помогают в восстановлении после сбоя

Utlesh Singh / 12 марта 2020

0 голосов

1 ответ

Что произойдет, если для оператора flink keyBy будет задан отдельный ключ, после которого откроется окно

Utlesh Singh / 12 марта 2020

1 голос

1 ответ

Apache Flink: Доступные слоты задач 0

arunprakashpj / 12 марта 2020

0 голосов

1 ответ

Как время контрольной точки мигания связано с размером выравнивания буфера или временем выравнивания?

Utlesh Singh / 11 марта 2020

1 голос

1 ответ

Фильтр уплотнения Flinkrocksdb не работает

Mohammad Hossein Gerami / 11 марта 2020

0 голосов

1 ответ

Как объединить поток и набор данных?

Bishamon Ten / 11 марта 2020

0 голосов

0 ответов

Flink Streaming Кафка Источник в Кафку Раковина

Atanu chatterjee / 11 марта 2020

0 голосов

1 ответ

Поведение Flink Kinesis Producer, когда целевой поток находится в состоянии ОБНОВЛЕНИЕ из-за UpdateShardCount

shahharshil46 / 11 марта 2020

0 голосов

0 ответов

Flink TaskManager не работает с OOM

aditya kumar / 10 марта 2020

0 голосов

1 ответ

Flink: трансляция оператора цепочки

user3161227 / 10 марта 2020

0 голосов

0 ответов

Flink: ошибка при запуске scala -shell - не удалось создать DispatcherResourceManagerComponent

Sarfaraz Hussain / 10 марта 2020

0 голосов

0 ответов

что это значит «фабрика сериализатора типов не может загрузить свои параметры из конфигурации»?

Soad Ahmed / 10 марта 2020

0 голосов

1 ответ

Flink job .UnfulfillableSlotRequestException: Не удалось выполнить требование слота. Требуемый профиль ресурса (ResourceProfile {UNKNOWN}) не может быть выполнен

vinsent paramanantham / 10 марта 2020