You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2015/07/08 16:23:27 UTC

[2/2] incubator-ignite git commit: GG-10507 wip

GG-10507 wip


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/da1249f5
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/da1249f5
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/da1249f5

Branch: refs/heads/ignite-gg-10507
Commit: da1249f577ddf26ac83fb3d862c4fdf0ab1d0877
Parents: 775fe24
Author: Pavel Tupitsyn <pt...@gridgain.com>
Authored: Wed Jul 8 17:16:08 2015 +0300
Committer: Pavel Tupitsyn <pt...@gridgain.com>
Committed: Wed Jul 8 17:16:08 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/datastreamer/DataStreamProcessor.java       | 1 -
 1 file changed, 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/da1249f5/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
index 81f4776..54478f8 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/processors/datastreamer/DataStreamProcessor.java
@@ -256,7 +256,6 @@ public class DataStreamProcessor<K, V> extends GridProcessorAdapter {
             try {
                 updater = marsh.unmarshal(req.updaterBytes(), clsLdr);
 
-                // TODO: think. Lifecycle iface?
                 if (updater != null)
                     ctx.resource().injectGeneric(updater);
             }