comment
Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/c193b5da Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/c193b5da Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/c193b5da Branch: refs/heads/feature/GEODE-1464 Commit: c193b5dad3ea9a187e01541345b53b4cfb5546ba Parents: 2a56adf Author: Darrel Schneider <[email protected]> Authored: Wed Jun 1 16:08:55 2016 -0700 Committer: Darrel Schneider <[email protected]> Committed: Wed Jun 1 16:08:55 2016 -0700 ---------------------------------------------------------------------- .../internal/cache/execute/FunctionStreamingResultCollector.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/c193b5da/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java ---------------------------------------------------------------------- diff --git a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java index 3874ad9..7ed908e 100755 --- a/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java +++ b/geode-core/src/main/java/com/gemstone/gemfire/internal/cache/execute/FunctionStreamingResultCollector.java @@ -96,8 +96,7 @@ public class FunctionStreamingResultCollector extends ReplyProcessor21 implement this.execution = execution; this.fites = Collections.synchronizedList(new ArrayList<FunctionInvocationTargetException>()); // add a reference to self inside the ResultCollector, if required, to avoid - // this ReplyProcessor21 from being GCed; currently is of use for SQLFabric - // result collectors to properly implement streaming + // this ReplyProcessor21 from being GCed if (rc instanceof LocalResultCollector<?, ?>) { ((LocalResultCollector<?, ?>)rc).setProcessor(this); }
