Seems in this pr[1], startTime and endTIme have been replaced with a single eveentTime, but the doc forget to update. Coud you please help create a JIRA[2] for it? And if you're interested to fix it, weclome to contribute.
[1] https://github.com/apache/flink-training/pull/36 [2] https://issues.apache.org/jira/projects/FLINK/issues Best regards, Yuxia 发件人: "Zhongpu Chen" <chenlov...@gmail.com> 收件人: "User" <user@flink.apache.org> 发送时间: 星期二, 2023年 2 月 21日 下午 8:49:13 主题: Inconsistent data format of flink-training-repo and learn-flink doc Hi, The data format specified in flink-training-repo ( [ https://github.com/apache/flink-training/tree/release-1.16 | https://github.com/apache/flink-training/tree/release-1.16 ] ) shows that a TaixRide is either a start or an end one with the eventTime. However, the Java code in "Data Pipelines & ETL" ( [ https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/learn-flink/etl/ | https://nightlies.apache.org/flink/flink-docs-release-1.16/docs/learn-flink/etl/ ] ) tried to get both "startTime" and "endTime". But in fact, those are not defined in flink-training-repo. ```java Interval rideInterval = new Interval ( ride . startTime , ride . endTime ); ``` I think such inconsistency would puzzle new comers of Flink. -- Zhongpu Chen
