SPARK-26734: Remove line break and stop tracker in test.

Author: rlodge

streaming/src/main/scala/org/apache/spark/streaming/scheduler/ReceivedBlockTracker.scala

@@ -116,8 +116,7 @@ private[streaming] class ReceivedBlockTracker(
       // a few thousand elements.  So we explicitly allocate a collection for serialization which
       // we know doesn't have this issue.  (See SPARK-26734).
       val streamIdToBlocks = streamIds.map { streamId =>
-        (streamId,
-          mutable.ArrayBuffer(getReceivedBlockQueue(streamId).clone(): _*))
+        (streamId, mutable.ArrayBuffer(getReceivedBlockQueue(streamId).clone(): _*))
       }.toMap
       val allocatedBlocks = AllocatedBlocks(streamIdToBlocks)
       if (writeToLog(BatchAllocationEvent(batchTime, allocatedBlocks))) {

streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockTrackerSuite.scala

@@ -113,6 +113,8 @@ class ReceivedBlockTrackerSuite
       BatchAllocationEvent(1, AllocatedBlocks(Map(streamId -> blockInfos)))
     getWrittenLogData() shouldEqual expectedWrittenData1
     getWriteAheadLogFiles() should have size 1
+
+    receivedBlockTracker.stop()
   }
 
   test("recovery with write ahead logs should remove only allocated blocks from received queue") {