ignite-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From sboi...@apache.org
Subject [11/29] incubator-ignite git commit: #ignite-611: Fix HadoopJobTracker
Date Tue, 31 Mar 2015 10:37:14 GMT
#ignite-611: Fix HadoopJobTracker


Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/fd370b9a
Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/fd370b9a
Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/fd370b9a

Branch: refs/heads/ignite-629-1
Commit: fd370b9a40a61c4c0219cc61fb9016e763a5f6c3
Parents: 95540fd
Author: ivasilinets <ivasilinets@gridgain.com>
Authored: Fri Mar 27 14:12:25 2015 +0300
Committer: ivasilinets <ivasilinets@gridgain.com>
Committed: Fri Mar 27 14:12:25 2015 +0300

----------------------------------------------------------------------
 .../internal/processors/hadoop/jobtracker/HadoopJobTracker.java   | 3 +++
 1 file changed, 3 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/fd370b9a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/HadoopJobTracker.java
----------------------------------------------------------------------
diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/HadoopJobTracker.java
b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/HadoopJobTracker.java
index 433b84f..1eef8ed 100644
--- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/HadoopJobTracker.java
+++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/HadoopJobTracker.java
@@ -557,6 +557,9 @@ public class HadoopJobTracker extends HadoopComponent {
 
             // Iteration over all local entries is correct since system cache is REPLICATED.
             for (Object metaObj : jobMetaCache().values()) {
+                if (!(metaObj instanceof HadoopJobMetadata))
+                    continue;
+
                 HadoopJobMetadata meta = (HadoopJobMetadata)metaObj;
 
                 HadoopJobId jobId = meta.jobId();


Mime
View raw message