fix throw table_not_exist exception

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientLSBatchOpsImpl.java

@@ -408,11 +408,10 @@ public Map<Long, Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSing
                     tableObPair = obTableClient.getTable(real_tableName, rowKey,
                             false, false, obTableClient.getRoute(false));
                     lsId = tableObPair.getRight().getLsId();
+                } else {
+                    throw e;
                 }
             }
-            if (tableObPair == null) {
-                throw new ObTableUnexpectedException("tableObPair is null, tableName: " + tableName);
-            }
 
             Map<Long, ObPair<ObTableParam, List<ObPair<Integer, ObTableSingleOp>>>> tabletOperations
                     = lsOperationsMap.computeIfAbsent(lsId, k -> new HashMap<>());

src/main/java/com/alipay/oceanbase/rpc/table/ObTableClientQueryImpl.java

@@ -135,12 +135,13 @@ public void checkArgumentBeforeExec() throws Exception {
             throw new IllegalArgumentException("table name is null");
         } else if (tableQuery.isFTSQuery()) {
             if (!ObGlobal.isFtsQuerySupport()) {
-                throw new FeatureNotSupportedException("full text query is not supported in "+ObGlobal.obVsnString());
+                throw new FeatureNotSupportedException("full text query is not supported in "
+                                                       + ObGlobal.obVsnString());
             }
             if (tableQuery.getIndexName() == null || tableQuery.getIndexName().isEmpty()
-                    || tableQuery.getIndexName().equalsIgnoreCase("primary")) {
+                || tableQuery.getIndexName().equalsIgnoreCase("primary")) {
                 throw new IllegalArgumentException(
-                        "use fulltext search but specified index name is not fulltext index");
+                    "use fulltext search but specified index name is not fulltext index");
             }
         }
     }
@@ -178,15 +179,16 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
         if (obTableClient.isOdpMode()) {
             if (tableQuery.getScanRangeColumns().isEmpty()) {
                 if (tableQuery.getIndexName() != null
-                    && !tableQuery.getIndexName().equalsIgnoreCase("primary") && !tableQuery.isFTSQuery()) {
+                    && !tableQuery.getIndexName().equalsIgnoreCase("primary")
+                    && !tableQuery.isFTSQuery()) {
                     throw new ObTableException("key range columns must be specified when use index");
                 }
             }
-            if (entityType != ObTableEntityType.HKV &&
-                    getPartId() != null && tableQuery.getIndexName() == null) {
+            if (entityType != ObTableEntityType.HKV && getPartId() != null
+                && tableQuery.getIndexName() == null) {
                 try {
                     ObPair<Long, ObTableParam> odpTable = obTableClient.getODPTableWithPartId(
-                            tableName, getPartId(), false);
+                        tableName, getPartId(), false);
                     partitionObTables.put(odpTable.getLeft(), odpTable);
                 } catch (Exception e) {
                     if (e instanceof ObTableException) {
@@ -208,7 +210,7 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
                 }
             } else {
                 partitionObTables.put(0L, new ObPair<Long, ObTableParam>(0L, new ObTableParam(
-                        obTableClient.getOdpTable())));
+                    obTableClient.getOdpTable())));
             }
         } else {
             if (getPartId() == null) {
@@ -222,12 +224,15 @@ private AbstractQueryStreamResult commonExecute(InitQueryResultCallback<Abstract
                         false);
                 }
                 try {
-                    ObPair<Long, ObTableParam> table = obTableClient.getTableWithPartId(indexTableName, getPartId(),
-                            false, false, false, obTableClient.getRoute(false));
+                    ObPair<Long, ObTableParam> table = obTableClient.getTableWithPartId(
+                        indexTableName, getPartId(), false, false, false,
+                        obTableClient.getRoute(false));
                     partitionObTables.put(table.getLeft(), table);
                 } catch (ObTableNotExistException e) {
-                    if (this.entityType == ObTableEntityType.HKV && obTableClient.isTableGroupName(tableName)) {
-                        indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, true);
+                    if (this.entityType == ObTableEntityType.HKV
+                        && obTableClient.isTableGroupName(tableName)) {
+                        indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(
+                            tableName, true);
                         ObPair<Long, ObTableParam> table = obTableClient.getTableWithPartId(
                             indexTableName, getPartId(), false, false, false,
                             obTableClient.getRoute(false));
@@ -337,11 +342,10 @@ public Map<Long, ObPair<Long, ObTableParam>> initPartitions(ObTableQuery tableQu
                     indexTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, true);
                     pairs = this.obTableClient.getTables(indexTableName, tableQuery, start,
                             borderFlag.isInclusiveStart(), end, borderFlag.isInclusiveEnd(), false, false);
+                } else {
+                    throw e;
                 }
             }
-            if (pairs == null) {
-                throw new ObTableUnexpectedException("Query meets exception, pairs is null, tableName: " + tableName);
-            }
             if (tableQuery.getScanOrder() == ObScanOrder.Reverse) {
                 for (int i = pairs.size() - 1; i >= 0; i--) {
                     partitionObTables.put(pairs.get(i).getLeft(), pairs.get(i));