Updated Branches: refs/heads/sqoop2 a82878bc7 -> 722e6480e
SQOOP-967: Sqoop2: Introduce dummy configuration key to easily identify Sqoop2 job (Jarek Jarcec Cecho via Kate Ting) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/722e6480 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/722e6480 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/722e6480 Branch: refs/heads/sqoop2 Commit: 722e6480ea5fb1d7f7b221d478e68ff239583c80 Parents: a82878b Author: Kate Ting <[email protected]> Authored: Mon Apr 15 11:50:52 2013 -0400 Committer: Kate Ting <[email protected]> Committed: Mon Apr 15 11:50:52 2013 -0400 ---------------------------------------------------------------------- .../sqoop/submission/mapreduce/Constants.java | 2 ++ .../mapreduce/MapreduceSubmissionEngine.java | 3 +++ 2 files changed, 5 insertions(+), 0 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/722e6480/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/Constants.java ---------------------------------------------------------------------- diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/Constants.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/Constants.java index e562701..93b0725 100644 --- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/Constants.java +++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/Constants.java @@ -27,6 +27,8 @@ public class Constants { public static final String CONF_CONFIG_DIR = PREFIX_MAPREDUCE + "configuration.directory"; + public static final String SQOOP_JOB = "sqoop.job"; + private Constants() { // Instantiation is prohibited } http://git-wip-us.apache.org/repos/asf/sqoop/blob/722e6480/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java ---------------------------------------------------------------------- diff --git a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java index dd7b9e7..6607885 100644 --- a/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java +++ b/submission/mapreduce/src/main/java/org/apache/sqoop/submission/mapreduce/MapreduceSubmissionEngine.java @@ -108,6 +108,9 @@ public class MapreduceSubmissionEngine extends SubmissionEngine { } } + // Save our own property inside the job to easily identify Sqoop jobs + globalConfiguration.setBoolean(Constants.SQOOP_JOB, true); + // Create job client try { jobClient = new JobClient(new JobConf(globalConfiguration));
