diff --git ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java index b0f124b..06ae2e9 100644 --- ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -78,6 +78,7 @@ import org.apache.hadoop.hive.metastore.api.SerDeInfo; import org.apache.hadoop.hive.metastore.api.SkewedInfo; import org.apache.hadoop.hive.metastore.api.hive_metastoreConstants; +import org.apache.hadoop.hive.ql.ErrorMsg; import org.apache.hadoop.hive.ql.exec.Utilities; import org.apache.hadoop.hive.ql.index.HiveIndexHandler; import org.apache.hadoop.hive.ql.optimizer.listbucketingpruner.ListBucketingPrunerUtils; @@ -1764,8 +1765,7 @@ public boolean dropPartition(String db_name, String tbl_name, short limit) throws HiveException { if (!tbl.isPartitioned()) { - throw new HiveException("Partition spec should only be supplied for a " + - "partitioned table"); + throw new HiveException(ErrorMsg.TABLE_NOT_PARTITIONED, tbl.getTableName()); } List partialPvals = MetaStoreUtils.getPvals(tbl.getPartCols(), partialPartSpec); @@ -1818,8 +1818,7 @@ public boolean dropPartition(String db_name, String tbl_name, throws HiveException { if (!tbl.isPartitioned()) { - throw new HiveException("Partition spec should only be supplied for a " + - "partitioned table"); + throw new HiveException(ErrorMsg.TABLE_NOT_PARTITIONED, tbl.getTableName()); } List names = getPartitionNames(tbl.getDbName(), tbl.getTableName(), @@ -1843,8 +1842,7 @@ public boolean dropPartition(String db_name, String tbl_name, throws HiveException { if (!tbl.isPartitioned()) { - throw new HiveException("Partition spec should only be supplied for a " + - "partitioned table"); + throw new HiveException(ErrorMsg.TABLE_NOT_PARTITIONED, tbl.getTableName()); } List partitions = new ArrayList(partNames.size()); @@ -1895,8 +1893,7 @@ public boolean dropPartition(String db_name, String tbl_name, throws HiveException, MetaException, NoSuchObjectException, TException { if (!tbl.isPartitioned()) { - throw new HiveException("Partition spec should only be supplied for a " + - "partitioned table"); + throw new HiveException(ErrorMsg.TABLE_NOT_PARTITIONED, tbl.getTableName()); } List tParts = getMSC().listPartitionsByFilter( diff --git ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java index 037191a..d00d173 100644 --- ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java +++ ql/src/java/org/apache/hadoop/hive/ql/parse/DDLSemanticAnalyzer.java @@ -128,7 +128,6 @@ import org.apache.hadoop.hive.serde.serdeConstants; import org.apache.hadoop.hive.serde2.lazy.LazySimpleSerDe; import org.apache.hadoop.hive.serde2.objectinspector.PrimitiveObjectInspector.PrimitiveCategory; -import org.apache.hadoop.hive.serde2.objectinspector.primitive.PrimitiveObjectInspectorUtils; import org.apache.hadoop.hive.serde2.typeinfo.VarcharTypeInfo; import org.apache.hadoop.mapred.InputFormat; import org.apache.hadoop.mapred.TextInputFormat; @@ -2933,6 +2932,7 @@ private void addTablePartsOutputs(String tblName, List> part parts = db.getPartitions(tab, partSpec); } catch (HiveException e) { LOG.error("Got HiveException during obtaining list of partitions"); + throw new SemanticException(e.getMessage(), e); } } else { parts = new ArrayList(); @@ -2943,6 +2943,7 @@ private void addTablePartsOutputs(String tblName, List> part } } catch (HiveException e) { LOG.debug("Wrong specification"); + throw new SemanticException(e.getMessage(), e); } } if (parts.isEmpty()) {