При использовании Flink Table SQL в моем проекте я обнаружил, что если в моем SQL-запросе есть какое-либо предложение GROUP BY, размер контрольной точки значительно возрастет. Например, INSERT INTO COMPANY_POST_DAY SELECT ...

У меня вышел из строя DataStream < Event > что я хочу отсортировать так, чтобы события были упорядочены по их временным меткам. Я упростил свой вариант использования до того, что мой класс Event имеет только ...

Я успешно использовал JsonRowSerializationSchema из артефакта flink-json для создания TableSink < Row > и вывести JSON из SQL, используя ROW. Он отлично работает для передачи плоских данных: INSERT ...