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

feature:oceanbase plugin add direct path support

Browse Source
This commit is contained in:
ranyu.zyh 2025-04-03 14:03:53 +08:00
parent 8478f7a212
commit 91e599b076
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java
View File

@ -343,7 +343,9 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
print(); print();
checkMemStore(); checkMemStore();
} }
concurrentWriter.doCommit(); if (directPath){
concurrentWriter.doCommit();
}
} catch (InterruptedException e) { } catch (InterruptedException e) {
LOG.warn("Concurrent table writer wait task finish interrupt"); LOG.warn("Concurrent table writer wait task finish interrupt");
} finally { } finally {