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

0 голосов

0 ответов

Flink `/ bin / sql -client.sh` выдает NoSuchMethodError при чтении из Кафки

Ruurtjan Pul / 02 апреля 2020

0 голосов

0 ответов

Можем ли мы изменить поле rowtime в FLINK SQL?

Brutal_JL / 31 марта 2020

0 голосов

0 ответов

Как автоматически зарегистрировать TableSink в клиенте Flink SQL?

bottaio / 30 марта 2020

0 голосов

0 ответов

временное окно объединяется, чтобы агрегировать данные по падающему окну фиксированного размера в мгновение ока

Nipun Jindal / 22 марта 2020

1 голос

1 ответ

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

Fernie / 18 марта 2020

0 голосов

0 ответов

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

xiemeilong / 13 марта 2020

0 голосов

0 ответов

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

Atanu chatterjee / 11 марта 2020

0 голосов

1 ответ

флинк счет отдельная проблема

Jeff / 09 марта 2020

1 голос

1 ответ

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

Vijay Veeraraghavan / 05 марта 2020

0 голосов

1 ответ

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

Anish Sarangi / 05 марта 2020

0 голосов

0 ответов

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

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

0 голосов

0 ответов

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

sky / 27 февраля 2020

0 голосов

0 ответов

Прочитать MySQL таблицу в мгновение ока с точными именами столбцов

codebot / 26 февраля 2020

0 голосов

0 ответов

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

xiemeilong / 24 февраля 2020

0 голосов

2 ответов

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

xiemeilong / 24 февраля 2020

0 голосов

1 ответ

Flink SQL Конфигурация клиентской среды для чтения файла CSV в качестве исходной потоковой таблицы

Ahmed Awad / 13 февраля 2020

0 голосов

1 ответ

Тип данных Flink не совпадает при добавлении атрибутов времени по источнику таблицы

K F / 13 февраля 2020

0 голосов

0 ответов

Flink JobGraph Представление

Ramana / 11 февраля 2020

1 голос

1 ответ

java .lang.IncompatibleClassChangeError При запуске программы Flink table-api в кластере

Rana Noureddin / 05 февраля 2020

2 голосов

1 ответ

Как определить таблицу apache flink с атрибутом времени строки

sky / 22 января 2020

0 голосов

0 ответов

Flink SQL Поле результата не соответствует запрошенной ошибке типа в LocalDateTime

C.T / 07 января 2020