diff options
| author | Tathagata Das <tathagata.das1565@gmail.com> | 2015-02-17 22:44:16 -0800 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-02-17 22:44:16 -0800 |
| commit | 3912d332464dcd124c60b734724c34d9742466a4 (patch) | |
| tree | e9a4fc0b299717e916f0a1ba95027b60b7408e1d /sql | |
| parent | e50934f11e1e3ded21a631e5ab69db3c79467137 (diff) | |
| download | spark-3912d332464dcd124c60b734724c34d9742466a4.tar.gz spark-3912d332464dcd124c60b734724c34d9742466a4.tar.bz2 spark-3912d332464dcd124c60b734724c34d9742466a4.zip | |
[SPARK-5731][Streaming][Test] Fix incorrect test in DirectKafkaStreamSuite
The test was incorrect. Instead of counting the number of records, it counted the number of partitions of RDD generated by DStream. Which is not its intention. I will be testing this patch multiple times to understand its flakiness.
PS: This was caused by my refactoring in https://github.com/apache/spark/pull/4384/
koeninger check it out.
Author: Tathagata Das <tathagata.das1565@gmail.com>
Closes #4597 from tdas/kafka-flaky-test and squashes the following commits:
d236235 [Tathagata Das] Unignored last test.
e9a1820 [Tathagata Das] fix test
Diffstat (limited to 'sql')
0 files changed, 0 insertions, 0 deletions