From 91e599b0764c48b4e61b1da2db328c97d1676d44 Mon Sep 17 00:00:00 2001
From: "ranyu.zyh" <ranyu.zyh@digital-engine.com>
Date: Thu, 3 Apr 2025 14:03:53 +0800
Subject: [PATCH] feature:oceanbase plugin add direct path support

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

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 {