You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user@flink.apache.org by Zhongpu Chen <ch...@gmail.com> on 2023/02/21 12:49:13 UTC

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) 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/)
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

Re: Inconsistent data format of flink-training-repo and learn-flink doc

Posted by yuxia <lu...@alumni.sjtu.edu.cn>.

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