diff --git a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/ClientContextManager.java b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/ClientContextManager.java
index 2df4c12a7fda8d..8e2fcfe60de02f 100644
--- a/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/ClientContextManager.java
+++ b/fs_brokers/apache_hdfs_broker/src/main/java/org/apache/doris/broker/hdfs/ClientContextManager.java
@@ -145,11 +145,11 @@ public synchronized void remoteExpireInputStreams() {
                 fd = entry.getKey();
                 if (entry.getValue().checkExpire(inputStreamExpireSeconds)) {
                     ClientContextManager.this.removeInputStream(fd);
+                    iter.remove();
+                    logger.info(fd + " in client [" + clientContext.clientId
+                            + "] is expired, remove it from contexts. last update time is "
+                            + entry.getValue().getLastPingTimestamp());
                 }
-                iter.remove();
-                logger.info(fd + " in client [" + clientContext.clientId
-                        + "] is expired, remove it from contexts. last update time is "
-                        + entry.getValue().getLastPingTimestamp());
             }
         }
     }
@@ -167,7 +167,7 @@ public void run() {
                             ClientContextManager.this.removeOutputStream(fd);
                         }
                         clientContexts.remove(clientContext.clientId);
-                        logger.info("client [" + clientContext.clientId 
+                        logger.info("client [" + clientContext.clientId
                                 + "] is expired, remove it from contexts. last access time is "
                                 + clientContext.lastAccessTimestamp);
                     }