diff options
| author | Lijie Xu <csxulijie@gmail.com> | 2014-07-19 01:27:26 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-07-19 01:27:26 -0700 |
| commit | 805f329bb1535ef4b8441994705b94a3bf0d758a (patch) | |
| tree | 0c87ac200ea3f8f0012358cc0b0e905b65841469 /core | |
| parent | 7b8cd175254d42c8e82f0aa8eb4b7f3508d8fde2 (diff) | |
| download | spark-805f329bb1535ef4b8441994705b94a3bf0d758a.tar.gz spark-805f329bb1535ef4b8441994705b94a3bf0d758a.tar.bz2 spark-805f329bb1535ef4b8441994705b94a3bf0d758a.zip | |
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
Diffstat (limited to 'core')
| -rw-r--r-- | core/src/main/scala/org/apache/spark/storage/BlockFetcherIterator.scala | 2 |
1 files changed, 1 insertions, 1 deletions
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 |