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);