Repository: ignite Updated Branches: refs/heads/ignite-4828-reviewed 6ccfb4384 -> d0e6173e2
ignite-4828 - fixed deserialization Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/d0e6173e Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/d0e6173e Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/d0e6173e Branch: refs/heads/ignite-4828-reviewed Commit: d0e6173e2ca5e22c77f7201e6bba2dbc591c539f Parents: 6ccfb43 Author: Yakov Zhdanov <[email protected]> Authored: Tue Apr 11 12:45:03 2017 +0300 Committer: Yakov Zhdanov <[email protected]> Committed: Tue Apr 11 12:45:03 2017 +0300 ---------------------------------------------------------------------- .../cache/affinity/rendezvous/RendezvousAffinityFunction.java | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/d0e6173e/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java index 3845715..dcac7d4 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/affinity/rendezvous/RendezvousAffinityFunction.java @@ -102,7 +102,7 @@ public class RendezvousAffinityFunction implements AffinityFunction, Externaliza private int parts; /** Mask to use in calculation when partitions count is power of 2. */ - private int mask = -1; + private transient int mask = -1; /** Exclude neighbors flag. */ private boolean exclNeighbors; @@ -570,7 +570,8 @@ public class RendezvousAffinityFunction implements AffinityFunction, Externaliza /** {@inheritDoc} */ @SuppressWarnings("unchecked") @Override public void readExternal(ObjectInput in) throws IOException, ClassNotFoundException { - parts = in.readInt(); + setPartitions(in.readInt()); + exclNeighbors = in.readBoolean(); hashIdRslvr = (AffinityNodeHashResolver)in.readObject(); backupFilter = (IgniteBiPredicate<ClusterNode, ClusterNode>)in.readObject();
