zsxwing 0634510686 [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 (cherry picked from commit 4d29867ede) Signed-off-by: Tathagata Das <tathagata.das1565@gmail.com>		2015-05-05 02:15:48 -07:00
..
main	[SPARK-7113] [STREAMING] Support input information reporting for Direct Kafka stream	2015-05-05 02:06:58 -07:00
test	[SPARK-7341] [STREAMING] [TESTS] Fix the flaky test: org.apache.spark.stre...	2015-05-05 02:15:48 -07:00