Some debug messages for cassandra

jayunit100 · Jan 25, 2015 · 61fd8c9 · 61fd8c9
1 parent aa0d6aa
commit 61fd8c9
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/scala/sparkapps/ctakes/CTakesTwitterStreamingApp.scala b/src/main/scala/sparkapps/ctakes/CTakesTwitterStreamingApp.scala
@@ -188,8 +188,11 @@ object Driver {
               Thread.sleep(1)
               transactions.foreach({
                 xN =>
+                  System.out.println("Running Cassandra Insert..." + xN)
+                  System.out.println("Note that this can fail if cassandra isnt working...")
                   val xNtxt=xN.toString+" "+xN.getText;
-                  session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")}
+                  session.executeAsync(s"INSERT INTO streaming_test.key_value (key, value) VALUES ('$xNtxt' , $x)")
+              }
               )
               true;
             }