fixed elasticsearch slicer recursion algorithm resolves terascope#591

jsnoble · Oct 24, 2017 · 5ea16d1 · 5ea16d1
1 parent daa1177
commit 5ea16d1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/lib/readers/elasticsearch_date_range/slicer.js b/lib/readers/elasticsearch_date_range/slicer.js
@@ -187,7 +187,7 @@ function newSlicer(context, opConfig, job, retryData, logger, client) {
         }
         else {
             var secondDiff = Math.floor(diff / 1000);
-            return secondDiff > 1 ? secondDiff : 1
+            return secondDiff;
         }
     }
 
@@ -216,8 +216,8 @@ function newSlicer(context, opConfig, job, retryData, logger, client) {
                     var newEnd = moment(dateParams.start).add(diff, time_resolution);
 
                     //prevent recursive call if difference is one millisecond
-                    if (diff <= 1) {
-                        return {start: dateParams.start, end: newEnd, count: count};
+                    if (diff <= 0) {
+                        return {start: dateParams.start, end: dateParams.end, count: count};
                     }
                     else {
                         //recurse to find smaller chunk