diff options
| author | jerryshao <saisai.shao@intel.com> | 2014-08-05 10:40:28 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2014-08-05 10:40:28 -0700 |
| commit | e87075df977a539e4a1684045a7bd66c36285174 (patch) | |
| tree | 71bcffa06e19fa2f6bfc4764f8d567c949753d8f /docs/running-on-yarn.md | |
| parent | 184048f80b6fa160c89d5bb47b937a0a89534a95 (diff) | |
| download | spark-e87075df977a539e4a1684045a7bd66c36285174.tar.gz spark-e87075df977a539e4a1684045a7bd66c36285174.tar.bz2 spark-e87075df977a539e4a1684045a7bd66c36285174.zip | |
[SPARK-1022][Streaming] Add Kafka real unit test
This PR is a updated version of (https://github.com/apache/spark/pull/557) to actually test sending and receiving data through Kafka, and fix previous flaky issues.
@tdas, would you mind reviewing this PR? Thanks a lot.
Author: jerryshao <saisai.shao@intel.com>
Closes #1751 from jerryshao/kafka-unit-test and squashes the following commits:
b6a505f [jerryshao] code refactor according to comments
5222330 [jerryshao] Change JavaKafkaStreamSuite to better test it
5525f10 [jerryshao] Fix flaky issue of Kafka real unit test
4559310 [jerryshao] Minor changes for Kafka unit test
860f649 [jerryshao] Minor style changes, and tests ignored due to flakiness
796d4ca [jerryshao] Add real Kafka streaming test
Diffstat (limited to 'docs/running-on-yarn.md')
0 files changed, 0 insertions, 0 deletions