Когда я использую данные процесса flink sql api. Перезапуск приложения ， sum результат не...

Я строю конвейер в Apache flink sql api.Конвейер выполняет простой проекционный запрос.Тем не менее...

Я использую Flink (1.4.2) для пряжи.Я использую Flink Yarn Client для отправки работы в Yarn...

Я ищу Query и использую потоковую обработку для моего собственного формата.хотя я все еще проверяю,...

Я заметил, что Apache Flink не оптимизирует порядок объединения таблиц.На данный момент он...

Я реализую функцию SourceFunction, которая считывает данные из базы данных.Задание должно быть в...

У меня есть две таблицы потоков Таблица id | data1 | ts ------------------------ 1 | xxxx | 1234...

Я хочу использовать Session агрегирование окон, а затем запустить Tumble агрегацию окон поверх...

У меня часто обновляется таблица MySql.Я хочу сделать снимок для каждого идентификатора, который...

Я использую api таблицы flink, я получаю данные от kafka, затем регистрирую их как таблицу, затем...

Мне нужно объединить несколько файлов, чтобы выполнить некоторую обработку. API набора данных...

Существует два способа развертывания приложений Flink на пряже.Первый - использовать yarn-session,...

Я ищу эквивалент функции from_unixtime (bigint unixtime) , которая существует в Spark-SQL, в...

У меня кластер Flink с 5 узлами. И у каждого узла есть 8 слотов. Я использую Flink 1.5.2. Если...

Я хочу сделать простой запрос в Flink SQL в одной таблице, которая включает оператор group by. Но в...

Я столкнулся с проблемой, из-за которой я не получаю результаты из своего запроса в Flink-SQL. У...

я использую flink sql api, и у меня есть sql как Table result2 = tableEnv.sqlQuery("SELECT...

У меня есть таблица с данными, и мне нужно объединить два поля. Я написал запрос, но он не работает...

Я хочу присоединиться к трем или более потокам данных или таблицам по заданному ключу и общему окну

Я запускаю SQL с несколькими проекциями, каждый из которых отнимает много времени, например: SELECT...

Я выполняю эти задания Flink в кластере пряжи.Когда задание Flink не удается или я перезапускаю его...

У меня есть два потоковых источника nifi в Flink, мне нужно выполнить соединения на этих двух...

Я использую пряжу для выполнения заданий Flink.Для каждого задания Flink я создаю контрольную точку

Я пытаюсь работать с Флинком и Кассандрой. Обе эти среды очень параллельны, но мне сложно заставить...

Я пытаюсь написать пользовательскую скалярную функцию во Flink, которая принимает несколько...