attilapiros commented on pull request #28618:
URL: https://github.com/apache/spark/pull/28618#issuecomment-649584687
In `BaseReceivedBlockHandlerSuite` one parameter (a `ShuffleOutputTracker`)
is missing but as the test does not do any shuffle we can pass a `null` as
value (or a `NoOpShuffleOutputTracker`). With `null`:
```diff
index 0976494b6d..5f6a0f164f 100644
---
a/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala
+++
b/streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala
@@ -70,7 +70,7 @@ abstract class
BaseReceivedBlockHandlerSuite(enableEncryption: Boolean)
val streamId = 1
val securityMgr = new SecurityManager(conf, encryptionKey)
val broadcastManager = new BroadcastManager(true, conf, securityMgr)
- val mapOutputTracker = new MapOutputTrackerMaster(conf, broadcastManager,
true)
+ val mapOutputTracker = new MapOutputTrackerMaster(conf, null,
broadcastManager, true)
val shuffleManager = new SortShuffleManager(conf)
val serializer = new KryoSerializer(conf)
var serializerManager = new SerializerManager(serializer, conf,
encryptionKey)
```
```
[info] ReceivedBlockHandlerSuite:
[info] - BlockManagerBasedBlockHandler - store blocks (315 milliseconds)
[info] - BlockManagerBasedBlockHandler - handle errors in storing block (5
milliseconds)
[info] - WriteAheadLogBasedBlockHandler - store blocks (216 milliseconds)
[info] - WriteAheadLogBasedBlockHandler - handle errors in storing block
(13 milliseconds)
[info] - WriteAheadLogBasedBlockHandler - clean old blocks (53
milliseconds)
[info] - Test Block - count messages (121 milliseconds)
[info] - Test Block - isFullyConsumed (24 milliseconds)
[info] ReceivedBlockHandlerWithEncryptionSuite:
[info] - BlockManagerBasedBlockHandler - store blocks (27 milliseconds)
[info] - BlockManagerBasedBlockHandler - handle errors in storing block (2
milliseconds)
[info] - WriteAheadLogBasedBlockHandler - store blocks (89 milliseconds)
[info] - WriteAheadLogBasedBlockHandler - handle errors in storing block
(8 milliseconds)
[info] - WriteAheadLogBasedBlockHandler - clean old blocks (16
milliseconds)
[info] - Test Block - count messages (71 milliseconds)
[info] - Test Block - isFullyConsumed (14 milliseconds)
[info] ScalaTest
[info] Run completed in 4 seconds, 30 milliseconds.
[info] Total number of tests run: 14
[info] Suites: completed 2, aborted 0
[info] Tests: succeeded 14, failed 0, canceled 0, ignored 0, pending 0
[info] All tests passed.
```
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
