diff options
| author | zsxwing <zsxwing@gmail.com> | 2015-05-05 02:15:39 -0700 |
|---|---|---|
| committer | Tathagata Das <tathagata.das1565@gmail.com> | 2015-05-05 02:15:39 -0700 |
| commit | 4d29867ede9a87b160c3d715c1fb02067feef449 (patch) | |
| tree | 9132f0dfe71737c4f964798e4d7e5f865b7545f2 /docs/running-on-yarn.md | |
| parent | 8436f7e98e674020007a9175973c6a1095b6774f (diff) | |
| download | spark-4d29867ede9a87b160c3d715c1fb02067feef449.tar.gz spark-4d29867ede9a87b160c3d715c1fb02067feef449.tar.bz2 spark-4d29867ede9a87b160c3d715c1fb02067feef449.zip | |
[SPARK-7341] [STREAMING] [TESTS] Fix the flaky test: org.apache.spark.stre...
...aming.InputStreamsSuite.socket input stream
Remove non-deterministic "Thread.sleep" and use deterministic strategies to fix the flaky failure: https://amplab.cs.berkeley.edu/jenkins/job/Spark-Master-Maven-pre-YARN/hadoop.version=1.0.4,label=centos/2127/testReport/junit/org.apache.spark.streaming/InputStreamsSuite/socket_input_stream/
Author: zsxwing <zsxwing@gmail.com>
Closes #5891 from zsxwing/SPARK-7341 and squashes the following commits:
611157a [zsxwing] Add wait methods to BatchCounter and use BatchCounter in InputStreamsSuite
014b58f [zsxwing] Use withXXX to clean up the resources
c9bf746 [zsxwing] Move 'waitForStart' into the 'start' method and fix the code style
9d0de6d [zsxwing] [SPARK-7341][Streaming][Tests] Fix the flaky test: org.apache.spark.streaming.InputStreamsSuite.socket input stream
Diffstat (limited to 'docs/running-on-yarn.md')
0 files changed, 0 insertions, 0 deletions