You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ka...@apache.org on 2013/04/15 17:51:50 UTC
git commit: SQOOP-967: Sqoop2: Introduce dummy configuration key to
easily identify Sqoop2 job
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 <ka...@apache.org>
Authored: Mon Apr 15 11:50:52 2013 -0400
Committer: Kate Ting <ka...@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));