You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2016/12/01 11:33:33 UTC
[2/6] ignite git commit: IGNITE-4305 marshalling fix
IGNITE-4305 marshalling fix
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1a2de51f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1a2de51f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1a2de51f
Branch: refs/heads/ignite-4296
Commit: 1a2de51f5807a91ce0d5dff28f24ed5bf7abebbc
Parents: 6fbaef4
Author: Konstantin Dudkov <kd...@ya.ru>
Authored: Mon Nov 28 12:59:02 2016 +0300
Committer: Konstantin Dudkov <kd...@ya.ru>
Committed: Tue Nov 29 11:53:07 2016 +0300
----------------------------------------------------------------------
.../dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1a2de51f/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java
index 238db8b..df9e384 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/atomic/GridNearAtomicSingleUpdateInvokeRequest.java
@@ -203,7 +203,8 @@ public class GridNearAtomicSingleUpdateInvokeRequest extends GridNearAtomicSingl
addDepInfo = true;
if (entryProcessor != null && entryProcessorBytes == null) {
- prepareObject(entryProcessor, cctx);
+ if (addDepInfo)
+ prepareObject(entryProcessor, cctx);
entryProcessorBytes = CU.marshal(cctx, entryProcessor);
}