I have made a pull request (https://github.com/apache/flink/pull/21989) to resolve this issue. Can anybody review it?
On 2023/02/22 02:40:23 yuxia wrote: > 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" <ch...@gmail.com> > 收件人: "User" <us...@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 > >
