diff options
author | guowei2 <guowei@growingio.com> | 2015-07-09 15:01:53 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-07-09 15:01:53 -0700 |
commit | 897700369f3aedf1a8fdb0984dd3d6d8e498e3af (patch) | |
tree | 73fdb9423967323d0c113029ef7e427237f96caf /external/kafka/src/main | |
parent | c9e2ef52bb54f35a904427389dc492d61f29b018 (diff) | |
download | spark-897700369f3aedf1a8fdb0984dd3d6d8e498e3af.tar.gz spark-897700369f3aedf1a8fdb0984dd3d6d8e498e3af.tar.bz2 spark-897700369f3aedf1a8fdb0984dd3d6d8e498e3af.zip |
[SPARK-8865] [STREAMING] FIX BUG: check key in kafka params
Author: guowei2 <guowei@growingio.com>
Closes #7254 from guowei2/spark-8865 and squashes the following commits:
48ca17a [guowei2] fix contains key
Diffstat (limited to 'external/kafka/src/main')
-rw-r--r-- | external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala index 3e6b937af5..8465432c58 100644 --- a/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala +++ b/external/kafka/src/main/scala/org/apache/spark/streaming/kafka/KafkaCluster.scala @@ -410,7 +410,7 @@ object KafkaCluster { } Seq("zookeeper.connect", "group.id").foreach { s => - if (!props.contains(s)) { + if (!props.containsKey(s)) { props.setProperty(s, "") } } |