IGNITE-11352 Fixed deserialization of CacheMetricsSnapshot - Fixes ap…

…ache#6133. Signed-off-by: Alexey Goncharuk <alexey.goncharuk@gmail.com>
gridgain · Feb 26, 2019 · 610f4d6 · 610f4d6
1 parent 01de553
commit 610f4d6
Showing 1 changed file with 7 additions and 5 deletions.
diff --git a/.../core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java b/.../core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java
@@ -1165,11 +1165,13 @@ public CacheMetricsSnapshot(CacheMetrics loc, Collection<CacheMetrics> metrics)
         rebalancingBytesRate = in.readLong();
         rebalancingKeysRate = in.readLong();
 
-        rebalancedKeys = in.readLong();
-        estimatedRebalancingKeys = in.readLong();
-        rebalanceStartTime = in.readLong();
-        rebalanceFinishTime = in.readLong();
-        rebalanceClearingPartitionsLeft = in.readLong();
+        if (in.available() >= 40) {
+            rebalancedKeys = in.readLong();
+            estimatedRebalancingKeys = in.readLong();
+            rebalanceStartTime = in.readLong();
+            rebalanceFinishTime = in.readLong();
+            rebalanceClearingPartitionsLeft = in.readLong();
+        }
 
         // 11 long and 5 float values give 108 bytes in total.
         if (in.available() >= 108) {