From 04c3c2e81034de25983fb49aca01e405fd9a2c8f Mon Sep 17 00:00:00 2001
From: johnrobbet <johnxu.xj@alibaba-inc.com>
Date: Tue, 8 Mar 2022 16:42:59 +0800
Subject: [PATCH] do not readBySplit when it's not in table mode

---
 .../plugin/reader/oceanbasev10reader/ext/ReaderJob.java   | 8 ++++++--
 1 file changed, 6 insertions(+), 2 deletions(-)

diff --git a/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java b/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
index 6ed15e40..291dc785 100644
--- a/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
+++ b/oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderJob.java
@@ -1,5 +1,6 @@
 package com.alibaba.datax.plugin.reader.oceanbasev10reader.ext;
 
+import java.util.Arrays;
 import java.util.List;
 
 import com.alibaba.datax.common.constant.CommonConstant;
@@ -48,8 +49,11 @@ public class ReaderJob extends CommonRdbmsReader.Job {
     @Override
     public List<Configuration> split(Configuration originalConfig, int adviceNumber) {
         List<Configuration> list;
-        // readByPartition is lower priority than splitPk
-        if (!isSplitPkValid(originalConfig) && originalConfig.getBool(ObReaderKey.READ_BY_PARTITION, false)) {
+        // readByPartition is lower priority than splitPk.
+        // and readByPartition only works in table mode.
+        if (!isSplitPkValid(originalConfig) &&
+                originalConfig.getBool(Constant.IS_TABLE_MODE) &&
+                originalConfig.getBool(ObReaderKey.READ_BY_PARTITION, false)) {
             LOG.info("try to split reader job by partition.");
             list = PartitionSplitUtil.splitByPartition(originalConfig);
         } else {