Repository: incubator-ignite Updated Branches: refs/heads/ignite-611 2962b7689 -> 684db5218
# ignite-611 do not need filter since only HadoopJobMetadata is stored in hadoop cache Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/684db521 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/684db521 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/684db521 Branch: refs/heads/ignite-611 Commit: 684db5218db2dff143ba392fa46df933aa0a72c0 Parents: 2962b76 Author: sboikov <sboi...@gridgain.com> Authored: Fri Mar 27 14:59:03 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Mar 27 14:59:03 2015 +0300 ---------------------------------------------------------------------- .../internal/processors/hadoop/jobtracker/HadoopJobTracker.java | 3 --- 1 file changed, 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/684db521/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 1eef8ed..433b84f 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,9 +557,6 @@ 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();
