ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From agoncha...@apache.org
Subject ignite git commit: IGNITE-950 - Debug.
Date Tue, 03 Nov 2015 13:48:48 GMT
Repository: ignite
Updated Branches:
  refs/heads/ignite-950-new f3d20c3a8 -> 8585cce4c


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-950-new
Commit: 8585cce4cb79285574160ee1eef46c943f405b86
Parents: f3d20c3
Author: Alexey Goncharuk <alexey.goncharuk@gmail.com>
Authored: Tue Nov 3 16:48:36 2015 +0300
Committer: Alexey Goncharuk <alexey.goncharuk@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);
 


Mime
View raw message