fix test2

Author: brkyvz

streaming/src/main/scala/org/apache/spark/streaming/util/BatchedWriteAheadLog.scala

@@ -188,7 +188,7 @@ private[util] class BatchedWriteAheadLog(val wrappedLog: WriteAheadLog, conf: Sp
 }
 
 /** Static methods for aggregating and de-aggregating records. */
-private[streaming] object BatchedWriteAheadLog {
+private[util] object BatchedWriteAheadLog {
 
   /**
    * Wrapper class for representing the records that we will write to the WriteAheadLog. Coupled

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

@@ -332,7 +332,7 @@ class ReceivedBlockTrackerSuite
       file => new FileBasedWriteAheadLogReader(file, hadoopConf).toSeq
     }.flatMap { byteBuffer =>
       val validBuffer = if (WriteAheadLogUtils.isBatchingEnabled(conf, isDriver = true)) {
-        BatchedWriteAheadLog.deaggregate(byteBuffer)
+        Utils.deserialize[Array[Array[Byte]]](byteBuffer.array()).map(ByteBuffer.wrap)
       } else {
         Array(byteBuffer)
       }