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();
|