[FLINK-31174] [Doc] Inconsistent data format between flink-training-repo and learn-flink doc

• Type: Improvement
• Status: Open
• Priority: Not a Priority
• Resolution: Unresolved
• Affects Version/s: 1.16.1
• Component/s: Documentation / Training
• Labels: auto-deprioritized-minor pull-request-available
• Assignee: Unassigned
• Reporter: CHEN Zhongpu
• Created: 22/Feb/23 03:05
• Updated: 31/Aug/23 22:35

Description

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.

Interval rideInterval = new Interval(ride.startTime, ride.endTime); 

I think such inconsistency would puzzle new comers of Flink.

According to the mail list discussion, it is due to a new [pr|https://github.com/apache/flink-training/pull/36] and the doc forgets to update. 

Issue Links

• links to: GitHub Pull Request #22016
• links to: GitHub Pull Request # 22016