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

Mon, 13 Jul 2020 17:55:11 -0700 

rowtime 定义如下，我发现 SchemaValidator#deriveFieldMapping 方法给移除了。
Rowtime rowtime = new Rowtime()
                .timestampsFromField("searchTime")
                .watermarksPeriodicBounded(5 * 1000);



--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复