diff --git a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java b/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
index fa2dcf86d848..ac0258a30b76 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionPoolExample.java
@@ -72,7 +72,14 @@ public static void main(String[] args)
     // Choose the SessionPool you going to use
     constructRedirectSessionPool();
 
-    service = Executors.newFixedThreadPool(10);
+  service = new ThreadPoolExecutor(
+        10,
+        10,
+        0L,
+        TimeUnit.MILLISECONDS,
+        new ArrayBlockingQueue<>(1000),
+        new ThreadPoolExecutor.CallerRunsPolicy()
+);
     insertRecord();
     Thread.sleep(1000);
     queryByIterator();