hdt-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rsha...@apache.org
Subject [19/27] git commit: HDT-51 : trival convertion of string to JobId
Date Thu, 26 Jun 2014 08:36:42 GMT
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
Commit: b6634e66d7098b498755634f08bd18c1b49db846
Parents: bf1a494
Author: Rahul Sharma <rsharma@apache.org>
Authored: Fri Jun 20 14:59:24 2014 +0530
Committer: Rahul Sharma <rsharma@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);


Mime
View raw message