You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hive.apache.org by ha...@apache.org on 2012/01/29 17:34:20 UTC
svn commit: r1237329 -
/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Author: hashutosh
Date: Sun Jan 29 16:34:20 2012
New Revision: 1237329
URL: http://svn.apache.org/viewvc?rev=1237329&view=rev
Log:
HIVE-2735: PlanUtils.configureTableJobPropertiesForStorageHandler() is not called for partitioned table (sushanth via ashutosh)
Modified:
hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
Modified: hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java
URL: http://svn.apache.org/viewvc/hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java?rev=1237329&r1=1237328&r2=1237329&view=diff
==============================================================================
--- hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java (original)
+++ hive/trunk/ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java Sun Jan 29 16:34:20 2012
@@ -6991,6 +6991,14 @@ public class SemanticAnalyzer extends Ba
if (fetch.getTblDesc() != null) {
PlanUtils.configureTableJobPropertiesForStorageHandler(
fetch.getTblDesc());
+ } else if ( (fetch.getPartDesc() != null) && (!fetch.getPartDesc().isEmpty())){
+ PartitionDesc pd0 = fetch.getPartDesc().get(0);
+ TableDesc td = pd0.getTableDesc();
+ if ((td != null)&&(td.getProperties() != null)
+ && td.getProperties().containsKey(
+ org.apache.hadoop.hive.metastore.api.Constants.META_TABLE_STORAGE)){
+ PlanUtils.configureTableJobPropertiesForStorageHandler(td);
+ }
}
fetchTask = (FetchTask) TaskFactory.get(fetch, conf);
setFetchTask(fetchTask);