You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by av...@apache.org on 2016/03/21 15:20:44 UTC
[19/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/75ed3f0a
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/75ed3f0a
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/75ed3f0a
Branch: refs/heads/ignite-2801
Commit: 75ed3f0a4245b77e9b0fa252255a9ba1c7cf6241
Parents: 79815b7
Author: Alexey Kuznetsov <ak...@apache.org>
Authored: Wed Mar 9 15:09:18 2016 +0700
Committer: Alexey Kuznetsov <ak...@apache.org>
Committed: Wed Mar 9 15:09:18 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/75ed3f0a/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()) {