int is enough.

elastic · Apr 13, 2021 · 6c5ecde · 6c5ecde
1 parent 1596b6d
commit 6c5ecde
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/.../src/main/java/org/elasticsearch/xpack/autoscaling/shards/FrozenShardsDeciderService.java b/.../src/main/java/org/elasticsearch/xpack/autoscaling/shards/FrozenShardsDeciderService.java
@@ -53,15 +53,15 @@ public String name() {
     @Override
     public AutoscalingDeciderResult scale(Settings configuration, AutoscalingDeciderContext context) {
         // we assume that nodes do not grow beyond 64GB here.
-        long shards = countFrozenShards(context.state().metadata());
+        int shards = countFrozenShards(context.state().metadata());
         long memory = shards * MEMORY_PER_SHARD.get(configuration).getBytes();
         return new AutoscalingDeciderResult(AutoscalingCapacity.builder().total(null, memory).build(), new FrozenShardsReason(shards));
     }
 
-    static long countFrozenShards(Metadata metadata) {
+    static int countFrozenShards(Metadata metadata) {
         return StreamSupport.stream(metadata.spliterator(), false)
             .filter(imd -> isFrozenIndex(imd.getSettings()))
-            .mapToLong(IndexMetadata::getTotalNumberOfShards)
+            .mapToInt(IndexMetadata::getTotalNumberOfShards)
             .sum();
     }
 

diff --git a/...test/java/org/elasticsearch/xpack/autoscaling/shards/FrozenShardsDeciderServiceTests.java b/...test/java/org/elasticsearch/xpack/autoscaling/shards/FrozenShardsDeciderServiceTests.java
@@ -42,13 +42,13 @@ public void testIsFrozenIndex() {
 
     public void testCountFrozenShards() {
         final Metadata.Builder builder = Metadata.builder();
-        long count = 0;
+        int count = 0;
         for (int i = 0; i < randomInt(20); ++i) {
             int shards = between(1, 3);
             int replicas = between(0, 2);
             String tierPreference = randomBoolean() ? DataTier.DATA_FROZEN : randomNonFrozenTierPreference();
             if (Objects.equals(tierPreference, DataTier.DATA_FROZEN)) {
-                count += (long) shards * (replicas + 1);
+                count += shards * (replicas + 1);
             }
             builder.put(
                 IndexMetadata.builder("index" + i).settings(indexSettings(tierPreference)).numberOfShards(shards).numberOfReplicas(replicas)