You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pig.apache.org by da...@apache.org on 2014/09/28 03:04:16 UTC
svn commit: r1628037 - in /pig/trunk: CHANGES.txt
contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java
Author: daijy
Date: Sun Sep 28 01:04:15 2014
New Revision: 1628037
URL: http://svn.apache.org/r1628037
Log:
PIG-4046: PiggyBank DBStorage DATETIME should use setTimestamp with java.sql.Timestamp
Modified:
pig/trunk/CHANGES.txt
pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java
Modified: pig/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/pig/trunk/CHANGES.txt?rev=1628037&r1=1628036&r2=1628037&view=diff
==============================================================================
--- pig/trunk/CHANGES.txt (original)
+++ pig/trunk/CHANGES.txt Sun Sep 28 01:04:15 2014
@@ -84,6 +84,8 @@ OPTIMIZATIONS
BUG FIXES
+PIG-4046: PiggyBank DBStorage DATETIME should use setTimestamp with java.sql.Timestamp (sinchii via daijy)
+
PIG-4050: HadoopShims.getTaskReports() can cause OOM with Hadoop 2 (rohini)
PIG-4176: Fix tez e2e test Bloom_[1-3] (daijy)
Modified: pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java
URL: http://svn.apache.org/viewvc/pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java?rev=1628037&r1=1628036&r2=1628037&view=diff
==============================================================================
--- pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java (original)
+++ pig/trunk/contrib/piggybank/java/src/main/java/org/apache/pig/piggybank/storage/DBStorage.java Sun Sep 28 01:04:15 2014
@@ -19,10 +19,10 @@ package org.apache.pig.piggybank.storage
import java.io.IOException;
import java.sql.Connection;
-import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
+import java.sql.Timestamp;
import java.util.Properties;
import org.apache.commons.logging.Log;
@@ -136,7 +136,7 @@ public class DBStorage extends StoreFunc
break;
case DataType.DATETIME:
- ps.setDate(sqlPos, new Date(((DateTime) field).getMillis()));
+ ps.setTimestamp(sqlPos, new Timestamp(((DateTime) field).getMillis()));
sqlPos++;
break;