Updated Branches: refs/heads/sqoop2 5c90d407f -> 53cb6caa7
SQOOP-781 Improve logging in GenericJdbcImportInitializer (Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/53cb6caa Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/53cb6caa Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/53cb6caa Branch: refs/heads/sqoop2 Commit: 53cb6caa705d1c6bcb52e0f61896d546b4d68220 Parents: 5c90d40 Author: Bilung Lee <[email protected]> Authored: Mon Dec 17 13:24:40 2012 -0800 Committer: Bilung Lee <[email protected]> Committed: Mon Dec 17 13:31:18 2012 -0800 ---------------------------------------------------------------------- .../jdbc/GenericJdbcImportInitializer.java | 24 ++++++++------- 1 files changed, 13 insertions(+), 11 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/53cb6caa/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportInitializer.java ---------------------------------------------------------------------- diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportInitializer.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportInitializer.java index 3ce6bb9..3b697b6 100644 --- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportInitializer.java +++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcImportInitializer.java @@ -191,15 +191,15 @@ public class GenericJdbcImportInitializer extends Initializer { rs.next(); - context.setString( - GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_COLUMNTYPE, - String.valueOf(rsmd.getColumnType(1))); - context.setString( - GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_MINVALUE, - rs.getString(1)); - context.setString( - GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_MAXVALUE, - rs.getString(2)); + int columnType = rsmd.getColumnType(1); + String min = rs.getString(1); + String max = rs.getString(2); + + LOG.info("Boundaries: min=" + min + ", max=" + max + ", columnType=" + columnType); + + context.setInteger(GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_COLUMNTYPE, columnType); + context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_MINVALUE, min); + context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_PARTITION_MAXVALUE, max); } catch (SQLException e) { throw new SqoopException( @@ -290,8 +290,10 @@ public class GenericJdbcImportInitializer extends Initializer { GenericJdbcConnectorError.GENERIC_JDBC_CONNECTOR_0008); } - context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL, - dataSql.toString()); + LOG.info("Using dataSql: " + dataSql); + LOG.info("Field names: " + fieldNames); + + context.setString(GenericJdbcConnectorConstants.CONNECTOR_JDBC_DATA_SQL, dataSql); context.setString(Constants.JOB_ETL_FIELD_NAMES, fieldNames); } }
