diff options
| author | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:34:56 +0530 |
|---|---|---|
| committer | Prashant Sharma <prashant.s@imaginea.com> | 2013-07-16 14:34:56 +0530 |
| commit | ff14f38f3dce314eb1afb876e79cbab6b1c252b8 (patch) | |
| tree | 31f14cf98377f2d05894636fab4447020b98b7a7 /streaming | |
| parent | 63addd93a8337f5181c0e7d64c86393cb519c661 (diff) | |
| download | spark-ff14f38f3dce314eb1afb876e79cbab6b1c252b8.tar.gz spark-ff14f38f3dce314eb1afb876e79cbab6b1c252b8.tar.bz2 spark-ff14f38f3dce314eb1afb876e79cbab6b1c252b8.zip | |
Fixed warning Throwables
Diffstat (limited to 'streaming')
| -rw-r--r-- | streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala index ba1312cbe8..8b23642e4a 100644 --- a/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala +++ b/streaming/src/main/scala/spark/streaming/dstream/KafkaInputDStream.scala @@ -118,7 +118,7 @@ class KafkaReceiver[T: ClassTag, D <: Decoder[_]: Manifest]( zk.deleteRecursive(dir) zk.close() } catch { - case _ => // swallow + case _ : Throwable => // swallow } } } |