Fixed scroll size setting

EinsamHauer · Jun 22, 2022 · 0af243e · 0af243e
1 parent 75477dc
commit 0af243e
Show file tree

Hide file tree

Showing 4 changed files with 4 additions and 4 deletions.
diff --git a/pom.xml b/pom.xml
@@ -4,7 +4,7 @@
     <groupId>net.iponweb.disthene.reader</groupId>
     <artifactId>disthene-reader</artifactId>
     <packaging>jar</packaging>
-    <version>2.0.5</version>
+    <version>2.0.6</version>
     <name>disthene-reader</name>
     <url>http://maven.apache.org</url>
 

diff --git a/src/main/java/net/iponweb/disthene/reader/DistheneReader.java b/src/main/java/net/iponweb/disthene/reader/DistheneReader.java
@@ -213,7 +213,7 @@ public void handle(Signal signal) {
 
                 throttlingService.reload(throttlingConfiguration);
 
-                logger.debug("Running with the following throttling configuration: " + throttlingConfiguration.toString());
+                logger.debug("Running with the following throttling configuration: " + throttlingConfiguration);
             } catch (Exception e) {
                 logger.error("Reloading throttling configuration failed");
                 logger.error(e);

diff --git a/src/main/java/net/iponweb/disthene/reader/graphite/functions/LegendValueFunction.java b/src/main/java/net/iponweb/disthene/reader/graphite/functions/LegendValueFunction.java
@@ -90,7 +90,7 @@ public List<TimeSeries> evaluate(TargetEvaluator evaluator) throws EvaluationExc
                 }
 
             }
-            ts.setName(ts.getName() + sb.toString());
+            ts.setName(ts.getName() + sb);
         }
 
         return processedArguments;

diff --git a/src/main/java/net/iponweb/disthene/reader/service/index/IndexService.java b/src/main/java/net/iponweb/disthene/reader/service/index/IndexService.java
@@ -70,7 +70,7 @@ private List<String> getPathsFromRegExs(String tenant, List<String> regExs, bool
                     .fetchSource("path", null)
                     .query(queryBuilder);
 
-            if (limit < maxResultWindow) sourceBuilder.size(limit);
+            sourceBuilder.size(Math.min(Math.min(limit, maxResultWindow), indexConfiguration.getScroll()));
 
             SearchRequest request = new SearchRequest(indexConfiguration.getIndex())
                     .source(sourceBuilder)
-Original file line number
+Diff line change
@@ Expand Up @@
                     }
                 }
-                ts.setName(ts.getName() + sb.toString());
+                ts.setName(ts.getName() + sb);
             }
             return processedArguments;
@@ Expand Down @@