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(); }