Update StreamAppForeachSink.java

abulbasar · web-flow · commit 50b8933a9688 · 2018-01-12T14:44:39.000+05:30
diff --git a/src/main/java/com/example/StreamAppForeachSink.java b/src/main/java/com/example/StreamAppForeachSink.java
@@ -22,8 +22,7 @@ public class StreamAppForeachSink{
 
 	public static void main(String[] args) throws AnalysisException,
 			StreamingQueryException{
-		
-		String outPath = args[0];
+				
 		String checkpointDir = args[1];
 		
 		ObjectMapper mapper = new ObjectMapper();

-Original file line number
+Diff line change
 publicstaticvoidmain(String[] args) throwsAnalysisException,
 StreamingQueryException{
+-
 -StringoutPath = args[0];
++
 StringcheckpointDir = args[1];
 ObjectMappermapper = newObjectMapper();