From cc9db90b19115e41c5a64c41d5dbc84b5f136a60 Mon Sep 17 00:00:00 2001 From: zhangjunfan Date: Fri, 17 Apr 2026 16:05:09 +0800 Subject: [PATCH] [client] Catch throwable to avoid slient failure on remote file download --- .../fluss/client/table/scanner/RemoteFileDownloader.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/fluss-client/src/main/java/org/apache/fluss/client/table/scanner/RemoteFileDownloader.java b/fluss-client/src/main/java/org/apache/fluss/client/table/scanner/RemoteFileDownloader.java index 9034da5511..01269f0c4c 100644 --- a/fluss-client/src/main/java/org/apache/fluss/client/table/scanner/RemoteFileDownloader.java +++ b/fluss-client/src/main/java/org/apache/fluss/client/table/scanner/RemoteFileDownloader.java @@ -76,8 +76,8 @@ public CompletableFuture downloadFileAsync( FsPath remoteFilePath = fsPathAndFileName.getPath(); long downloadBytes = downloadFile(targetFilePath, remoteFilePath); future.complete(downloadBytes); - } catch (Exception e) { - future.completeExceptionally(e); + } catch (Throwable t) { + future.completeExceptionally(t); } }); return future;