You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ak...@apache.org on 2015/11/05 04:28:28 UTC
[36/66] [abbrv] ignite git commit: IGNITE-950 - Debug.
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/8585cce4
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/8585cce4
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/8585cce4
Branch: refs/heads/ignite-1753-1282
Commit: 8585cce4cb79285574160ee1eef46c943f405b86
Parents: f3d20c3
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Tue Nov 3 16:48:36 2015 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Tue Nov 3 16:48:36 2015 +0300
----------------------------------------------------------------------
.../ignite/internal/processors/datastreamer/DataStreamerImpl.java | 2 ++
1 file changed, 2 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/8585cce4/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
index a2a109f..df1f656 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamerImpl.java
@@ -1255,6 +1255,8 @@ public class DataStreamerImpl<K, V> implements IgniteDataStreamer<K, V>, Delayed
IgniteInternalFuture<Object> fut;
if (isLocNode) {
+ U.dumpStack("Submitting local streamer job [entries=" + entries + ", keepBinary=" + keepBinary + ']');
+
fut = ctx.closure().callLocalSafe(
new DataStreamerUpdateJob(ctx, log, cacheName, entries, false, skipStore, keepBinary, rcvr), false);