[fluo] branch master updated: Fix issue found by newer version of checkstyle (#1065)

[kturner]

This is an automated email from the ASF dual-hosted git repository.

kturner pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/fluo.git


The following commit(s) were added to refs/heads/master by this push:
     new 277d0e7  Fix issue found by newer version of checkstyle (#1065)
277d0e7 is described below

commit 277d0e7f3500242d3dcb09827dad71e3a747d026
Author: Keith Turner <ktur...@apache.org>
AuthorDate: Wed Nov 21 10:01:51 2018 -0500

    Fix issue found by newer version of checkstyle (#1065)
    
    This problem was found when building using #1059
    and #1064
---
 .../main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
 
b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
index acea710..ffe9194 100644
--- 
a/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
+++ 
b/modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java
@@ -83,14 +83,15 @@ public class ScanTask implements Runnable {
 
     while (!stopped.get()) {
       try {
+        ranges.clear();
+        rangeSet.clear();
+
         PartitionInfo partition = partitionManager.waitForPartitionInfo();
 
         while (proccessor.size() > qSize / 2 && !stopped.get()) {
           UtilWaitThread.sleep(50, stopped);
         }
 
-        ranges.clear();
-        rangeSet.clear();
         partition.getMyGroupsRanges().forEach(t -> {
           ranges.add(t);
           rangeSet.add(t);