From d5d7d0e676bfdd960c06cc4bd076b8048251400d Mon Sep 17 00:00:00 2001
From: Julio Biason <julio.biason@azion.com>
Date: Fri, 3 Aug 2018 13:36:55 -0300
Subject: [PATCH] updated some words

---
 .../java/net/juliobiason/flink/SocketWindowWordCount.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/main/java/net/juliobiason/flink/SocketWindowWordCount.java b/src/main/java/net/juliobiason/flink/SocketWindowWordCount.java
index da99f75..5119670 100644
--- a/src/main/java/net/juliobiason/flink/SocketWindowWordCount.java
+++ b/src/main/java/net/juliobiason/flink/SocketWindowWordCount.java
@@ -102,7 +102,7 @@ public class SocketWindowWordCount {
 					if (extractedTimestamp > currentMaxTimestamp) {
 						currentMaxTimestamp = extractedTimestamp;
 						watermarkTime = currentMaxTimestamp - Time.seconds(10).toMilliseconds();
-						displayStep("TIMESTAMP", "moved to " + (watermarkTime / 1000));
+						displayStep("WATERMARK", "moved to " + (watermarkTime / 1000));
 						result = new Watermark(watermarkTime);
 					}
 					return result;
@@ -167,7 +167,7 @@ public class SocketWindowWordCount {
 								WordEvent result = new WordEvent(window.getStart(),
 											word.getWord(),
 											word.getCount());
-								displayStep("MOVE", word + " to " + (window.getStart() / 1000) + ", now " + result);
+								displayStep("FIRING", word + " to " + (window.getStart() / 1000) + ", now " + result);
 								out.collect(result);
 							}
 						}