From 805f329bb1535ef4b8441994705b94a3bf0d758a Mon Sep 17 00:00:00 2001
From: Lijie Xu <csxulijie@gmail.com>
Date: Sat, 19 Jul 2014 01:27:26 -0700
Subject: [PATCH] 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 <csxulijie@gmail.com>
Closes #1477 from JerryLead/patch-1 and squashes the following commits:
aed722d [Lijie Xu] put 'curRequestSize = 0' after 'logDebug' it
---
.../scala/org/apache/spark/storage/BlockFetcherIterator.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
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 408a797088..2f0296c20f 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
--
GitLab