diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java b/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java
index 9e62c1ccb5..9b641a9ec7 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/util/BrokerUtil.java
@@ -408,7 +408,7 @@ public class BrokerUtil {
         return pair;
     }
 
-    private static TNetworkAddress getAddress(BrokerDesc brokerDesc) throws UserException {
+    public static TNetworkAddress getAddress(BrokerDesc brokerDesc) throws UserException {
         FsBroker broker = null;
         try {
             String localIP = FrontendOptions.getLocalHostAddress();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java
index 3d394604fb..a4cff888bf 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/load/loadv2/BrokerLoadPendingTask.java
@@ -87,8 +87,8 @@ public class BrokerLoadPendingTask extends LoadTask {
                 }
                 tableTotalFileSize += groupFileSize;
                 tableTotalFileNum += fileStatuses.size();
-                LOG.info("get {} files in file group {} for table {}. size: {}. job: {}",
-                        fileStatuses.size(), groupNum, entry.getKey(), groupFileSize, callback.getCallbackId());
+                LOG.info("get {} files in file group {} for table {}. size: {}. job: {}, broker: {} ",
+                        fileStatuses.size(), groupNum, entry.getKey(), groupFileSize, callback.getCallbackId(), BrokerUtil.getAddress(brokerDesc));
                 groupNum++;
             }