Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-31174

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

    XMLWordPrintableJSON

Details

    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. 

      Attachments

        Activity

          People

            Unassigned Unassigned
            zhongpu314 CHEN Zhongpu
            Votes:
            0 Vote for this issue
            Watchers:
            1 Start watching this issue

            Dates

              Created:
              Updated: