From c8358d00c7195c56e04faf7d1036a9b8db6c22b6 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E4=BB=9F=E5=BC=8B?= Date: Thu, 19 Sep 2024 16:42:32 +0800 Subject: [PATCH] fix comment --- .../main/java/org/apache/paimon/table/system/FilesTable.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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();