Skip to content

Commit 1401223

Browse files
committed
fix
1 parent 44e101a commit 1401223

File tree

1 file changed

+1
-8
lines changed

1 file changed

+1
-8
lines changed

paimon-core/src/main/java/org/apache/paimon/rest/RESTCatalog.java

Lines changed: 1 addition & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -657,14 +657,7 @@ public List<Partition> listPartitionsByNames(
657657
} catch (ForbiddenException e) {
658658
throw new TableNoPermissionException(identifier, e);
659659
} catch (NotImplementedException e) {
660-
// not a metastore partitioned table, filter from file system partitions
661-
List<Partition> allPartitions = listPartitionsFromFileSystem(getTable(identifier));
662-
return allPartitions.stream()
663-
.filter(
664-
partition ->
665-
partitions.stream()
666-
.anyMatch(spec -> partition.spec().equals(spec)))
667-
.collect(java.util.stream.Collectors.toList());
660+
return listPartitionsFromFileSystem(getTable(identifier), partitions);
668661
}
669662
}
670663

0 commit comments

Comments
 (0)