diff options
| author | Shixiong Zhu <shixiong@databricks.com> | 2016-05-24 22:01:40 -0700 |
|---|---|---|
| committer | Shixiong Zhu <shixiong@databricks.com> | 2016-05-24 22:01:40 -0700 |
| commit | c9c1c0e54d34773ac2cf5457fe5925559ece36c7 (patch) | |
| tree | ebafa9efe64f0917fae0e984da6966e850db03ee /docs | |
| parent | 50b660d725269dc0c11e0d350ddd7fc8b19539a0 (diff) | |
| download | spark-c9c1c0e54d34773ac2cf5457fe5925559ece36c7.tar.gz spark-c9c1c0e54d34773ac2cf5457fe5925559ece36c7.tar.bz2 spark-c9c1c0e54d34773ac2cf5457fe5925559ece36c7.zip | |
[SPARK-15508][STREAMING][TESTS] Fix flaky test: JavaKafkaStreamSuite.testKafkaStream
## What changes were proposed in this pull request?
`JavaKafkaStreamSuite.testKafkaStream` assumes when `sent.size == result.size`, the contents of `sent` and `result` should be same. However, that's not true. The content of `result` may not be the final content.
This PR modified the test to always retry the assertions even if the contents of `sent` and `result` are not same.
Here is the failure in Jenkins: http://spark-tests.appspot.com/tests/org.apache.spark.streaming.kafka.JavaKafkaStreamSuite/testKafkaStream
## How was this patch tested?
Jenkins unit tests.
Author: Shixiong Zhu <shixiong@databricks.com>
Closes #13281 from zsxwing/flaky-kafka-test.
Diffstat (limited to 'docs')
0 files changed, 0 insertions, 0 deletions