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 1f9fb3b897..8787ca5700 100644 --- ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java +++ ql/src/java/org/apache/hadoop/hive/ql/metadata/Hive.java @@ -2876,13 +2876,10 @@ private void constructOneLBLocationMap(FileStatus fSta, // calculate full path spec for each valid partition path validPartitions.forEach(partPath -> { Map fullPartSpec = Maps.newLinkedHashMap(partSpec); - if (!Warehouse.makeSpecFromName(fullPartSpec, partPath, new HashSet<>(partSpec.keySet()))) { - Utilities.FILE_OP_LOGGER.warn("Ignoring invalid DP directory " + partPath); - } else { - PartitionDetails details = new PartitionDetails(); - details.fullSpec = fullPartSpec; - partitionDetailsMap.put(partPath, details); - } + Warehouse.makeSpecFromName(fullPartSpec, partPath, new HashSet<>(partSpec.keySet())); + PartitionDetails details = new PartitionDetails(); + details.fullSpec = fullPartSpec; + partitionDetailsMap.put(partPath, details); }); // fetch all the partitions matching the part spec using the partition iterable