diff --git a/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest.java b/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest.java
index 75f0b3e581..cfd16401bc 100644
--- a/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest.java
+++ b/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest.java
@@ -30,10 +30,10 @@ public class OnFatalErrorMaxActiveTest extends PoolTestCase {
         Field field = DruidAbstractDataSource.class.getDeclaredField("onFatalError");
         field.setAccessible(true);
 
-        SQLException faltalError = new SQLException();
-        {
+        SQLException faltalError = null;
+        for ( int i = 0; i < 2; i++) {
+            faltalError = new SQLException();
             Connection conn = dataSource.getConnection();
-
             Method method = DruidDataSource.class.getDeclaredMethod("handleFatalError", DruidPooledConnection.class, SQLException.class, String.class);
             method.setAccessible(true);
             method.invoke(dataSource, conn.unwrap(DruidPooledConnection.class), faltalError, "select 'x'");
diff --git a/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest_1.java b/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest_1.java
index 9df3475698..48b2c4c105 100644
--- a/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest_1.java
+++ b/src/test/java/com/alibaba/druid/bvt/pool/OnFatalErrorMaxActiveTest_1.java
@@ -30,8 +30,9 @@ public class OnFatalErrorMaxActiveTest_1 extends PoolTestCase {
         Field field = DruidAbstractDataSource.class.getDeclaredField("onFatalError");
         field.setAccessible(true);
 
-        SQLException faltalError = new SQLException();
-        {
+        SQLException faltalError = null;
+        for ( int i = 0; i < 2; i++) {
+            faltalError = new SQLException();
             Connection conn = dataSource.getConnection();
 
             Method method = DruidDataSource.class.getDeclaredMethod("handleFatalError", DruidPooledConnection.class, SQLException.class, String.class);