I figured out a way to solve this by writing my own code, but would love to know if there are better - more efficient solutions. Here's the answer - https://stackoverflow.com/questions/50697296/how-to-read-from-cassandra-using-apache-flink/50721953#50721953
@Chesnay I've been wondering about this. Where exactly do you close the connection in a Streaming job? -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
