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 | |
| 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')
| -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, "") } } |