aboutsummaryrefslogtreecommitdiff
path: root/external/kafka/src/test
Commit message (Expand)AuthorAgeFilesLines
* [SPARK-15085][STREAMING][KAFKA] Rename streaming-kafka artifactcody koeninger2016-05-119-1513/+0
* [SPARK-6005][TESTS] Fix flaky test: o.a.s.streaming.kafka.DirectKafkaStreamSu...Shixiong Zhu2016-05-101-6/+14
* [SPARK-14134][CORE] Change the package name used for shading classes.Marcelo Vanzin2016-04-061-1/+1
* [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-044-11/+63
* [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-12618][CORE][STREAMING][SQL] Clean up build warnings: 2.0.0 editionSean Owen2016-01-082-9/+6
* [SPARK-3873][TESTS] Import ordering fixes.Marcelo Vanzin2016-01-052-4/+3
* [SPARK-10547] [TEST] Streamline / improve style of Java API testsSean Owen2015-09-123-27/+28
* [SPARK-8978] [STREAMING] Implements the DirectKafkaRateControllerNilanjan Raychaudhuri2015-08-061-0/+89
* [SPARK-9534] [BUILD] Enable javac lint for scalac parity; fix a lot of build ...Sean Owen2015-08-041-1/+1
* [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-192-5/+22
* [SPARK-8389] [STREAMING] [KAFKA] Example of getting offset ranges out o…cody koeninger2015-06-191-2/+13
* [SPARK-8404] [STREAMING] [TESTS] Use thread-safe collections to make the test...zsxwing2015-06-174-19/+14
* [SPARK-2808] [STREAMING] [KAFKA] cleanup tests fromcody koeninger2015-06-072-7/+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-012-9/+26
* [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-098-308/+180
* [SPARK-6758]block the right jetty package in logWangTaoTheTonic2015-04-091-1/+1
* SPARK-6338 [CORE] Use standard temp dir mechanisms in tests to avoid orphane...Sean Owen2015-03-201-7/+3
* SPARK-6225 [CORE] [SQL] [STREAMING] Resolve most build warnings, 1.3.0 editionSean Owen2015-03-113-34/+22
* [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-112-29/+223
* [SPARK-4964][Streaming][Kafka] More updates to Exactly-once Kafka streamTathagata Das2015-02-098-140/+516
* [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-4159 [CORE] Maven build doesn't run JUnit test suitesSean Owen2015-01-061-3/+2
* [SPARK-4062][Streaming]Add ReliableKafkaReceiver in Spark Streaming Kafka con...jerryshao2014-11-143-117/+283
* [SPARK-3748] Log thread name in unit test logsReynold Xin2014-10-011-1/+1
* [SPARK-3615][Streaming]Fix Kafka unit test hard coded Zookeeper port issuejerryshao2014-09-242-14/+34
* [SPARK-1022][Streaming] Add Kafka real unit testjerryshao2014-08-052-35/+287
* SPARK-1798. Tests should clean up temp filesSean Owen2014-05-121-1/+1
* [SPARK-1332] Improve Spark Streaming's Network Receiver and InputDStream API ...Tathagata Das2014-04-212-7/+13
* Changed SparkConf to not be serializable. And also fixed unit-test log paths ...Tathagata Das2014-01-142-1/+2
* Removed XYZFunctions and added XYZUtils as a common Scala and Java interface ...Tathagata Das2014-01-072-12/+7
* Changed JavaStreamingContextWith*** to ***Function in streaming.api.java.*** ...Tathagata Das2014-01-061-8/+7
* Refactored kafka, flume, zeromq, mqtt as separate external projects, with the...Tathagata Das2013-12-303-0/+119
generated by cgit v1.2.3 (git 2.39.1) at 2024-07-30 02:05:08 +0000