Remove tab space and change avg datatype to LONG (Signed-off-by: Jeff…

…rey Liu [email protected]) Signed-off-by: CoderJeffrey <[email protected]>
opensearch-project · Jul 3, 2023 · 353c3a6 · 353c3a6
1 parent 6578073
commit 353c3a6
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 7 deletions.
diff --git a/...in/java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsProcessor.java b/...in/java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsProcessor.java
@@ -56,7 +56,6 @@ static SearchBackPressureMetricsProcessor buildSearchBackPressureMetricsProcesso
                     currentWindowStartTime, searchBackPressureMetricsSnapShot);
             return new SearchBackPressureMetricsProcessor(searchBackPressureMetricsSnapShot);
         }
-
         return new SearchBackPressureMetricsProcessor(
                 searchBackPressureSnapshotNavigableMap.get(currentWindowStartTime));
     }

diff --git a/...ain/java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsSnapShot.java b/...ain/java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsSnapShot.java
@@ -84,7 +84,7 @@ public SearchBackPressureMetricsSnapShot(Connection conn, Long windowStartTime)
                                                 AllMetrics.SearchBackPressureStatsValue
                                                         .SEARCHBP_SHARD_STATS_RESOURCE_HEAP_USAGE_ROLLINGAVG
                                                         .toString()),
-                                        Integer.class));
+                                        Long.class));
                         this.add(
                                 DSL.field(
                                         DSL.name(
@@ -106,7 +106,7 @@ public SearchBackPressureMetricsSnapShot(Connection conn, Long windowStartTime)
                                                 AllMetrics.SearchBackPressureStatsValue
                                                         .SEARCHBP_SHARD_STATS_RESOURCE_CPU_USAGE_CURRENTAVG
                                                         .toString()),
-                                        Integer.class));
+                                        Long.class));
 
                         // Task Stats Resource Heap / CPU Usage
                         this.add(
@@ -129,7 +129,7 @@ public SearchBackPressureMetricsSnapShot(Connection conn, Long windowStartTime)
                                                 AllMetrics.SearchBackPressureStatsValue
                                                         .SEARCHBP_TASK_STATS_RESOURCE_HEAP_USAGE_ROLLINGAVG
                                                         .toString()),
-                                        Integer.class));
+                                        Long.class));
                         this.add(
                                 DSL.field(
                                         DSL.name(
@@ -151,7 +151,7 @@ public SearchBackPressureMetricsSnapShot(Connection conn, Long windowStartTime)
                                                 AllMetrics.SearchBackPressureStatsValue
                                                         .SEARCHBP_TASK_STATS_RESOURCE_CPU_USAGE_CURRENTAVG
                                                         .toString()),
-                                        Integer.class));
+                                        Long.class));
                     }
                 };
 

diff --git a/...ava/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsProcessorTest.java b/...ava/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsProcessorTest.java
@@ -93,7 +93,7 @@ public void testSearchBackPressureProcessEvent() throws Exception {
         // SEARCHBP_SHARD_STATS_RESOURCE_HEAP_USAGE_ROLLINGAVG value is 3L according to the
         // SERIALIZED_EVENT, should EQUAL
         Assert.assertEquals(
-                3,
+                3L,
                 result.get(0)
                         .get(
                                 AllMetrics.SearchBackPressureStatsValue

diff --git a/...java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsSnapShotTest.java b/...java/org/opensearch/performanceanalyzer/reader/SearchBackPressureMetricsSnapShotTest.java
@@ -116,7 +116,7 @@ public void testReadSearchBackPressureMetricsSnapshot() throws Exception {
                             + " should be "
                             + String.valueOf(i),
                     i,
-                    result.get(0).get(required_searchbp_dims.get((int) i)));
+                    ((Number) result.get(0).get(required_searchbp_dims.get(i))).intValue());
         }
     }