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