commit 277d0e7f3500242d3dcb09827dad71e3a747d026
author Keith Turner <kturner@apache.org> Wed Nov 21 10:01:51 2018 -0500
committer GitHub <noreply@github.com> Wed Nov 21 10:01:51 2018 -0500
tree e27a162b9d8b4f2aba4379bbeeb15f68aff2547a
parent 70b6fb2520bc89d3b7348d2594eba04d90dd063d

Fix issue found by newer version of checkstyle (#1065)

This problem was found when building using #1059
and #1064

modules/core/src/main/java/org/apache/fluo/core/worker/finder/hash/ScanTask.java

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 @@
 
     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);