diff --git a/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java b/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java index b44926ff9a22..8dcf69a923d3 100644 --- a/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java +++ b/paimon-core/src/main/java/org/apache/paimon/table/system/FilesTable.java @@ -180,7 +180,9 @@ public InnerTableScan withFilter(Predicate pushdown) { @Override public Plan innerPlan() { List partitions = new ArrayList<>(); - if (partitionPredicate != null && partitionPredicate.function() instanceof Equal) { + if (partitionPredicate != null + && fileStoreTable.partitionKeys().isEmpty() + && partitionPredicate.function() instanceof Equal) { GenericRow partitionRow = new GenericRow(fileStoreTable.partitionKeys().size()); RowType partitionRowType = fileStoreTable.schema().logicalPartitionType(); String partitionStr = partitionPredicate.literals().get(0).toString();