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 <[email protected]> Authored: Tue Apr 30 21:12:56 2013 -0700 Committer: Jarek Jarcec Cecho <[email protected]> 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();
