From 971d8db03ae6bf973fcfdc0dc4fe76f2009ee824 Mon Sep 17 00:00:00 2001 From: Qiaozhi Date: Thu, 3 May 2018 17:20:12 +0800 Subject: [PATCH] =?UTF-8?q?odps=E7=94=A8=E6=88=B7=E5=90=8D=E4=B8=BA?= =?UTF-8?q?=E7=A9=BA=E6=8A=A5=E9=94=99=E6=AD=BB=E5=BE=AA=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);