CodeCow/DataX
1
0
Fork 0
mirror of https://github.com/alibaba/DataX.git synced 2026-06-30 21:01:32 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix bug: 解决ob writer连接数随着写入不断上涨的问题

Browse Source
This commit is contained in:
wang 2021-09-09 16:31:47 +08:00
parent 3225f02bf9
commit 38b4dc8946
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -65,6 +65,7 @@ public class InsertTask implements Runnable {
this.writeRecordSql = writeRecordSql;
this.isStop = false;
this.deleteMeta = deleteMeta;
connHolder.initConnection();
}
void setWriterTask(ConcurrentTableWriterTask writerTask) {
@ -151,7 +152,6 @@ public class InsertTask implements Runnable {
public void doMultiInsert(final List<Record> buffer, final boolean printCost, final long restrict) {
checkMemstore();
connHolder.initConnection();
Connection conn = connHolder.getConn();
boolean success = false;
long cost = 0;