diff --git a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
index 03b6af1ec2cf23836593051908bfd70e644b2c71..2bc3059cf84ff4fff5bff5926b13fb4c6bf814b3 100644
--- a/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
+++ b/tests/examples/JDBC/connectionPools/src/main/java/com/taosdata/demo/ConnectionPoolDemo.java
@@ -79,7 +79,7 @@ public class ConnectionPoolDemo {
 //        }
 
         ExecutorService executor = Executors.newFixedThreadPool(threadCount);
-        for (long i = 0; i < totalSize / batchSize; i++) {
+        for (long i = 0; i < totalSize / batchSize / tableSize; i++) {
             executor.execute(new InsertTask(dataSource, dbName, tableSize, batchSize));
             // sleep few seconds
             try {