hive-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From br...@apache.org
Subject svn commit: r1659028 - in /hive/branches/branch-1.1: ./ ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Date Wed, 11 Feb 2015 18:10:57 GMT
Author: brock
Date: Wed Feb 11 18:10:56 2015
New Revision: 1659028

URL: http://svn.apache.org/r1659028
Log:
HIVE-9651 - FileSinkOperator does not pass in conf to serde.initialize (Brock via Szehon)

Modified:
    hive/branches/branch-1.1/   (props changed)
    hive/branches/branch-1.1/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java

Propchange: hive/branches/branch-1.1/
------------------------------------------------------------------------------
--- svn:mergeinfo (original)
+++ svn:mergeinfo Wed Feb 11 18:10:56 2015
@@ -3,4 +3,4 @@
 /hive/branches/spark:1608589-1654414,1654553,1654869,1654873,1655427,1655468,1655926,1658877
 /hive/branches/tez:1494760-1622766
 /hive/branches/vectorization:1466908-1527856
-/hive/trunk:1655202,1655210,1655213,1655436,1655460,1655894-1655895,1656061,1656114,1656234,1656780,1657990,1658221,1658471,1658766
+/hive/trunk:1655202,1655210,1655213,1655436,1655460,1655894-1655895,1656061,1656114,1656234,1656780,1657990,1658221,1658471,1658766,1659027

Modified: hive/branches/branch-1.1/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
URL: http://svn.apache.org/viewvc/hive/branches/branch-1.1/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java?rev=1659028&r1=1659027&r2=1659028&view=diff
==============================================================================
--- hive/branches/branch-1.1/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
(original)
+++ hive/branches/branch-1.1/ql/src/java/org/apache/hadoop/hive/ql/exec/FileSinkOperator.java
Wed Feb 11 18:10:56 2015
@@ -341,7 +341,7 @@ public class FileSinkOperator extends Te
       statsCollectRawDataSize = conf.isStatsCollectRawDataSize();
       statsFromRecordWriter = new boolean[numFiles];
       serializer = (Serializer) conf.getTableInfo().getDeserializerClass().newInstance();
-      serializer.initialize(null, conf.getTableInfo().getProperties());
+      serializer.initialize(hconf, conf.getTableInfo().getProperties());
       outputClass = serializer.getSerializedClass();
 
       if (isLogInfoEnabled) {



Mime
View raw message