From 042aa2d86599162367024a3072fdb34547736a4e Mon Sep 17 00:00:00 2001
From: sanChouIsACat <993924507@qq.com>
Date: Tue, 28 Dec 2021 19:32:15 +0800
Subject: [PATCH] =?UTF-8?q?=E5=9C=A8=E4=B8=8A=E4=B8=AA=E7=89=88=E6=9C=AC?=
 =?UTF-8?q?=E7=9A=84=E5=9F=BA=E7=A1=80=E4=B8=8A=E6=A0=BC=E5=BC=8F=E5=8C=96?=
 =?UTF-8?q?=E4=BA=86=E4=BB=A3=E7=A0=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../oceanbasev10writer/task/ConcurrentTableWriterTask.java    | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java
index eb1222c3..bed0598d 100644
--- a/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java
+++ b/oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java
@@ -308,7 +308,7 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
 				}
 			}
 		}
-		if(unknownPartRecords.size()>0){
+		if (unknownPartRecords.size() > 0) {
 			int retry = 0;
 			while (true) {
 				try {
@@ -364,7 +364,7 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
 
 			unknownPartRecords.add(record);
 			int i = 0;
-			if(unknownPartRecords.size()>batchSize){
+			if (unknownPartRecords.size() > batchSize) {
 				while (true) {
 					if (i > 0) {
 						LOG.info("retry add batch record the {} times", i);