svn commit: r1230842 - in /incubator/hcatalog/trunk: CHANGES.txt src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java

[khorgath]

Author: khorgath
Date: Thu Jan 12 23:57:45 2012
New Revision: 1230842

URL: http://svn.apache.org/viewvc?rev=1230842&view=rev
Log:
HCATALOG-199 HCatOutputCommitter::cleanupJob() fails : Unable to connect to 
metastore.

Modified:
    incubator/hcatalog/trunk/CHANGES.txt
    
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java

Modified: incubator/hcatalog/trunk/CHANGES.txt
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/CHANGES.txt?rev=1230842&r1=1230841&r2=1230842&view=diff
==============================================================================
--- incubator/hcatalog/trunk/CHANGES.txt (original)
+++ incubator/hcatalog/trunk/CHANGES.txt Thu Jan 12 23:57:45 2012
@@ -93,6 +93,8 @@ Trunk (unreleased changes)
   OPTIMIZATIONS
 
   BUG FIXES
+  HCAT-199. HCatOutputCommitter::cleanupJob() fails : Unable to connect to 
metastore. (mithun via khorgath)
+
   HCAT-197. data generator for e2e assumes hadoop tarball installation 
(arpitgupta via hashutosh)  
 
   HCAT-202. ant clean target is failing (thw via hashutosh)

Modified: 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
URL: 
http://svn.apache.org/viewvc/incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java?rev=1230842&r1=1230841&r2=1230842&view=diff
==============================================================================
--- 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
 (original)
+++ 
incubator/hcatalog/trunk/src/java/org/apache/hcatalog/mapreduce/HCatOutputFormat.java
 Thu Jan 12 23:57:45 2012
@@ -261,9 +261,6 @@ public class HCatOutputFormat extends HC
             hiveConf.setBoolean(ConfVars.METASTORE_USE_THRIFT_SASL.varname, 
true);
             hiveConf.set(ConfVars.METASTORE_KERBEROS_PRINCIPAL.varname, 
kerberosPrincipal);
         }
-        if(conf.get(HCatConstants.HCAT_KEY_TOKEN_SIGNATURE) != null) {
-          hiveConf.set("hive.metastore.token.signature", 
conf.get(HCatConstants.HCAT_KEY_TOKEN_SIGNATURE));
-        }
       } else {
         //Thrift url is null, copy the hive conf into the job conf and restore 
it
         //in the backend context
@@ -291,6 +288,10 @@ public class HCatOutputFormat extends HC
 
       }
 
+      if(conf.get(HCatConstants.HCAT_KEY_TOKEN_SIGNATURE) != null) {
+        hiveConf.set("hive.metastore.token.signature", 
conf.get(HCatConstants.HCAT_KEY_TOKEN_SIGNATURE));
+      }
+
       // figure out what the maximum number of partitions allowed is, so we 
can pass it on to our outputinfo
       if (HCatConstants.HCAT_IS_DYNAMIC_MAX_PTN_CHECK_ENABLED){
         maxDynamicPartitions = 
hiveConf.getIntVar(HiveConf.ConfVars.DYNAMICPARTITIONMAXPARTS);