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);
             }