You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@sqoop.apache.org by ab...@apache.org on 2014/12/04 03:45:21 UTC
sqoop git commit: SQOOP-1843: Sqoop2: Fix timestamp type casting
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 <ab...@elmahrek.com>
Authored: Wed Dec 3 18:30:34 2014 -0800
Committer: Abraham Elmahrek <ab...@elmahrek.com>
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