Re: flink 1.11 createTemporaryTable 指定 rowtime 字段报 Field null does not exist 错误

Mon, 13 Jul 2020 19:22:36 -0700 

这可能是 connect API  的某个 bug 吧。 建议先用 DDL 。

Best,
Jark

On Tue, 14 Jul 2020 at 08:54, Hito Zhu <[email protected]> wrote:

> rowtime 定义如下，我发现 SchemaValidator#deriveFieldMapping 方法给移除了。
> Rowtime rowtime = new Rowtime()
>                 .timestampsFromField("searchTime")
>                 .watermarksPeriodicBounded(5 * 1000);
>
>
>
> --
> Sent from: http://apache-flink.147419.n8.nabble.com/
>

回复