sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: SQOOP-1025: Sqoop metadata upgrade must set job id in the new job being created
Date Wed, 01 May 2013 04:13:38 GMT
Updated Branches:
  refs/heads/sqoop2 7f1dc4045 -> 4f318755d


SQOOP-1025: Sqoop metadata upgrade must set job id in the new job being created

(Hari Shreedharan via Jarek Jarcec Cecho)


Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/4f318755
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/4f318755
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/4f318755

Branch: refs/heads/sqoop2
Commit: 4f318755dd32f19191682412739fee47da6fa8f0
Parents: 7f1dc40
Author: Jarek Jarcec Cecho <jarcec@apache.org>
Authored: Tue Apr 30 21:12:56 2013 -0700
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
Committed: Tue Apr 30 21:12:56 2013 -0700

----------------------------------------------------------------------
 .../org/apache/sqoop/repository/Repository.java    |    1 +
 1 files changed, 1 insertions(+), 0 deletions(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/sqoop/blob/4f318755/core/src/main/java/org/apache/sqoop/repository/Repository.java
----------------------------------------------------------------------
diff --git a/core/src/main/java/org/apache/sqoop/repository/Repository.java b/core/src/main/java/org/apache/sqoop/repository/Repository.java
index c820484..7a7e884 100644
--- a/core/src/main/java/org/apache/sqoop/repository/Repository.java
+++ b/core/src/main/java/org/apache/sqoop/repository/Repository.java
@@ -349,6 +349,7 @@ public abstract class Repository {
         upgrader.upgrade(job.getConnectorPart(), newJobForms);
         MJob newJob = new MJob(connectorID, job.getConnectionId(),
           job.getType(), newJobForms, job.getFrameworkPart());
+        newJob.setPersistenceId(job.getPersistenceId());
         updateJob(newJob, tx);
       }
       tx.commit();


Mime
View raw message