github/DataX
5
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2025-05-03 00:10:13 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix bug：在出异常的时候，会调一次reconnect，这里面释放旧连接，创建新连接；进入下一次循环的时候，又创建一次连接，所以在reconnect里面创建的那个新连接就泄露了

Browse Source
This commit is contained in:
wang 2021-09-16 19:27:56 +08:00
parent 38b4dc8946
commit 5b975c55a7
1 changed files with 0 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java
View File

@ -165,7 +165,6 @@ public class InsertTask implements Runnable {
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.info("thread interrupted ..., ignore"); LOG.info("thread interrupted ..., ignore");
} }
connHolder.initConnection();
conn = connHolder.getConn(); conn = connHolder.getConn();
LOG.info("retry {}, start do batch insert, size={}", i, buffer.size()); LOG.info("retry {}, start do batch insert, size={}", i, buffer.size());
checkMemstore(); checkMemstore();