diff --git a/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java b/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java index 8e0bba6..c135179 100644 --- a/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java +++ b/metastore/src/java/org/apache/hadoop/hive/metastore/MetaStoreDirectSql.java @@ -852,6 +852,7 @@ private int getNumPartitionsViaSqlFilterInternal(String dbName, String tblName, long start = doTrace ? System.nanoTime() : 0; Query query = pm.newQuery("javax.jdo.query.SQL", queryText); + query.setUnique(true); int sqlResult = extractSqlInt(query.executeWithArray(params)); long queryTime = doTrace ? System.nanoTime() : 0; timingTrace(doTrace, queryText, start, queryTime);