From eacab1a8b11a002a6728b16e9955e8dbaadb4bca Mon Sep 17 00:00:00 2001 From: LaviniaGherasim Date: Tue, 2 Apr 2024 17:59:56 +0300 Subject: [PATCH] test access --- .../training/exercises/ridecleansing/RideCleansingExercise.java | 1 + 1 file changed, 1 insertion(+) diff --git a/ride-cleansing/src/main/java/org/apache/flink/training/exercises/ridecleansing/RideCleansingExercise.java b/ride-cleansing/src/main/java/org/apache/flink/training/exercises/ridecleansing/RideCleansingExercise.java index 1f07312f..44a28c48 100644 --- a/ride-cleansing/src/main/java/org/apache/flink/training/exercises/ridecleansing/RideCleansingExercise.java +++ b/ride-cleansing/src/main/java/org/apache/flink/training/exercises/ridecleansing/RideCleansingExercise.java @@ -55,6 +55,7 @@ public static void main(String[] args) throws Exception { RideCleansingExercise job = new RideCleansingExercise(new TaxiRideGenerator(), new PrintSinkFunction<>()); + System.out.println("Lavinia Test"); job.execute(); }