svn commit: r724517 - in /hadoop/hive/trunk: CHANGES.txt ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java

[zs...@apache.org]

Author: zshao
Date: Mon Dec  8 14:21:25 2008
New Revision: 724517

URL: http://svn.apache.org/viewvc?rev=724517&view=rev
Log:
HIVE-127. Fetch Task to pass the jobconf to SerDe. (Namit through zshao)

Modified:
    hadoop/hive/trunk/CHANGES.txt
    hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java

Modified: hadoop/hive/trunk/CHANGES.txt
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/CHANGES.txt?rev=724517&r1=724516&r2=724517&view=diff
==============================================================================
--- hadoop/hive/trunk/CHANGES.txt (original)
+++ hadoop/hive/trunk/CHANGES.txt Mon Dec  8 14:21:25 2008
@@ -30,6 +30,8 @@
 
   BUG FIXES
 
+    HIVE-127. Fetch Task to pass the jobconf to SerDe. (Namit through zshao)
+
     HIVE-116. Let test depend on deploy. (Johan Oskarsson through zshao)
 
     HIVE-90. Fixed TestGetDBs for File.list() order.

Modified: hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java
URL: http://svn.apache.org/viewvc/hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java?rev=724517&r1=724516&r2=724517&view=diff
==============================================================================
--- hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java (original)
+++ hadoop/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/exec/FetchTask.java Mon Dec  8 14:21:25 2008
@@ -77,7 +77,7 @@
        Properties mSerdeProp = new Properties();
        mSerdeProp.put(Constants.SERIALIZATION_FORMAT, "" + Utilities.tabCode);
        mSerdeProp.put(Constants.SERIALIZATION_NULL_FORMAT, "NULL");
-       mSerde.initialize(null, mSerdeProp);
+       mSerde.initialize(job, mSerdeProp);
        
        currPath = null;
        currTbl = null;
@@ -231,7 +231,7 @@
  			inputSplits = inputFormat.getSplits(job, 1); 		
  			splitNum = 0;
       serde = tmp.getDeserializerClass().newInstance();
-      serde.initialize(null, tmp.getProperties());
+      serde.initialize(job, tmp.getProperties());
       LOG.debug("Creating fetchTask with deserializer typeinfo: " + serde.getObjectInspector().getTypeName());
       LOG.debug("deserializer properties: " + tmp.getProperties());
       if (!tblDataDone)