Repository: incubator-ignite Updated Branches: refs/heads/ignite-143 88e6ff5e6 -> cba8e1a09
# IGNITE-143 - Fixing tests Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/cba8e1a0 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/cba8e1a0 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/cba8e1a0 Branch: refs/heads/ignite-143 Commit: cba8e1a099ea64455c9a55fe106fd527dc4faf21 Parents: 88e6ff5 Author: Valentin Kulichenko <vkuliche...@gridgain.com> Authored: Thu Feb 12 19:01:52 2015 -0800 Committer: Valentin Kulichenko <vkuliche...@gridgain.com> Committed: Thu Feb 12 19:01:52 2015 -0800 ---------------------------------------------------------------------- .../processors/hadoop/jobtracker/GridHadoopJobTracker.java | 7 +------ 1 file changed, 1 insertion(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/cba8e1a0/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/GridHadoopJobTracker.java ---------------------------------------------------------------------- diff --git a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/GridHadoopJobTracker.java b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/GridHadoopJobTracker.java index 6b2d302..6ec4058 100644 --- a/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/GridHadoopJobTracker.java +++ b/modules/hadoop/src/main/java/org/apache/ignite/internal/processors/hadoop/jobtracker/GridHadoopJobTracker.java @@ -82,9 +82,6 @@ public class GridHadoopJobTracker extends GridHadoopComponent { /** Component busy lock. */ private GridSpinReadWriteLock busyLock; - /** Job meta query ID. */ - private UUID jobMetaQryId; - /** Closure to check result of async transform of system cache. */ private final IgniteInClosure<IgniteInternalFuture<?>> failsLog = new CI1<IgniteInternalFuture<?>>() { @Override public void apply(IgniteInternalFuture<?> gridFut) { @@ -172,7 +169,7 @@ public class GridHadoopJobTracker extends GridHadoopComponent { @Override public void onKernalStart() throws IgniteCheckedException { super.onKernalStart(); - jobMetaQryId = jobMetaCache().context().continuousQueries().executeInternalQuery( + jobMetaCache().context().continuousQueries().executeInternalQuery( new CacheEntryUpdatedListener<GridHadoopJobId, GridHadoopJobMetadata>() { @Override public void onUpdated(final Iterable<CacheEntryEvent<? extends GridHadoopJobId, ? extends GridHadoopJobMetadata>> evts) { @@ -227,8 +224,6 @@ public class GridHadoopJobTracker extends GridHadoopComponent { // Fail all pending futures. for (GridFutureAdapter<GridHadoopJobId> fut : activeFinishFuts.values()) fut.onDone(new IgniteCheckedException("Failed to execute Hadoop map-reduce job (grid is stopping).")); - - jobMetaCache().context().continuousQueries().cancelInternalQuery(jobMetaQryId); } /**
