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:27 -0800 |
| commit | f8f9a64ebdfe581d62773a6276f66c75d4ba43e1 (patch) | |
| tree | 623ac9e12aebde4572dfb3fad300fd70177efa7e /sql | |
| parent | 6e82c46bf6cdfd227b5680f114e029219204e641 (diff) | |
| download | spark-f8f9a64ebdfe581d62773a6276f66c75d4ba43e1.tar.gz spark-f8f9a64ebdfe581d62773a6276f66c75d4ba43e1.tar.bz2 spark-f8f9a64ebdfe581d62773a6276f66c75d4ba43e1.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
(cherry picked from commit 3912d332464dcd124c60b734724c34d9742466a4)
Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>
Diffstat (limited to 'sql')
0 files changed, 0 insertions, 0 deletions