diff --git a/databend-client/src/main/java/com/databend/client/DatabendClientV1.java b/databend-client/src/main/java/com/databend/client/DatabendClientV1.java
index 609f044..61cb236 100644
--- a/databend-client/src/main/java/com/databend/client/DatabendClientV1.java
+++ b/databend-client/src/main/java/com/databend/client/DatabendClientV1.java
@@ -183,7 +183,7 @@ private void processResponse(Headers headers, QueryResults results) {
         if (results.getSession() != null) {
             databendSession.set(results.getSession());
         }
-        if (results.getQueryId() != null && this.additonalHeaders.get(ClientSettings.X_Databend_Query_ID).isEmpty()) {
+        if (results.getQueryId() != null && this.additonalHeaders.get(ClientSettings.X_Databend_Query_ID).equals(null)) {
             this.additonalHeaders.put(ClientSettings.X_Databend_Query_ID, results.getQueryId());
         }
         currentResults.set(results);