<p>JObject(List((Event,JString(SparkListenerTaskEnd)), (Stage ID,JInt(0)), (Stage Attempt ID,JInt(0)), (Task Type,JString(ResultTask)), (Task End Reason,JObject(List((Reason,JString(ExecutorLostFailure)), (Executor ID,JString(0)), (Exit Caused By App,JBool(true)), (Loss Reason,JString(Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.))))), (Task Info,JObject(List((Task ID,JInt(0)), (Index,JInt(0)), (Attempt,JInt(0)), (Launch Time,JInt(1452195195730)), (Executor ID,JString(0)), (Host,JString(localhost)), (Locality,JString(PROCESS_LOCAL)), (Speculative,JBool(false)), (Getting Result Time,JInt(0)), (Finish Time,JInt(1452195196589)), (Failed,JBool(true)), (Accumulables,JArray(List()))))), (Task Metrics,JNothing))) did not equal JObject(List((Event,JString(SparkListenerTaskEnd)), (Stage ID,JInt(0)), (Stage Attempt ID,JInt(0)), (Task Type,JString(ResultTask)), (Task End Reason,JObject(List((Reason,JString(ExecutorLostFailure)), (Executor ID,JString(0)), (Exit Caused By App,JBool(true)), (Loss Reason,JString(Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.))))), (Task Info,JObject(List((Task ID,JInt(0)), (Index,JInt(0)), (Attempt,JInt(0)), (Launch Time,JInt(1452195195730)), (Executor ID,JString(0)), (Host,JString(localhost)), (Locality,JString(PROCESS_LOCAL)), (Speculative,JBool(false)), (Getting Result Time,JInt(0)), (Finish Time,JInt(1452195196589)), (Failed,JBool(true)), (Accumulables,JArray(List()))))), (Task Metrics,JObject(List((Host Name,JString(null)), (Executor Deserialize Time,JInt(0)), (Executor Run Time,JInt(0)), (Result Size,JInt(0)), (JVM GC Time,JInt(0)), (Result Serialization Time,JInt(0)), (Memory Bytes Spilled,JInt(0)), (Disk Bytes Spilled,JInt(0)), (Shuffle Read Metrics,JNothing), (Shuffle Write Metrics,JNothing), (Input Metrics,JNothing), (Output Metrics,JNothing), (Updated Blocks,JNothing))))))</p>


