aboutsummaryrefslogtreecommitdiff
path: root/external/kafka/src/test/scala
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-115-1019/+0
* [SPARK-6005][TESTS] Fix flaky test: o.a.s.streaming.kafka.DirectKafkaStreamSu...Shixiong Zhu2016-05-101-6/+14
* [SPARK-13928] Move org.apache.spark.Logging into org.apache.spark.internal.Lo...Wenchen Fan2016-03-171-1/+2
* [SPARK-12073][STREAMING] backpressure rate controller consumes events prefere...Jason White2016-03-041-8/+60
* [SPARK-13186][STREAMING] migrate away from SynchronizedMapHuaxin Gao2016-02-221-6/+7
* [SPARK-13165][STREAMING] Replace deprecated synchronizedBuffer in streamingHolden Karau2016-02-091-22/+21
* [SPARK-12692][BUILD][STREAMING] Scala style: Fix the style violation (Space b...Kousuke Saruta2016-01-111-1/+1
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-052-4/+3
* [SPARK-8978] [STREAMING] Implements the DirectKafkaRateControllerNilanjan Raychaudhuri2015-08-061-0/+89
* [SPARK-7977] [BUILD] Disallowing printlnJonathan Alter2015-07-101-1/+1
* [SPARK-8127] [STREAMING] [KAFKA] KafkaRDD optimize count() take() isEmpty()cody koeninger2015-06-191-3/+23
* [SPARK-8390] [STREAMING] [KAFKA] fix docs related to HasOffsetRangescody koeninger2015-06-191-4/+12
* [SPARK-8404] [STREAMING] [TESTS] Use thread-safe collections to make the test...zsxwing2015-06-172-11/+10
* [SPARK-2808] [STREAMING] [KAFKA] cleanup tests fromcody koeninger2015-06-071-4/+0
* [SPARK-7558] Demarcate tests in unit-tests.logAndrew Or2015-05-295-13/+15
* [SPARK-7929] Turn whitespace checker on for more token types.Reynold Xin2015-05-281-1/+1
* [SPARK-7113] [STREAMING] Support input information reporting for Direct Kafka...jerryshao2015-05-051-1/+58
* [SPARK-2808][Streaming][Kafka] update kafka to 0.8.2cody koeninger2015-05-011-9/+23
* [SPARK-6431][Streaming][Kafka] Error message for partition metadata requ...cody koeninger2015-04-121-0/+3
* [SPARK-6211][Streaming] Add Python Kafka API unit testjerryshao2015-04-095-266/+132
* SPARK-6338 [CORE] Use standard temp dir mechanisms in tests to avoid orphane...Sean Owen2015-03-201-7/+3
* [SPARK-5731][Streaming][Test] Fix incorrect test in DirectKafkaStreamSuiteTathagata Das2015-02-171-12/+16
* [HOTFIX] Ignore DirectKafkaStreamSuite.Reynold Xin2015-02-131-4/+4
* [SPARK-4964] [Streaming] refactor createRDD to take leaders via map instead o...cody koeninger2015-02-111-29/+67
* [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka streamTathagata Das2015-02-096-138/+354
* [SPARK-4964] [Streaming] Exactly-once semantics for Kafkacody koeninger2015-02-044-4/+268
* [SPARK-5153][Streaming][Test] Increased timeout to deal with flaky KafkaStrea...Tathagata Das2015-02-031-1/+1
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-142-99/+257
* [SPARK-3615][Streaming]Fix Kafka unit test hard coded Zookeeper port issuejerryshao2014-09-241-13/+33
* [SPARK-1022][Streaming] Add Kafka real unit testjerryshao2014-08-051-16/+181
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-211-3/+7
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-141-0/+1
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-071-4/+4
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-301-0/+39
generated by cgit v1.2.3 (git 2.39.1) at 2024-09-19 15:53:28 +0000