我觉得原因应该是 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/
>

回复