sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kathl...@apache.org
Subject git commit: SQOOP-967: Sqoop2: Introduce dummy configuration key to easily identify Sqoop2 job
Date Mon, 15 Apr 2013 15:51:50 GMT
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 <kathleen@apache.org>
Authored: Mon Apr 15 11:50:52 2013 -0400
Committer: Kate Ting <kathleen@apache.org>
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));


Mime
View raw message