From 74f57b2bf99508edbab6aa1507bd0e86027ce5ba Mon Sep 17 00:00:00 2001
From: Viren Nadkarni <viren.nadkarni@gmail.com>
Date: Mon, 3 Feb 2025 18:07:15 +0530
Subject: [PATCH] Add logging with SLF4J

---
 .../java/com/amazonaws/services/msf/StreamingJob.java     | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/java/Printer/src/main/java/com/amazonaws/services/msf/StreamingJob.java b/java/Printer/src/main/java/com/amazonaws/services/msf/StreamingJob.java
index d29cba8..e3e632b 100644
--- a/java/Printer/src/main/java/com/amazonaws/services/msf/StreamingJob.java
+++ b/java/Printer/src/main/java/com/amazonaws/services/msf/StreamingJob.java
@@ -9,8 +9,8 @@
 import org.apache.flink.streaming.api.datastream.DataStream;
 import org.apache.flink.streaming.api.environment.LocalStreamEnvironment;
 import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
-import org.apache.logging.log4j.LogManager;
-import org.apache.logging.log4j.Logger;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 import java.io.IOException;
 import java.util.Map;
@@ -18,7 +18,7 @@
 
 public class StreamingJob {
 
-    private static final Logger LOGGER = LogManager.getLogger(StreamingJob.class);
+    private static final Logger LOGGER = LoggerFactory.getLogger(StreamingJob.class);
 
     // Create ObjectMapper instance to serialise POJOs into JSONs
     private static final ObjectMapper OBJECT_MAPPER = new ObjectMapper();
@@ -55,6 +55,8 @@ public static void main(String[] args) throws Exception {
         DataStream<StockPrice> kinesis = env.fromSource(
                 source, WatermarkStrategy.noWatermarks(), "data-generator").setParallelism(1);
 
+        LOGGER.info("Executing printer job...");
+
         // Print
         kinesis.print();