SPARK-2034. KafkaInputDStream doesn't close resources and may prevent JVM shutdown#980

Closed

srowen wants to merge 2 commits intoapache:masterfrom

srowen:SPARK-2034

Commits on Jun 5, 2014

Close ConsumerConnector in onStop; shutdown() the local Executor that is created so that its threads stop when done; close the Zookeeper client even on exception; fix a few typos; log exceptions th…
srowen
committed
Restore ClassTag to private class because MIMA flags it; is the shadowing intended?
srowen
committed