From 5fc2a6a3cece798203f6c39f60e5d76aa78e6dcb Mon Sep 17 00:00:00 2001
From: Qiaozhi <ballboy@foxmail.com>
Date: Thu, 3 May 2018 16:29:35 +0800
Subject: [PATCH] =?UTF-8?q?odps=E6=8A=A5=E9=94=99=E6=AD=BB=E5=BE=AA?=
 =?UTF-8?q?=E7=8E=AF?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../com/fr/third/alibaba/druid/pool/DruidDataSource.java    | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/fine-druid/src/com/fr/third/alibaba/druid/pool/DruidDataSource.java b/fine-druid/src/com/fr/third/alibaba/druid/pool/DruidDataSource.java
index d52806006..eec487950 100644
--- a/fine-druid/src/com/fr/third/alibaba/druid/pool/DruidDataSource.java
+++ b/fine-druid/src/com/fr/third/alibaba/druid/pool/DruidDataSource.java
@@ -2012,6 +2012,9 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
                     LOG.error("create connection error", e);
                     // unknow fatal exception
                     setFailContinuous(true);
+                    if (breakAfterAcquireFailure) {
+                        break;
+                    }
                     continue;
                 } catch (Error e) {
                     lock.lock();
@@ -2128,6 +2131,9 @@ public class DruidDataSource extends DruidAbstractDataSource implements DruidDat
                 } catch (RuntimeException e) {
                     LOG.error("create connection error", e);
                     setFailContinuous(true);
+                    if (breakAfterAcquireFailure) {
+                        break;
+                    }
                     continue;
                 } catch (Error e) {
                     LOG.error("create connection error", e);