You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2014/07/19 10:27:31 UTC
git commit: put 'curRequestSize = 0' after 'logDebug' it
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 <cs...@gmail.com>
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 <cs...@gmail.com>
Authored: Sat Jul 19 01:27:26 2014 -0700
Committer: Reynold Xin <rx...@apache.org>
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