diff --git a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendStatement.java b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendStatement.java
index bac6aea8..129d8c37 100644
--- a/databend-jdbc/src/main/java/com/databend/jdbc/DatabendStatement.java
+++ b/databend-jdbc/src/main/java/com/databend/jdbc/DatabendStatement.java
@@ -201,8 +201,8 @@ final boolean internalExecute(String sql, StageAttachment attachment) throws SQL
             while (client.hasNext()) {
                 QueryResults results = client.getResults();
                 List<List<Object>> data = results.getData();
-                List<QueryRowField> schema = results.getSchema();
-                if ((data == null || data.isEmpty()) && (schema == null || schema.isEmpty())) {
+//                List<QueryRowField> schema = results.getSchema();
+                if (data == null || data.isEmpty()) {
                     client.advance();
                 } else {
                     break;