[flink-training] 02/02: [hotfix] collect rather than collectWithTimestamp

[nkruber]

This is an automated email from the ASF dual-hosted git repository.

nkruber pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink-training.git

commit 1b6720707c6f97b4dc502b58ec8229fac0c4bee5
Author: David Anderson <da...@alpinegizmo.com>
AuthorDate: Wed Sep 1 10:19:28 2021 -0600

    [hotfix] collect rather than collectWithTimestamp
---
 .../flink/training/exercises/common/sources/TaxiRideGenerator.java    | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java
 
b/common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java
index b3776d9..975ff2b 100644
--- 
a/common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java
+++ 
b/common/src/main/java/org/apache/flink/training/exercises/common/sources/TaxiRideGenerator.java
@@ -69,9 +69,7 @@ public class TaxiRideGenerator implements 
SourceFunction<TaxiRide> {
 
             // then emit the new START events (out-of-order)
             java.util.Collections.shuffle(startEvents, new Random(id));
-            startEvents
-                    .iterator()
-                    .forEachRemaining(r -> ctx.collectWithTimestamp(r, 
r.getEventTimeMillis()));
+            startEvents.iterator().forEachRemaining(r -> ctx.collect(r));
 
             // prepare for the next batch
             id += BATCH_SIZE;