IGNITE-11352 Fixed deserialization of CacheMetricsSnapshot - Fixes ap…

…ache#6133. Signed-off-by: Alexey Goncharuk <alexey.goncharuk@gmail.com>
javaronok · Feb 20, 2019 · 45226c3 · 45226c3
1 parent 481e5a5
commit 45226c3
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
@@ -1150,11 +1150,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) {