Jungtaek Lim (HeartSaVioR) 85e95b7d27 [SPARK-28142][SS] Use CaseInsensitiveStringMap for KafkaContinuousStream ... ## What changes were proposed in this pull request? This patch addresses a missing spot which Map should be passed as CaseInsensitiveStringMap - KafkaContinuousStream seems to be only the missed one. Before this fix, it has a relevant bug where `pollTimeoutMs` is always set to default value, as the value of `KafkaSourceProvider.CONSUMER_POLL_TIMEOUT` is `kafkaConsumer.pollTimeoutMs` which key-lowercased map has been provided as `sourceOptions`. ## How was this patch tested? N/A. Closes #24942 from HeartSaVioR/MINOR-use-case-insensitive-map-for-kafka-continuous-source. Authored-by: Jungtaek Lim (HeartSaVioR) <kabhwan@gmail.com> Signed-off-by: HyukjinKwon <gurwls223@apache.org>		2019-06-24 22:20:32 +09:00
..
avro	[SPARK-27798][SQL] from_avro shouldn't produces same value when converted to local relation	2019-06-07 13:47:36 -07:00
docker	[SPARK-27794][R][DOCS] Use https URL for CRAN repo	2019-05-22 14:28:21 -07:00
docker-integration-tests	[SPARK-27596][SQL] The JDBC 'query' option doesn't work for Oracle database	2019-05-05 21:52:23 -07:00
kafka-0-10	[SPARK-27294][SS] Add multi-cluster Kafka delegation token	2019-05-07 11:40:43 -07:00
kafka-0-10-assembly	[SPARK-25956] Make Scala 2.12 as default Scala version in Spark 3.0	2018-11-14 16:22:23 -08:00
kafka-0-10-sql	[SPARK-28142][SS] Use CaseInsensitiveStringMap for KafkaContinuousStream	2019-06-24 22:20:32 +09:00
kafka-0-10-token-provider	[SPARK-27748][SS] Kafka consumer/producer password/token redaction.	2019-06-03 15:43:08 -07:00
kinesis-asl	[SPARK-27610][YARN] Shade netty native libraries	2019-05-07 10:47:36 -07:00
kinesis-asl-assembly	[SPARK-25956] Make Scala 2.12 as default Scala version in Spark 3.0	2018-11-14 16:22:23 -08:00
spark-ganglia-lgpl	[SPARK-25956] Make Scala 2.12 as default Scala version in Spark 3.0	2018-11-14 16:22:23 -08:00