You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vo...@apache.org on 2016/03/09 10:28:04 UTC
[49/50] [abbrv] ignite git commit: Minor Visor fixes.
Minor Visor fixes.
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/f687ba2f
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/f687ba2f
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/f687ba2f
Branch: refs/heads/ignite-1786
Commit: f687ba2fc3c0444e9ed458387ddf0022bf985c16
Parents: cd203a7
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Wed Mar 9 15:12:11 2016 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Wed Mar 9 15:12:11 2016 +0700
----------------------------------------------------------------------
.../org/apache/ignite/internal/visor/util/VisorTaskUtils.java | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/f687ba2f/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java
----------------------------------------------------------------------
diff --git a/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java b/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java
index 83dbda0..9be8c35 100644
--- a/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java
+++ b/modules/core/src/main/java/org/apache/ignite/internal/visor/util/VisorTaskUtils.java
@@ -434,11 +434,11 @@ public class VisorTaskUtils {
lastFound.set(true);
// Retains events by lastOrder, period and type.
- return e.localOrder() > lastOrder && e.timestamp() > notOlderThan && F.contains(evtTypes, e.type());
+ return e.localOrder() > lastOrder && e.timestamp() > notOlderThan;
}
};
- Collection<Event> evts = ignite.events().localQuery(p);
+ Collection<Event> evts = ignite.events().localQuery(p, evtTypes);
// Update latest order in node local, if not empty.
if (!evts.isEmpty()) {