Repository: spark Updated Branches: refs/heads/master 7b8cd1752 -> 805f329bb
put 'curRequestSize = 0' after 'logDebug' it This is a minor change. We should first logDebug($curRequestSize) and then set it to 0. Author: Lijie Xu <[email protected]> Closes #1477 from JerryLead/patch-1 and squashes the following commits: aed722d [Lijie Xu] put 'curRequestSize = 0' after 'logDebug' it Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/805f329b Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/805f329b Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/805f329b Branch: refs/heads/master Commit: 805f329bb1535ef4b8441994705b94a3bf0d758a Parents: 7b8cd17 Author: Lijie Xu <[email protected]> Authored: Sat Jul 19 01:27:26 2014 -0700 Committer: Reynold Xin <[email protected]> Committed: Sat Jul 19 01:27:26 2014 -0700 ---------------------------------------------------------------------- .../main/scala/org/apache/spark/storage/BlockFetcherIterator.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/spark/blob/805f329b/core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala ---------------------------------------------------------------------- diff --git a/core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala b/core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala index 408a797..2f0296c 100644 --- a/core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala +++ b/core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala @@ -180,9 +180,9 @@ object BlockFetcherIterator { if (curRequestSize >= targetRequestSize) { // Add this FetchRequest remoteRequests += new FetchRequest(address, curBlocks) - curRequestSize = 0 curBlocks = new ArrayBuffer[(BlockId, Long)] logDebug(s"Creating fetch request of $curRequestSize at $address") + curRequestSize = 0 } } // Add in the final request
