IGNITE-950 - Debug.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ab32d0af Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ab32d0af Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ab32d0af Branch: refs/heads/ignite-1753-1282 Commit: ab32d0af71ae04a085e734263321f5511f35a7a2 Parents: a101bdf Author: Alexey Goncharuk <[email protected]> Authored: Tue Nov 3 17:48:37 2015 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Tue Nov 3 17:48:37 2015 +0300 ---------------------------------------------------------------------- .../cache/distributed/GridDistributedCacheAdapter.java | 4 ++-- .../cache/distributed/GridDistributedTxRemoteAdapter.java | 2 ++ .../processors/cache/transactions/IgniteTxLocalAdapter.java | 3 +++ 3 files changed, 7 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java index 77035df..3eb60a3 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedCacheAdapter.java @@ -370,8 +370,6 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter if (cache == null) return true; - U.debug(">>>> Running global remove all job: " + cache.name()); - final GridCacheContext<K, V> ctx = cache.context(); ctx.gate().enter(); @@ -397,6 +395,8 @@ public abstract class GridDistributedCacheAdapter<K, V> extends GridCacheAdapter dataLdr.skipStore(skipStore); dataLdr.keepBinary(keepBinary); + U.debug("Will use streamer [skipStore=" + skipStore + ", keepBinary=" + keepBinary + ']'); + dataLdr.receiver(DataStreamerCacheUpdaters.<KeyCacheObject, Object>batched()); for (int part : ctx.affinity().primaryPartitions(ctx.localNodeId(), topVer)) { http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java index 3aa7e1c..b678679 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/GridDistributedTxRemoteAdapter.java @@ -505,6 +505,8 @@ public class GridDistributedTxRemoteAdapter extends IgniteTxAdapter for (IgniteTxEntry txEntry : (near() ? allEntries() : writeEntries())) { GridCacheContext cacheCtx = txEntry.context(); + U.debug(log, "Will write transactional entry: " + txEntry); + boolean replicate = cacheCtx.isDrEnabled(); try { http://git-wip-us.apache.org/repos/asf/ignite/blob/ab32d0af/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java index 214ba45..4c53d88 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/transactions/IgniteTxLocalAdapter.java @@ -2076,6 +2076,9 @@ public abstract class IgniteTxLocalAdapter extends IgniteTxAdapter return new GridFinishedFuture<>(e); } + if (!keepBinary) + U.dumpStack("Writing to cache without keepBinary: " + keys); + Set<KeyCacheObject> skipped = null; boolean rmv = lookup == null && invokeMap == null;
