Github user dibbhatt commented on a diff in the pull request:
https://github.com/apache/spark/pull/6707#discussion_r32369028
--- Diff:
streaming/src/test/scala/org/apache/spark/streaming/ReceivedBlockHandlerSuite.scala
---
@@ -251,9 +377,20 @@ class ReceivedBlockHandlerSuite
(blockIds, storeResults)
}
+ /** Store block using a handler */
+ private def storeBlock(
--- End diff --
existing storeBlocks take Sequence of blocks and return Sequence of blockId
and BlockResult. In my test cases I need to count messages in single Block.
Probably can rename it to storeSingleBlock which will be much intuitive . Also
I can generate random block id there also using generateBlockId
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at [email protected] or file a JIRA ticket
with INFRA.
---
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
