(paimon) branch master updated: [core] Fix NumberFoematException of Dedicated Compaction (#5153)

[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 95ab66043f [core] Fix NumberFoematException of Dedicated Compaction 
(#5153)
95ab66043f is described below

commit 95ab66043ff3b36977254166e0b1a649a11ed731
Author: wangwj <hongli....@gmail.com>
AuthorDate: Thu Feb 27 12:09:32 2025 +0800

    [core] Fix NumberFoematException of Dedicated Compaction (#5153)
---
 .../java/org/apache/paimon/table/FallbackReadFileStoreTable.java     | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
 
b/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
index 535bd6a270..d6f073fd2c 100644
--- 
a/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
+++ 
b/paimon-core/src/main/java/org/apache/paimon/table/FallbackReadFileStoreTable.java
@@ -140,8 +140,9 @@ public class FallbackReadFileStoreTable extends 
DelegatedFileStoreTable {
         // so we need to convert main branch snapshot id to millisecond,
         // then convert millisecond to fallback branch snapshot id
         String scanSnapshotIdOptionKey = CoreOptions.SCAN_SNAPSHOT_ID.key();
-        if (options.containsKey(scanSnapshotIdOptionKey)) {
-            long id = Long.parseLong(options.get(scanSnapshotIdOptionKey));
+        String scanSnapshotId = options.get(scanSnapshotIdOptionKey);
+        if (scanSnapshotId != null) {
+            long id = Long.parseLong(scanSnapshotId);
             long millis = wrapped.snapshotManager().snapshot(id).timeMillis();
             Snapshot fallbackSnapshot = 
fallback.snapshotManager().earlierOrEqualTimeMills(millis);
             long fallbackId;