<pre><code>
      org.scalatest.exceptions.TestFailedException: JObject(List((Event,JString(SparkListenerTaskEnd)), (Stage ID,JInt(0)), (Stage Attempt ID,JInt(0)), (Task Type,JString(ResultTask)), (Task End Reason,JObject(List((Reason,JString(ExecutorLostFailure)), (Executor ID,JString(0)), (Exit Caused By App,JBool(true)), (Loss Reason,JString(Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.))))), (Task Info,JObject(List((Task ID,JInt(0)), (Index,JInt(0)), (Attempt,JInt(0)), (Launch Time,JInt(1452195195730)), (Executor ID,JString(0)), (Host,JString(localhost)), (Locality,JString(PROCESS_LOCAL)), (Speculative,JBool(false)), (Getting Result Time,JInt(0)), (Finish Time,JInt(1452195196589)), (Failed,JBool(true)), (Accumulables,JArray(List()))))), (Task Metrics,JNothing))) did not equal JObject(List((Event,JString(SparkListenerTaskEnd)), (Stage ID,JInt(0)), (Stage Attempt ID,JInt(0)), (Task Type,JString(ResultTask)), (Task End Reason,JObject(List((Reason,JString(ExecutorLostFailure)), (Executor ID,JString(0)), (Exit Caused By App,JBool(true)), (Loss Reason,JString(Remote RPC client disassociated. Likely due to containers exceeding thresholds, or network issues. Check driver logs for WARN messages.))))), (Task Info,JObject(List((Task ID,JInt(0)), (Index,JInt(0)), (Attempt,JInt(0)), (Launch Time,JInt(1452195195730)), (Executor ID,JString(0)), (Host,JString(localhost)), (Locality,JString(PROCESS_LOCAL)), (Speculative,JBool(false)), (Getting Result Time,JInt(0)), (Finish Time,JInt(1452195196589)), (Failed,JBool(true)), (Accumulables,JArray(List()))))), (Task Metrics,JObject(List((Host Name,JString(null)), (Executor Deserialize Time,JInt(0)), (Executor Run Time,JInt(0)), (Result Size,JInt(0)), (JVM GC Time,JInt(0)), (Result Serialization Time,JInt(0)), (Memory Bytes Spilled,JInt(0)), (Disk Bytes Spilled,JInt(0)), (Shuffle Read Metrics,JNothing), (Shuffle Write Metrics,JNothing), (Input Metrics,JNothing), (Output Metrics,JNothing), (Updated Blocks,JNothing))))))
      at org.scalatest.Assertions$class.newAssertionFailedException(Assertions.scala:500)
      at org.scalatest.FunSuite.newAssertionFailedException(FunSuite.scala:1555)
      at org.scalatest.Assertions$AssertionsHelper.macroAssert(Assertions.scala:466)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$org$apache$spark$scheduler$ReplayListenerSuite$$testApplicationReplay$4.apply(ReplayListenerSuite.scala:135)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$org$apache$spark$scheduler$ReplayListenerSuite$$testApplicationReplay$4.apply(ReplayListenerSuite.scala:135)
      at scala.collection.mutable.ResizableArray$class.foreach(ResizableArray.scala:59)
      at scala.collection.mutable.ArrayBuffer.foreach(ArrayBuffer.scala:47)
      at org.apache.spark.scheduler.ReplayListenerSuite.org$apache$spark$scheduler$ReplayListenerSuite$$testApplicationReplay(ReplayListenerSuite.scala:135)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$5$$anonfun$apply$mcV$sp$1.apply(ReplayListenerSuite.scala:84)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$5$$anonfun$apply$mcV$sp$1.apply(ReplayListenerSuite.scala:83)
      at scala.collection.immutable.Stream.foreach(Stream.scala:547)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$5.apply$mcV$sp(ReplayListenerSuite.scala:83)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$5.apply(ReplayListenerSuite.scala:83)
      at org.apache.spark.scheduler.ReplayListenerSuite$$anonfun$5.apply(ReplayListenerSuite.scala:83)
      at org.scalatest.Transformer$$anonfun$apply$1.apply$mcV$sp(Transformer.scala:22)
      at org.scalatest.OutcomeOf$class.outcomeOf(OutcomeOf.scala:85)
      at org.scalatest.OutcomeOf$.outcomeOf(OutcomeOf.scala:104)
      at org.scalatest.Transformer.apply(Transformer.scala:22)
      at org.scalatest.Transformer.apply(Transformer.scala:20)
      at org.scalatest.FunSuiteLike$$anon$1.apply(FunSuiteLike.scala:166)
      at org.apache.spark.SparkFunSuite.withFixture(SparkFunSuite.scala:42)
      at org.scalatest.FunSuiteLike$class.invokeWithFixture$1(FunSuiteLike.scala:163)
      at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175)
      at org.scalatest.FunSuiteLike$$anonfun$runTest$1.apply(FunSuiteLike.scala:175)
      at org.scalatest.SuperEngine.runTestImpl(Engine.scala:306)
      at org.scalatest.FunSuiteLike$class.runTest(FunSuiteLike.scala:175)
      at org.apache.spark.scheduler.ReplayListenerSuite.org$scalatest$BeforeAndAfter$$super$runTest(ReplayListenerSuite.scala:35)
      at org.scalatest.BeforeAndAfter$class.runTest(BeforeAndAfter.scala:200)
      at org.apache.spark.scheduler.ReplayListenerSuite.runTest(ReplayListenerSuite.scala:35)
      at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208)
      at org.scalatest.FunSuiteLike$$anonfun$runTests$1.apply(FunSuiteLike.scala:208)
      at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:413)
      at org.scalatest.SuperEngine$$anonfun$traverseSubNodes$1$1.apply(Engine.scala:401)
      at scala.collection.immutable.List.foreach(List.scala:318)
      at org.scalatest.SuperEngine.traverseSubNodes$1(Engine.scala:401)
      at org.scalatest.SuperEngine.org$scalatest$SuperEngine$$runTestsInBranch(Engine.scala:396)
      at org.scalatest.SuperEngine.runTestsImpl(Engine.scala:483)
      at org.scalatest.FunSuiteLike$class.runTests(FunSuiteLike.scala:208)
      at org.scalatest.FunSuite.runTests(FunSuite.scala:1555)
      at org.scalatest.Suite$class.run(Suite.scala:1424)
      at org.scalatest.FunSuite.org$scalatest$FunSuiteLike$$super$run(FunSuite.scala:1555)
      at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212)
      at org.scalatest.FunSuiteLike$$anonfun$run$1.apply(FunSuiteLike.scala:212)
      at org.scalatest.SuperEngine.runImpl(Engine.scala:545)
      at org.scalatest.FunSuiteLike$class.run(FunSuiteLike.scala:212)
      at org.apache.spark.scheduler.ReplayListenerSuite.org$scalatest$BeforeAndAfter$$super$run(ReplayListenerSuite.scala:35)
      at org.scalatest.BeforeAndAfter$class.run(BeforeAndAfter.scala:241)
      at org.apache.spark.scheduler.ReplayListenerSuite.run(ReplayListenerSuite.scala:35)
      at org.scalatest.Suite$class.callExecuteOnSuite$1(Suite.scala:1492)
      at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1528)
      at org.scalatest.Suite$$anonfun$runNestedSuites$1.apply(Suite.scala:1526)
      at scala.collection.IndexedSeqOptimized$class.foreach(IndexedSeqOptimized.scala:33)
      at scala.collection.mutable.ArrayOps$ofRef.foreach(ArrayOps.scala:108)
      at org.scalatest.Suite$class.runNestedSuites(Suite.scala:1526)
      at org.scalatest.tools.DiscoverySuite.runNestedSuites(DiscoverySuite.scala:29)
      at org.scalatest.Suite$class.run(Suite.scala:1421)
      at org.scalatest.tools.DiscoverySuite.run(DiscoverySuite.scala:29)
      at org.scalatest.tools.SuiteRunner.run(SuiteRunner.scala:55)
      at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2563)
      at org.scalatest.tools.Runner$$anonfun$doRunRunRunDaDoRunRun$3.apply(Runner.scala:2557)
      at scala.collection.immutable.List.foreach(List.scala:318)
      at org.scalatest.tools.Runner$.doRunRunRunDaDoRunRun(Runner.scala:2557)
      at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1044)
      at org.scalatest.tools.Runner$$anonfun$runOptionallyWithPassFailReporter$2.apply(Runner.scala:1043)
      at org.scalatest.tools.Runner$.withClassLoaderAndDispatchReporter(Runner.scala:2722)
      at org.scalatest.tools.Runner$.runOptionallyWithPassFailReporter(Runner.scala:1043)
      at org.scalatest.tools.Runner$.main(Runner.scala:860)
      at org.scalatest.tools.Runner.main(Runner.scala)
</code></pre>