(paimon) branch master updated: [core] Ignore beforeFiles on initial refresh for LocalTableQuery (#6099)

[lzljs3620320]

This is an automated email from the ASF dual-hosted git repository.

lzljs3620320 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/paimon.git


The following commit(s) were added to refs/heads/master by this push:
     new 649a53de9a [core] Ignore beforeFiles on initial refresh for 
LocalTableQuery (#6099)
649a53de9a is described below

commit 649a53de9a24022a1a1a2d3f840d4036079cb864
Author: Arnav Balyan <60175178+arnavbal...@users.noreply.github.com>
AuthorDate: Tue Aug 19 19:47:43 2025 +0530

    [core] Ignore beforeFiles on initial refresh for LocalTableQuery (#6099)
---
 .../src/main/java/org/apache/paimon/table/query/LocalTableQuery.java  | 4 +---
 1 file changed, 1 insertion(+), 3 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java 
b/paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java
index 4b89a48464..7e0cbc62f3 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/query/LocalTableQuery.java
@@ -115,9 +115,7 @@ public class LocalTableQuery implements TableQuery {
         LookupLevels<KeyValue> lookupLevels =
                 tableView.computeIfAbsent(partition, k -> new 
HashMap<>()).get(bucket);
         if (lookupLevels == null) {
-            Preconditions.checkArgument(
-                    beforeFiles.isEmpty(),
-                    "The before file should be empty for the initial phase.");
+            // Initial phase: ignore beforeFiles as they represent deletions 
from previous state
             newLookupLevels(partition, bucket, dataFiles);
         } else {
             lookupLevels.getLevels().update(beforeFiles, dataFiles);