apache-flink

Вопрос или проблема Я работаю над переводом нашего кода с одиночной обработки на обработку в flink-кластере, чтобы сделать его более параллельным. Мы используем версию flink-1.5. Конвейер работает нормально в течение нескольких минут, а затем выдает исключение.

Вопрос или проблема Я использую Hudi с Flink. У меня есть таблица MySQL с именем stu4. Без каталога всё работает. Но с каталогом DFS я не могу считать данные из исходной таблицы. таблица в Hudi: create table stu4( id bigint not null, name string, school

Вопрос или проблема У меня есть работа Flink, которая потребляет данные из Kafka, и задача стабильно работает, когда пропускная способность Kafka составляет <= 1000 сообщений в секунду. Когда пропускная способность Kafka превышает 1000, например, при

Вопрос или проблема Я столкнулся с проблемой при настройке UDAF с использованием Flink (версия 1.20). Я хотел реализовать UDAF, который рассчитывает медиану, и использовал следующие два метода: public class MedianUDAF2 extends AggregateFunction<