Repository: ignite Updated Branches: refs/heads/ignite-4436-2 6da54da7b -> 708d6e14d
IGNITE-4436 Fixed NPE. Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/708d6e14 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/708d6e14 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/708d6e14 Branch: refs/heads/ignite-4436-2 Commit: 708d6e14dfcbc6c935546a1e18e55bcba40f804e Parents: 6da54da Author: AKuznetsov <[email protected]> Authored: Thu Feb 9 22:16:55 2017 +0700 Committer: AKuznetsov <[email protected]> Committed: Thu Feb 9 22:16:55 2017 +0700 ---------------------------------------------------------------------- .../internal/visor/query/VisorCollectRunningQueriesTask.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/708d6e14/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorCollectRunningQueriesTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorCollectRunningQueriesTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorCollectRunningQueriesTask.java index fbc8a25..8ac8ace 100644 --- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorCollectRunningQueriesTask.java +++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorCollectRunningQueriesTask.java @@ -77,7 +77,8 @@ public class VisorCollectRunningQueriesTask extends VisorMultiNodeTask<Long, Map /** {@inheritDoc} */ @Override protected Collection<VisorRunningQuery> run(@Nullable Long duration) throws IgniteException { - Collection<GridRunningQueryInfo> queries = ignite.context().query().runningQueries(duration); + Collection<GridRunningQueryInfo> queries = ignite.context().query() + .runningQueries(duration != null ? duration : 0); Collection<VisorRunningQuery> res = new ArrayList<>(queries.size());
