Hi, I am reading data from Kafka into spark. It runs fine for sometime but then hangs forever with following output. I don't see and errors in logs. How do I debug this?
2015-12-01 06:04:30,697 [dag-scheduler-event-loop] INFO (Logging.scala:59) - Adding task set 19.0 with 4 tasks 2015-12-01 06:04:30,872 [pool-13-thread-1] INFO (Logging.scala:59) - Disconnected from Cassandra cluster: APG DEV Cluster 2015-12-01 06:04:35,060 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949875000 ms 2015-12-01 06:04:40,054 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949880000 ms 2015-12-01 06:04:45,034 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949885000 ms 2015-12-01 06:04:50,100 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949890000 ms 2015-12-01 06:04:55,064 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949895000 ms 2015-12-01 06:05:00,125 [JobGenerator] INFO (Logging.scala:59) - Added jobs for time 1448949900000 ms Thanks LCassa
