#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 <[email protected]> Authored: Fri Mar 27 14:12:25 2015 +0300 Committer: ivasilinets <[email protected]> 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();
