diff --git a/flink-doris-connector/pom.xml b/flink-doris-connector/pom.xml
index 4b51a089b..883964ecb 100644
--- a/flink-doris-connector/pom.xml
+++ b/flink-doris-connector/pom.xml
@@ -67,7 +67,7 @@ under the License.
     </mailingLists>
 
     <properties>
-        <revision>24.0.0-SNAPSHOT</revision>
+        <revision>24.1.0-SNAPSHOT</revision>
         <flink.version>1.18.0</flink.version>
         <flink.major.version>1.18</flink.major.version>
         <flink.sql.cdc.version>3.2.1</flink.sql.cdc.version>
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java
index 59cfd85df..8eef01cfe 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/lookup/Worker.java
@@ -169,7 +169,8 @@ public static List<Get> deduplicateRecords(List<Get> recordList) {
 
     private void appendSelect(StringBuilder sb, LookupSchema schema) {
         String[] selectFields = schema.getSelectFields();
-        sb.append("select ");
+        sb.append("/* ApplicationName=Flink Lookup Query */ ");
+        sb.append(" select ");
         for (int i = 0; i < selectFields.length; i++) {
             if (i > 0) {
                 sb.append(",");
diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
index 1663d4b39..459fbe70d 100644
--- a/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
+++ b/flink-doris-connector/src/main/java/org/apache/doris/flink/rest/RestService.java
@@ -209,9 +209,9 @@ private static String getConnectionGet(
         HttpURLConnection connection = (HttpURLConnection) realUrl.openConnection();
         connection.setRequestProperty("Authorization", authHeader(dorisOptions));
 
-        connection.connect();
         connection.setConnectTimeout(request.getConfig().getConnectTimeout());
         connection.setReadTimeout(request.getConfig().getSocketTimeout());
+        connection.connect();
         return parseResponse(connection, logger);
     }