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

在上个版本的基础上格式化了代码

Browse Source
This commit is contained in:
sanChouIsACat 2021-12-28 19:32:15 +08:00
parent ce29ae7ee5
commit 042aa2d865
1 changed files with 2 additions and 2 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

@ -308,7 +308,7 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
} }
} }
} }
if(unknownPartRecords.size()>0){ if (unknownPartRecords.size() > 0) {
int retry = 0; int retry = 0;
while (true) { while (true) {
try { try {
@ -364,7 +364,7 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
unknownPartRecords.add(record); unknownPartRecords.add(record);
int i = 0; int i = 0;
if(unknownPartRecords.size()>batchSize){ if (unknownPartRecords.size() > batchSize) {
while (true) { while (true) {
if (i > 0) { if (i > 0) {
LOG.info("retry add batch record the {} times", i); LOG.info("retry add batch record the {} times", i);