You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2017/04/27 15:02:41 UTC
[06/28] ignite git commit: IGNITE-4988 Fixed
VisorRunningQueriesCollectorTask.
IGNITE-4988 Fixed VisorRunningQueriesCollectorTask.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1104ca0f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1104ca0f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1104ca0f
Branch: refs/heads/ignite-5075-cacheStart
Commit: 1104ca0fa49be07aeef3ee822d1cc1ecc6b598b5
Parents: 6a435b1
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Thu Apr 27 11:58:35 2017 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Thu Apr 27 11:58:35 2017 +0700
----------------------------------------------------------------------
.../visor/query/VisorRunningQueriesCollectorTask.java | 2 +-
.../visor/query/VisorRunningQueriesCollectorTaskArg.java | 10 +++++-----
2 files changed, 6 insertions(+), 6 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/1104ca0f/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTask.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTask.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTask.java
index f6bbf7c..8d00dd6 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTask.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTask.java
@@ -83,7 +83,7 @@ public class VisorRunningQueriesCollectorTask extends VisorMultiNodeTask<VisorRu
assert arg != null;
Collection<GridRunningQueryInfo> queries = ignite.context().query()
- .runningQueries(arg.getDuration() != null ? arg.getDuration() : 0);
+ .runningQueries(arg.getDuration());
Collection<VisorRunningQuery> res = new ArrayList<>(queries.size());
http://git-wip-us.apache.org/repos/asf/ignite/blob/1104ca0f/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTaskArg.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTaskArg.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTaskArg.java
index c851559..2de61c5 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTaskArg.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/query/VisorRunningQueriesCollectorTaskArg.java
@@ -31,7 +31,7 @@ public class VisorRunningQueriesCollectorTaskArg extends VisorDataTransferObject
private static final long serialVersionUID = 0L;
/** Duration to check. */
- private Long duration;
+ private long duration;
/**
* Default constructor.
@@ -43,25 +43,25 @@ public class VisorRunningQueriesCollectorTaskArg extends VisorDataTransferObject
/**
* @param duration Duration to check.
*/
- public VisorRunningQueriesCollectorTaskArg(Long duration) {
+ public VisorRunningQueriesCollectorTaskArg(long duration) {
this.duration = duration;
}
/**
* @return Duration to check.
*/
- public Long getDuration() {
+ public long getDuration() {
return duration;
}
/** {@inheritDoc} */
@Override protected void writeExternalData(ObjectOutput out) throws IOException {
- out.writeObject(duration);
+ out.writeLong(duration);
}
/** {@inheritDoc} */
@Override protected void readExternalData(byte protoVer, ObjectInput in) throws IOException, ClassNotFoundException {
- duration = (Long)in.readObject();
+ duration = in.readLong();
}
/** {@inheritDoc} */