Fixed unit tests for work with the new version of Cassandra, after the
introduction of Apache Flume