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 bd34b4a6..e6b4a561 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
@@ -326,15 +326,14 @@ public class ConcurrentTableWriterTask extends CommonRdbmsWriter.Task {
 			}
 			groupValues.add(record);
 			if (groupValues.size() >= batchSize) {
-				int i = 0;
-				groupValues =addRecordsToWriteQueue(groupValues);
+				groupValues = addRecordsToWriteQueue(groupValues);
 				groupInsertValues.put(partId, groupValues);
 			}
 		} else {
 			LOG.debug("add unknown part record {}", record);
 			unknownPartRecords.add(record);
-			if (unknownPartRecords.size() > batchSize) {
-				unknownPartRecords=addRecordsToWriteQueue(unknownPartRecords);
+			if (unknownPartRecords.size() >= batchSize) {
+				unknownPartRecords = addRecordsToWriteQueue(unknownPartRecords);
 			}
 
 		}