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 <[email protected]> Authored: Tue Nov 3 16:48:36 2015 +0300 Committer: Alexey Goncharuk <[email protected]> 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);
