ignite-1.5 Added withKeepBinary for Visor scan and SQL query task.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/6fedd27f Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/6fedd27f Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/6fedd27f Branch: refs/heads/ignite-1.5.1 Commit: 6fedd27fc3dcf41e657df9b7d2d3ca87a0006c0b Parents: 490f552 Author: Alexey Kuznetsov <akuznet...@apache.org> Authored: Wed Dec 16 17:26:26 2015 +0700 Committer: Alexey Kuznetsov <akuznet...@apache.org> Committed: Wed Dec 16 17:26:26 2015 +0700 ---------------------------------------------------------------------- .../org/apache/ignite/internal/visor/query/VisorQueryJob.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/6fedd27f/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryJob.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryJob.java index 50e5a06..dcca671 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryJob.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorQueryJob.java @@ -86,7 +86,7 @@ public class VisorQueryJob extends VisorJob<VisorQueryArg, IgniteBiTuple<? exten qry.setPageSize(arg.pageSize()); qry.setLocal(arg.local()); - return c.query(qry); + return c.withKeepBinary().query(qry); } /** @@ -142,7 +142,7 @@ public class VisorQueryJob extends VisorJob<VisorQueryArg, IgniteBiTuple<? exten long start = U.currentTimeMillis(); - VisorQueryCursor<List<?>> cur = new VisorQueryCursor<>(c.query(qry)); + VisorQueryCursor<List<?>> cur = new VisorQueryCursor<>(c.withKeepBinary().query(qry)); Collection<GridQueryFieldMetadata> meta = cur.fieldsMeta();