ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [29/64] [abbrv] ignite git commit: IGNITE-4988 Fixed VisorRunningQueriesCollectorTask.
Date Fri, 28 Apr 2017 12:44:57 GMT
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
Commit: 1104ca0fa49be07aeef3ee822d1cc1ecc6b598b5
Parents: 6a435b1
Author: Alexey Kuznetsov <akuznetsov@apache.org>
Authored: Thu Apr 27 11:58:35 2017 +0700
Committer: Alexey Kuznetsov <akuznetsov@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} */


Mime
View raw message