Fixing ShardStateCollector; impacted by core refactoring

Signed-off-by: Khushboo Rajput <[email protected]>
opensearch-project · May 17, 2023 · 27ca714 · 27ca714
1 parent 329e8f4
commit 27ca714
Show file tree

Hide file tree

Showing 10 changed files with 10 additions and 12 deletions.
diff --git a/licenses/jackson-annotations-2.14.2.jar.sha1 b/licenses/jackson-annotations-2.14.2.jar.sha1
diff --git a/licenses/jackson-annotations-2.15.1.jar.sha1 b/licenses/jackson-annotations-2.15.1.jar.sha1
@@ -0,0 +1 @@
+092a90d3739e970e03b5971839e4fe51f13c1fa3
diff --git a/licenses/jackson-databind-2.14.2.jar.sha1 b/licenses/jackson-databind-2.14.2.jar.sha1
diff --git a/licenses/jackson-databind-2.15.1.jar.sha1 b/licenses/jackson-databind-2.15.1.jar.sha1
@@ -0,0 +1 @@
+ac9ba74d208faf356e4719a49e59c6ea9237c01d
diff --git a/licenses/jackson-module-paranamer-2.14.2.jar.sha1 b/licenses/jackson-module-paranamer-2.14.2.jar.sha1
diff --git a/licenses/jackson-module-paranamer-2.15.1.jar.sha1 b/licenses/jackson-module-paranamer-2.15.1.jar.sha1
@@ -0,0 +1 @@
+1eee39f6a814b12d92a936cd198657ff26970215
diff --git a/licenses/performanceanalyzer-rca-2.7.0.0-SNAPSHOT.jar.sha1 b/licenses/performanceanalyzer-rca-2.7.0.0-SNAPSHOT.jar.sha1
diff --git a/licenses/performanceanalyzer-rca-2.8.0.0-SNAPSHOT.jar.sha1 b/licenses/performanceanalyzer-rca-2.8.0.0-SNAPSHOT.jar.sha1
@@ -0,0 +1 @@
+5393e43564d111dacd4121e26e77f327168413e8
diff --git a/src/main/java/org/opensearch/performanceanalyzer/collectors/CircuitBreakerCollector.java b/src/main/java/org/opensearch/performanceanalyzer/collectors/CircuitBreakerCollector.java
@@ -25,8 +25,7 @@ public class CircuitBreakerCollector extends PerformanceAnalyzerMetricsCollector
     public static final int SAMPLING_TIME_INTERVAL =
             MetricsConfiguration.CONFIG_MAP.get(CircuitBreakerCollector.class).samplingInterval;
 
-    private static final Logger LOG =
-            LogManager.getLogger(CircuitBreakerCollector.class);
+    private static final Logger LOG = LogManager.getLogger(CircuitBreakerCollector.class);
     private static final int KEYS_PATH_LENGTH = 0;
     private StringBuilder value;
 
@@ -54,10 +53,10 @@ public void collectMetrics(long startTime) {
                 value.append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor)
                         .append(
                                 new CircuitBreakerStatus(
-                                        stats.getName(),
-                                        stats.getEstimated(),
-                                        stats.getTrippedCount(),
-                                        stats.getLimit())
+                                                stats.getName(),
+                                                stats.getEstimated(),
+                                                stats.getTrippedCount(),
+                                                stats.getLimit())
                                         .serialize());
             }
 
@@ -76,7 +75,6 @@ public void collectMetrics(long startTime) {
                     () -> ex.toString(),
                     () -> startTime);
         }
-
     }
 
     @Override

diff --git a/src/main/java/org/opensearch/performanceanalyzer/collectors/ShardStateCollector.java b/src/main/java/org/opensearch/performanceanalyzer/collectors/ShardStateCollector.java
@@ -64,7 +64,7 @@ public void collectMetrics(long startTime) {
             value.append(PerformanceAnalyzerMetrics.getJsonCurrentMilliSeconds())
                     .append(PerformanceAnalyzerMetrics.sMetricNewLineDelimitor);
             RoutingTable routingTable = clusterState.routingTable();
-            String[] indices = routingTable.indicesRouting().keySet().toArray(new String[0]);
+            String[] indices = routingTable.indicesRouting().keys().toArray(String.class);
             for (String index : indices) {
                 List<ShardRouting> allShardsIndex = routingTable.allShards(index);
                 value.append(