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

1 голос

1 ответ

Ошибка запуска кластера flink [ОШИБКА] Не удалось правильно получить параметры JVM

vinsent paramanantham / 10 марта 2020

2 голосов

1 ответ

Нужно ли мне устанавливать assignTimestampsAndWatermarks, если я установил свои временные характеристики c в IngestionTime в Flink 1.10?

user1870400 / 10 марта 2020

0 голосов

1 ответ

flink scala ошибка потоковой передачи java .lang.NoSuchMethodError: org. apache .flink.util.PropertiesUtil.getBoolean (Ljava / util / Properties; Ljava / lang / String; Z) Z

vinsent paramanantham / 09 марта 2020

0 голосов

1 ответ

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

Bishamon Ten / 09 марта 2020

1 голос

1 ответ

Flink добавить TTL к существующему состоянию значения

jjjmyoung / 08 марта 2020

1 голос

0 ответов

Flink AssignerWithPeriodicWatermarks getCurrentWatermark никогда не вызывается

mrooding / 06 марта 2020

0 голосов

1 ответ

Apache Flink задание не запланировано на нескольких TaskManager в Kubernetes (реплики)

Vijay Veeraraghavan / 06 марта 2020

0 голосов

1 ответ

Флинк кафка к S3 с повтором

Invisible / 05 марта 2020

0 голосов

0 ответов

Какую стратегию очистки Flink я должен использовать?

MAI / 05 марта 2020

1 голос

1 ответ

Apache Flink - обработка дублирующихся сообщений во время развертываний заданий, с ActiveMQ в качестве источника

Vijay Veeraraghavan / 05 марта 2020

0 голосов

1 ответ

В любом случае можно ли преобразование набора данных: «Distinct ()» использовать в Datastream во Flink?

Anish Sarangi / 05 марта 2020

1 голос

1 ответ

Flink StreamSink и Checkpoint Понимание

Anuj jain / 05 марта 2020

1 голос

1 ответ

Повторное использование объекта Flink: изменить входные объекты?

Caesar / 04 марта 2020

0 голосов

2 ответов

Flink не добавляет никаких данных в Elasticsearch, но ошибок нет

Fernie / 03 марта 2020

0 голосов

1 ответ

Flink: Можно ли предоставить или назначить отметку времени для контрольной точки?

Bishamon Ten / 03 марта 2020

1 голос

1 ответ

Есть ли у Flink DataStream api, как mapPartition?

Tracholar Zuo / 03 марта 2020

3 голосов

1 ответ

Apache Flink Dashboard не показывает метрики

ali / 02 марта 2020

0 голосов

1 ответ

Flink EventTime Обработка Водяной знак всегда приходит как -9223372036854725808

Anuj jain / 02 марта 2020

2 голосов

1 ответ

Хранить данные кафки в формате hdfs в формате паркета, используя flink?

andani / 02 марта 2020

1 голос

1 ответ

Тестирование Flink со встроенным Kafka

Felder / 01 марта 2020

0 голосов

1 ответ

Flink: Как перезапустить диспетчер задач Flink на windows?

Bishamon Ten / 01 марта 2020

0 голосов

1 ответ

Dynami c имя таблицы или запрос для коннектора Cassandra / Dynami c приемник задания Flink

Jean Cai / 01 марта 2020

0 голосов

2 ответов

Застрял на: Не удалось найти подходящую столовую фабрику

Fernie / 29 февраля 2020

0 голосов

1 ответ

Локальная ячейка во Флинке

baol / 28 февраля 2020

0 голосов

1 ответ

Flink: ошибка при запуске программы flink на CLI

Bishamon Ten / 28 февраля 2020