diff --git a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetastoreDefaultTransformer.java b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetastoreDefaultTransformer.java index 8d018d759fe3db4b6ed5a607110ee2191bdfa945..2a6d72fef46b4b1ed7e10dbcf6f85d0b5fee03d4 100644 --- a/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetastoreDefaultTransformer.java +++ b/standalone-metastore/metastore-server/src/main/java/org/apache/hadoop/hive/metastore/MetastoreDefaultTransformer.java @@ -109,7 +109,7 @@ public MetastoreDefaultTransformer(IHMSHandler handler) throws HiveMetaException Map params = table.getParameters(); String tableType = table.getTableType(); String tCapabilities = params.get(OBJCAPABILITIES); - int numBuckets = table.getSd().getNumBuckets(); + int numBuckets = table.isSetSd()? table.getSd().getNumBuckets() : 0; boolean isBucketed = (numBuckets > 0) ? true : false; LOG.info("Table " + table.getTableName() + ",#bucket=" + numBuckets + ",isBucketed:" + isBucketed + ",tableType=" + tableType + ",tableCapabilities=" + tCapabilities); @@ -466,6 +466,8 @@ public MetastoreDefaultTransformer(IHMSHandler handler) throws HiveMetaException if (partition.getSd() != null) { partBuckets = partition.getSd().getNumBuckets(); LOG.info("Number of original part buckets=" + partBuckets); + } else { + partBuckets = 0; } if (tCapabilities == null) {