You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2019/02/20 12:26:40 UTC
[ignite] branch master updated: IGNITE-11352 Fixed deserialization
of CacheMetricsSnapshot - Fixes #6133.
This is an automated email from the ASF dual-hosted git repository.
agoncharuk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/ignite.git
The following commit(s) were added to refs/heads/master by this push:
new 45226c3 IGNITE-11352 Fixed deserialization of CacheMetricsSnapshot - Fixes #6133.
45226c3 is described below
commit 45226c379db146fd79e77982f90a4fa38b8dc288
Author: mstepachev <ma...@gmail.com>
AuthorDate: Wed Feb 20 15:25:56 2019 +0300
IGNITE-11352 Fixed deserialization of CacheMetricsSnapshot - Fixes #6133.
Signed-off-by: Alexey Goncharuk <al...@gmail.com>
---
.../internal/processors/cache/CacheMetricsSnapshot.java | 12 +++++++-----
1 file changed, 7 insertions(+), 5 deletions(-)
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java
index af33b4e..22df3fe 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheMetricsSnapshot.java
@@ -1150,11 +1150,13 @@ public class CacheMetricsSnapshot implements CacheMetrics, Externalizable {
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) {