回复: Table API connect method timestamp watermark assignment problem

Thanks a lot, hope it will be fixed soon! 发件人: Jark Wu 发送时间: 2020年3月3日 11:25 收件人: Lu Weizheng 抄送: user@flink.apache.org 主题: Re: Table API connect method timestamp watermark assignment problem Hi Lu, DDL and Schema descriptor do not share the same code path. I

Re: Table API connect method timestamp watermark assignment problem

Hi Lu, DDL and Schema descriptor do not share the same code path. I guess the reason why Schema descriptor doesn't work is because of FLINK-16160. We will fix that in the next minor release. Please use DDL to define watermark which is also the suggested way to do that. The current Schema descripto

Table API connect method timestamp watermark assignment problem

Hey guys, I am using Flink Table API recently. I want to use EventTime and use a Kakfa Table Connector. I think in my code Flink cannot recognize event time timestamp field. Here is my code : public static void main(String[] args) throws Exception { EnvironmentSettings fsSettings = En