Removing offset management code that is non-existent in kafka 0.7.0+
StateDStream changes to give updateStateByKey consistent behavior
Add spark.executor.memory to differentiate executor memory from spark-shell memory.
Merge branch 'streaming' into sm-updateStateByKey
kafka jar wasn't being included by run script
further KafkaInputDStream cleanup (removing unused and commented out code relating to offset management)
kafkaStream API cleanup. A quorum of zookeepers can now be specified
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
Plug in actor as stream receiver API
adding updateStateByKey object lifecycle test
Splitting StreamingContext.queueStream into two methods
Changed method name of createReceiver to getReceiver as it is not intended to be a factory.
add ensime
actor as receiver
Refactored DStreamCheckpointData.
Call removeJob instead of killing the cluster.
Handle Master telling the Worker to kill an already-dead executor.
Restore SPARK_MEM in executorEnvs.
Fix SPARK_MEM in ExecutorRunner.
Don't bother creating an exception.