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

Merge pull request #1095 from WangAShao/master

Browse Source 
fix #1094: 解决连接泄漏的问题
This commit is contained in:
Trafalgar 2021-09-18 18:16:09 +08:00 committed by GitHub
commit c22db301b6
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 1 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
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.writeRecordSql = writeRecordSql;
this.isStop = false; this.isStop = false;
this.deleteMeta = deleteMeta; this.deleteMeta = deleteMeta;
connHolder.initConnection();
} }
void setWriterTask(ConcurrentTableWriterTask writerTask) { 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) { public void doMultiInsert(final List<Record> buffer, final boolean printCost, final long restrict) {
checkMemstore(); checkMemstore();
connHolder.initConnection();
Connection conn = connHolder.getConn(); Connection conn = connHolder.getConn();
boolean success = false; boolean success = false;
long cost = 0; long cost = 0;
@ -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();