You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ch...@apache.org on 2013/03/02 01:25:45 UTC
[2/2] git commit: SQOOP-907: Print out queries executed by Sqoop on
mapreduce job side
Updated Branches:
refs/heads/trunk 4aa174abe -> f4d5ed537
SQOOP-907: Print out queries executed by Sqoop on mapreduce job side
(Jarcec Cecho via Cheolsoo Park)
Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo
Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/f4d5ed53
Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/f4d5ed53
Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/f4d5ed53
Branch: refs/heads/trunk
Commit: f4d5ed5375a7c4f94646ae0faa815b63ad641343
Parents: 1d9339d
Author: Cheolsoo Park <ch...@apache.org>
Authored: Fri Mar 1 16:20:10 2013 -0800
Committer: Cheolsoo Park <ch...@apache.org>
Committed: Fri Mar 1 16:20:10 2013 -0800
----------------------------------------------------------------------
.../apache/sqoop/mapreduce/db/DBRecordReader.java | 3 ++-
.../mapreduce/db/DataDrivenDBInputFormat.java | 5 +++++
2 files changed, 7 insertions(+), 1 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/sqoop/blob/f4d5ed53/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
index 4c03c0d..ab8bf18 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/DBRecordReader.java
@@ -107,7 +107,7 @@ public class DBRecordReader<T extends DBWritable> extends
statement.setFetchSize(fetchSize);
}
- LOG.debug("Executing query: " + query);
+ LOG.info("Executing query: " + query);
return statement.executeQuery();
}
@@ -233,6 +233,7 @@ public class DBRecordReader<T extends DBWritable> extends
}
if (null == this.results) {
// First time into this method, run the query.
+ LOG.info("Working on split: " + split);
this.results = executeQuery(getSelectQuery());
}
if (!results.next()) {
http://git-wip-us.apache.org/repos/asf/sqoop/blob/f4d5ed53/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
----------------------------------------------------------------------
diff --git a/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java b/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
index 140517a..81677d7 100644
--- a/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
+++ b/src/java/org/apache/sqoop/mapreduce/db/DataDrivenDBInputFormat.java
@@ -352,6 +352,11 @@ public class DataDrivenDBInputFormat<T extends DBWritable>
public String getUpperClause() {
return upperBoundClause;
}
+
+ @Override
+ public String toString() {
+ return this.lowerBoundClause + " AND " + this.upperBoundClause;
+ }
}
}