You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hdt.apache.org by rs...@apache.org on 2014/06/20 13:01:06 UTC

git commit: HDT-51 : trival convertion of string to JobId

Repository: incubator-hdt
Updated Branches:
  refs/heads/hadoop-eclipse-merge-development bf1a49495 -> b6634e66d


HDT-51 : trival convertion of string to JobId


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

Branch: refs/heads/hadoop-eclipse-merge-development
Commit: b6634e66d7098b498755634f08bd18c1b49db846
Parents: bf1a494
Author: Rahul Sharma <rs...@apache.org>
Authored: Fri Jun 20 14:59:24 2014 +0530
Committer: Rahul Sharma <rs...@apache.org>
Committed: Fri Jun 20 14:59:24 2014 +0530

----------------------------------------------------------------------
 .../src/org/apache/hdt/hadoop/release/HadoopCluster.java           | 2 +-
 .../src/org/apache/hdt/hadoop2/release/HadoopCluster.java          | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-hdt/blob/b6634e66/org.apache.hdt.hadoop.release/src/org/apache/hdt/hadoop/release/HadoopCluster.java
----------------------------------------------------------------------
diff --git a/org.apache.hdt.hadoop.release/src/org/apache/hdt/hadoop/release/HadoopCluster.java b/org.apache.hdt.hadoop.release/src/org/apache/hdt/hadoop/release/HadoopCluster.java
index 54c5500..c64f757 100644
--- a/org.apache.hdt.hadoop.release/src/org/apache/hdt/hadoop/release/HadoopCluster.java
+++ b/org.apache.hdt.hadoop.release/src/org/apache/hdt/hadoop/release/HadoopCluster.java
@@ -274,7 +274,7 @@ public class HadoopCluster extends AbstractHadoopCluster {
 	 *            the job to remove
 	 */
 	public void purgeJob(final IHadoopJob job) {
-		runningJobs.remove(job.getJobID());
+		runningJobs.remove(JobID.forName(job.getJobID()));
 		Display.getDefault().asyncExec(new Runnable() {
 			public void run() {
 				fireJobRemoved(job);

http://git-wip-us.apache.org/repos/asf/incubator-hdt/blob/b6634e66/org.apache.hdt.hadoop2.release/src/org/apache/hdt/hadoop2/release/HadoopCluster.java
----------------------------------------------------------------------
diff --git a/org.apache.hdt.hadoop2.release/src/org/apache/hdt/hadoop2/release/HadoopCluster.java b/org.apache.hdt.hadoop2.release/src/org/apache/hdt/hadoop2/release/HadoopCluster.java
index cf4dcd4..d18679a 100644
--- a/org.apache.hdt.hadoop2.release/src/org/apache/hdt/hadoop2/release/HadoopCluster.java
+++ b/org.apache.hdt.hadoop2.release/src/org/apache/hdt/hadoop2/release/HadoopCluster.java
@@ -271,7 +271,7 @@ public class HadoopCluster extends AbstractHadoopCluster {
 	 *            the job to remove
 	 */
 	public void purgeJob(final IHadoopJob job) {
-		runningJobs.remove(job.getJobID());
+		runningJobs.remove(JobID.forName(job.getJobID()));
 		Display.getDefault().asyncExec(new Runnable() {
 			public void run() {
 				fireJobRemoved(job);