Updated for Spark Flume event processing test.