我觉得原因应该是 postgres 中在建表的时候,默认会把字段名转成小写的,所以你在 Flink SQL 这边也要声明成小写的。 你可以在postgres 中看一下表的字段信息。
Best, Jark On Fri, 7 Aug 2020 at 13:48, lgs <[email protected]> wrote: > schema是public > 问题在这里:ERROR: column "recordid" of relation "alarm_history_data" does not > exist > > 数据库表里面是“recordId”,这里的提示变成了“recordid” > > > > > -- > Sent from: http://apache-flink.147419.n8.nabble.com/ >
