Repository: sqoop Updated Branches: refs/heads/sqoop2 1f4b7fd29 -> 1675c512a
SQOOP-1843: Sqoop2: Fix timestamp type casting (Veena Basavaraj via Abraham Elmahrek) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/1675c512 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/1675c512 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/1675c512 Branch: refs/heads/sqoop2 Commit: 1675c512ad3ac1bc4829a923759015edb9505db1 Parents: 1f4b7fd Author: Abraham Elmahrek <[email protected]> Authored: Wed Dec 3 18:30:34 2014 -0800 Committer: Abraham Elmahrek <[email protected]> Committed: Wed Dec 3 18:30:34 2014 -0800 ---------------------------------------------------------------------- .../org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/1675c512/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java ---------------------------------------------------------------------- diff --git a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java index 9a61701..ab1c64a 100644 --- a/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java +++ b/connector/connector-generic-jdbc/src/main/java/org/apache/sqoop/connector/jdbc/GenericJdbcExtractor.java @@ -81,11 +81,11 @@ public class GenericJdbcExtractor extends Extractor<LinkConfiguration, FromJobCo break; case DATE_TIME: // convert the sql date time to JODA time as prescribed the Sqoop IDF spec - array[i] = LocalDateTime.fromDateFields((java.sql.Date)resultSet.getObject(i + 1)); + array[i] = LocalDateTime.fromDateFields((java.sql.Timestamp)resultSet.getObject(i + 1)); break; case TIME: // convert the sql time to JODA time as prescribed the Sqoop IDF spec - array[i] = LocalTime.fromDateFields((java.sql.Date)resultSet.getObject(i + 1)); + array[i] = LocalTime.fromDateFields((java.sql.Time)resultSet.getObject(i + 1)); break; default: //for anything else
