From 3de8e90f104ce536d6989927964ca24fcc170cf7 Mon Sep 17 00:00:00 2001
From: zhangjunfan <zhangjunfan@qiyi.com>
Date: Tue, 18 Aug 2026 16:54:14 +0800
Subject: [PATCH] [client] Include original partition name in historical lookup
 errors

---
 .../org/apache/fluss/client/lookup/LookupSender.java   | 10 ++++++++--
 1 file changed, 8 insertions(+), 2 deletions(-)

diff --git a/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java b/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java
index d1b59a75cc2..e608494e43b 100644
--- a/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java
+++ b/fluss-client/src/main/java/org/apache/fluss/client/lookup/LookupSender.java
@@ -566,21 +566,27 @@ private void handleLookupError(
         }
 
         for (AbstractLookupQuery<?> lookup : lookups) {
+            String originalPartitionNameMsg =
+                    lookup.originalPartitionName() == null
+                            ? ""
+                            : " for historical partition " + lookup.originalPartitionName();
             if (canRetry(lookup, exception)) {
                 long retryDelayMs = prepareRetry(lookup, exception);
                 LOG.warn(
-                        "Get error {} response on table bucket {}, retrying after {} ms ({} attempts left). Error: {}",
+                        "Get error {} response on table bucket {}{}, retrying after {} ms ({} attempts left). Error: {}",
                         lookupType,
                         tableBucket,
+                        originalPartitionNameMsg,
                         retryDelayMs,
                         maxRetries - lookup.retries(),
                         error.formatErrMsg());
                 reEnqueueLookup(lookup);
             } else {
                 LOG.warn(
-                        "Get error {} response on table bucket {}, fail. Error: {}",
+                        "Get error {} response on table bucket {}{}, fail. Error: {}",
                         lookupType,
                         tableBucket,
+                        originalPartitionNameMsg,
                         error.formatErrMsg());
                 lookup.future().completeExceptionally(exception);
             }