Details
-
Bug
-
Status: Resolved
-
Minor
-
Resolution: Fixed
-
0.8.1, 0.9.0
-
None
Description
Since SparkListener events are now processed asynchronously from the SparkListenerBus eventQueue, the jobLogger conditions checked in the "inner variables" and "interface functions" tests of the JobLoggerSuite are not guaranteed to be satisfied just because rdd.reduceByKey(+).collect() has returned. This leads to infrequent failures of these tests when we lose the race.