Commit message (Expand) | Author | Age | Files | Lines | |
---|---|---|---|---|---|
* | [SPARK-17534][TESTS] Increase timeouts for DirectKafkaStreamSuite tests | Adam Roberts | 2016-09-16 | 1 | -4/+4 |
* | [SPARK-16779][TRIVIAL] Avoid using postfix operators where they do not add mu... | Holden Karau | 2016-08-08 | 1 | -2/+0 |
* | [SPARK-16776][STREAMING] Replace deprecated API in KafkaTestUtils for 0.10.0. | hyukjinkwon | 2016-08-01 | 1 | -8/+12 |
* | [TEST][STREAMING] Fix flaky Kafka rate controlling test | Tathagata Das | 2016-07-26 | 1 | -5/+4 |
* | [SPARK-13569][STREAMING][KAFKA] pattern based topic subscription | cody koeninger | 2016-07-08 | 3 | -9/+258 |
* | [SPARK-12177][STREAMING][KAFKA] limit api surface area | cody koeninger | 2016-07-01 | 13 | -193/+222 |
* | [SPARK-12177][TEST] Removed test to avoid compilation issue in scala 2.10 | Tathagata Das | 2016-06-30 | 1 | -4/+4 |
* | [SPARK-12177][STREAMING][KAFKA] Update KafkaDStreams to new Kafka 0.10 Consum... | cody koeninger | 2016-06-29 | 18 | -0/+3077 |