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 <[email protected]> Authored: Wed Jul 8 17:16:08 2015 +0300 Committer: Pavel Tupitsyn <[email protected]> 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); }
