diff --git a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java
index 1d9546b8fb..289e6b83ad 100644
--- a/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java
+++ b/src/connector/jdbc/src/test/java/com/taosdata/jdbc/TSDBConnectionTest.java
@@ -38,7 +38,7 @@ public class TSDBConnectionTest {
             TSDBSubscribe subscribe = unwrap.subscribe("topic1", "select * from log.log", false);
             TSDBResultSet rs = subscribe.consume();
             ResultSetMetaData metaData = rs.getMetaData();
-            while (rs.next()) {
+            for (int count = 0; count < 10 && rs.next(); count++) {
                 for (int i = 1; i <= metaData.getColumnCount(); i++) {
                     String value = rs.getString(i);
                     System.out.print(metaData.getColumnLabel(i) + ":" + value + "\t");