fix comment

apache · Sep 19, 2024 · c8358d0 · c8358d0
1 parent aae1b66
commit c8358d0
Showing 1 changed file with 3 additions and 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
@@ -180,7 +180,9 @@ public InnerTableScan withFilter(Predicate pushdown) {
         @Override
         public Plan innerPlan() {
             List<BinaryRow> 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();