Fix to "clear" method.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/7f993fa2 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/7f993fa2 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/7f993fa2 Branch: refs/heads/ignite-2523-1 Commit: 7f993fa22ef5c598cd5915c05a49b5eee1924c07 Parents: 32001ad Author: vozerov-gridgain <[email protected]> Authored: Tue Apr 19 15:24:53 2016 +0300 Committer: vozerov-gridgain <[email protected]> Committed: Tue Apr 19 15:24:53 2016 +0300 ---------------------------------------------------------------------- .../dht/atomic/GridNearAtomicAbstractUpdateRequest.java | 5 ----- .../dht/atomic/GridNearAtomicSingleUpdateRequest.java | 4 ++++ 2 files changed, 4 insertions(+), 5 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/7f993fa2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateRequest.java index 33812df..37d9e45 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicAbstractUpdateRequest.java @@ -161,23 +161,18 @@ public abstract class GridNearAtomicAbstractUpdateRequest extends GridCacheMessa * @param idx Key index. * @return Value. */ - // TODO - @SuppressWarnings("unchecked") public abstract CacheObject value(int idx); /** * @param idx Key index. * @return Entry processor. */ - @SuppressWarnings("unchecked") - // TODO public abstract EntryProcessor<Object, Object, Object> entryProcessor(int idx); /** * @param idx Index to get. * @return Write value - either value, or transform closure. */ - // TODO public abstract CacheObject writeValue(int idx); /** http://git-wip-us.apache.org/repos/asf/ignite/blob/7f993fa2/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateRequest.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateRequest.java index 41d0c8b..0a19eb4 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateRequest.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateRequest.java @@ -800,8 +800,12 @@ public class GridNearAtomicSingleUpdateRequest extends GridNearAtomicAbstractUpd /** {@inheritDoc} */ @Override public void cleanup(boolean clearKeys) { + val = null; invokeArgs = null; invokeArgsBytes = null; + + if (clearKeys) + key = null; } /** {@inheritDoc} */
