Hi there This was exactly the problem.
Dian figured out the reason: I needed to rename file org.apache.flink.table.factories.DynamicTableFactory to org.apache.flink.table.factories.Factory And then needed to added the format tag for the flink sql. Blog will drop in 1 hour on medium and LinkedIn, Will tag Apache Flink group. Sent from my iPhone George Leonard __________________________ george...@gmail.com +27 82 655 2466 > On 17 Jun 2025, at 03:34, Xuyang <xyzhong...@163.com> wrote: > > factories.Factory