From 5b975c55a775e0a1075d1076987939d1e326030e Mon Sep 17 00:00:00 2001
From: wang <wangjinpu.wjp@alibaba-inc.com>
Date: Thu, 16 Sep 2021 19:27:56 +0800
Subject: [PATCH] =?UTF-8?q?fix=20bug=EF=BC=9A=E5=9C=A8=E5=87=BA=E5=BC=82?=
 =?UTF-8?q?=E5=B8=B8=E7=9A=84=E6=97=B6=E5=80=99=EF=BC=8C=E4=BC=9A=E8=B0=83?=
 =?UTF-8?q?=E4=B8=80=E6=AC=A1reconnect=EF=BC=8C=E8=BF=99=E9=87=8C=E9=9D=A2?=
 =?UTF-8?q?=E9=87=8A=E6=94=BE=E6=97=A7=E8=BF=9E=E6=8E=A5=EF=BC=8C=E5=88=9B?=
 =?UTF-8?q?=E5=BB=BA=E6=96=B0=E8=BF=9E=E6=8E=A5=EF=BC=9B=E8=BF=9B=E5=85=A5?=
 =?UTF-8?q?=E4=B8=8B=E4=B8=80=E6=AC=A1=E5=BE=AA=E7=8E=AF=E7=9A=84=E6=97=B6?=
 =?UTF-8?q?=E5=80=99=EF=BC=8C=E5=8F=88=E5=88=9B=E5=BB=BA=E4=B8=80=E6=AC=A1?=
 =?UTF-8?q?=E8=BF=9E=E6=8E=A5=EF=BC=8C=E6=89=80=E4=BB=A5=E5=9C=A8reconnect?=
 =?UTF-8?q?=E9=87=8C=E9=9D=A2=E5=88=9B=E5=BB=BA=E7=9A=84=E9=82=A3=E4=B8=AA?=
 =?UTF-8?q?=E6=96=B0=E8=BF=9E=E6=8E=A5=E5=B0=B1=E6=B3=84=E9=9C=B2=E4=BA=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../datax/plugin/writer/oceanbasev10writer/task/InsertTask.java  | 1 -
 1 file changed, 1 deletion(-)

diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
index 36fc726b..968908ca 100644
--- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
+++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
@@ -165,7 +165,6 @@ public class InsertTask implements Runnable {
 					} catch (InterruptedException e) {
 						LOG.info("thread interrupted ..., ignore");
 					}
-					connHolder.initConnection();
 					conn = connHolder.getConn();
 					LOG.info("retry {}, start do batch insert, size={}", i, buffer.size());
 					checkMemstore();