diff options
author | cody koeninger <cody@koeninger.org> | 2016-07-06 16:21:41 -0700 |
---|---|---|
committer | Tathagata Das <tathagata.das1565@gmail.com> | 2016-07-06 16:21:41 -0700 |
commit | b8ebf63c1e1fa1ab53ea760fa293051c08ce5f59 (patch) | |
tree | 22d63233b9b7f6c9e0d0e7a43dd8b5826561a5f6 /project | |
parent | 8e3e4ed6c090d18675d49eec46b3ee572457db95 (diff) | |
download | spark-b8ebf63c1e1fa1ab53ea760fa293051c08ce5f59.tar.gz spark-b8ebf63c1e1fa1ab53ea760fa293051c08ce5f59.tar.bz2 spark-b8ebf63c1e1fa1ab53ea760fa293051c08ce5f59.zip |
[SPARK-16212][STREAMING][KAFKA] apply test tweaks from 0-10 to 0-8 as well
## What changes were proposed in this pull request?
Bring the kafka-0-8 subproject up to date with some test modifications from development on 0-10.
Main changes are
- eliminating waits on concurrent queue in favor of an assert on received results,
- atomics instead of volatile (although this probably doesn't matter)
- increasing uniqueness of topic names
## How was this patch tested?
Unit tests
Author: cody koeninger <cody@koeninger.org>
Closes #14073 from koeninger/kafka-0-8-test-direct-cleanup.
Diffstat (limited to 'project')
0 files changed, 0 insertions, 0 deletions