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

0 голосов

1 ответ

Как соединить два потока и управлять ими во Флинке?

ChackM / 28 февраля 2020

0 голосов

1 ответ

Настройка FlinkKafkaConsumer group.id не работает должным образом при использовании

alen / 28 февраля 2020

1 голос

1 ответ

Flink: запросы относительно контрольной точки Flink и точки сохранения

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

0 голосов

0 ответов

Проблема, когда Flink загружает работу с потоком sql запрос

Miguel Angel Perez Garcia / 27 февраля 2020

1 голос

1 ответ

Как добавить коннектор Kafka, чтобы прошивать через sbt IntelliJ? Хочу добавить универсальный разъем для поддержки Кафки 2.3

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

1 голос

1 ответ

Как запустить нисходящий метод onEventTime () при использовании шаблона BroadcastState?

343GuiltySpark / 27 февраля 2020

0 голосов

0 ответов

Что лучше? Выполнение запросов в виде двух отдельных заданий или двух запросов в одном задании

sky / 27 февраля 2020

0 голосов

1 ответ

Тестирование окна Flink

Felder / 26 февраля 2020

0 голосов

1 ответ

записать json данные из кафки в s3 в формате паркета

raj247 / 25 февраля 2020

1 голос

0 ответов

Flink - Создать BroadcastStream из свойств базы данных

Francesco Salvatore Lazzaro / 25 февраля 2020

0 голосов

1 ответ

Flink Tumbling задерживает запуск getResult с помощью AscendingTimestampExtractor

lucky_start_izumi / 25 февраля 2020

0 голосов

2 ответов

Как Flink обрабатывает водяные знаки с операторами Union?

ChrisATX / 25 февраля 2020

0 голосов

1 ответ

Расщепление потока во Флинке

ChrisATX / 24 февраля 2020

0 голосов

0 ответов

Как я могу сделать удаление в таблицу Dynami c, которая преобразована из потока, добавив элемент в поток в Flink

xiemeilong / 24 февраля 2020

0 голосов

2 ответов

Типы полей результата запроса и зарегистрированного TableSink не совпадают

xiemeilong / 24 февраля 2020

0 голосов

0 ответов

контрольно-пропускной пункт и производитель кафки ровно один раз

张浩文 / 22 февраля 2020

0 голосов

1 ответ

Как написать функцию внешнего соединения в Flink с помощью Connect?

MJeremy / 20 февраля 2020

0 голосов

1 ответ

данные flink не обрабатываются функцией процесса в операторе временного окна

igx / 19 февраля 2020

0 голосов

1 ответ

Flink: StreamingFileSink.withRollingPolicy не работает

cause1028 / 18 февраля 2020

0 голосов

1 ответ

Что такое водяной знак в Flink по отношению к обработке времени события? Зачем это нужно?

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

0 голосов

1 ответ

Совместное использование состояния подзадачи оператора с использованием побочных выходов

Vishal Surana / 18 февраля 2020

0 голосов

0 ответов

Как Flink распределяет работу при использовании потоков Kinesis?

C. Johnson / 17 февраля 2020

1 голос

2 ответов

Таймер моргания асинхронный

Amitai / 17 февраля 2020

0 голосов

1 ответ

Распределить нагрузку внутри цепочки операторов в Flink

justlikethat / 17 февраля 2020

0 голосов

1 ответ

Кинезис Потоки и Флинк

ChrisATX / 15 февраля 2020