(fluss) branch main updated: [hotfix] Optimize the error msg when throwing LogOffsetOutOfRangeException (#1216)

[yunhong]

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

yunhong pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git


The following commit(s) were added to refs/heads/main by this push:
     new ee249b6c [hotfix] Optimize the error msg when throwing 
LogOffsetOutOfRangeException (#1216)
ee249b6c is described below

commit ee249b6cd24e84be4a0f082651ef19c919665e01
Author: yunhong <337361...@qq.com>
AuthorDate: Tue Jul 15 21:14:00 2025 +0800

    [hotfix] Optimize the error msg when throwing LogOffsetOutOfRangeException 
(#1216)
    
    * [hotfix] Optimize the error msg when throwing LogOffsetOutOfRangeException
    
    * address jark's comments
---
 .../client/table/scanner/log/LogFetchCollector.java      | 16 ++++++++++------
 1 file changed, 10 insertions(+), 6 deletions(-)

diff --git 
a/fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java
 
b/fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java
index f30e1de2..f847ac04 100644
--- 
a/fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java
+++ 
b/fluss-client/src/main/java/com/alibaba/fluss/client/table/scanner/log/LogFetchCollector.java
@@ -256,15 +256,19 @@ public class LogFetchCollector {
                 || error == Errors.STORAGE_EXCEPTION
                 || error == Errors.FENCED_LEADER_EPOCH_EXCEPTION) {
             LOG.debug(
-                    "Error in fetch for bucket {}: {}:{}", tb, 
error.exceptionName(), errorMessage);
+                    "Error in fetch for bucket {}: {}:{}",
+                    tb,
+                    error.exceptionName(),
+                    error.exception(errorMessage));
             metadataUpdater.checkAndUpdateMetadata(tablePath, tb);
         } else if (error == Errors.UNKNOWN_TABLE_OR_BUCKET_EXCEPTION) {
             LOG.warn("Received unknown table or bucket error in fetch for 
bucket {}", tb);
             metadataUpdater.checkAndUpdateMetadata(tablePath, tb);
         } else if (error == Errors.LOG_OFFSET_OUT_OF_RANGE_EXCEPTION) {
             throw new FetchException(
-                    String.format("The fetching offset %s is out of range", 
fetchOffset),
-                    error.exception());
+                    String.format(
+                            "The fetching offset %s is out of range: %s",
+                            fetchOffset, error.exception(errorMessage)));
         } else if (error == Errors.AUTHORIZATION_EXCEPTION) {
             throw new AuthorizationException(errorMessage);
         } else if (error == Errors.UNKNOWN_SERVER_ERROR) {
@@ -272,17 +276,17 @@ public class LogFetchCollector {
                     "Unknown server error while fetching offset {} for bucket 
{}: {}",
                     fetchOffset,
                     tb,
-                    errorMessage);
+                    error.exception(errorMessage));
         } else if (error == Errors.CORRUPT_MESSAGE) {
             throw new FetchException(
                     String.format(
                             "Encountered corrupt message when fetching offset 
%s for bucket %s: %s",
-                            fetchOffset, tb, errorMessage));
+                            fetchOffset, tb, error.exception(errorMessage)));
         } else {
             throw new FetchException(
                     String.format(
                             "Unexpected error code %s while fetching at offset 
%s from bucket %s: %s",
-                            error, fetchOffset, tb, errorMessage));
+                            error, fetchOffset, tb, 
error.exception(errorMessage)));
         }
     }
 }