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 <[email protected]> Authored: Fri Mar 1 16:20:10 2013 -0800 Committer: Cheolsoo Park <[email protected]> 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; + } } }
