fix multi-cf operations have not existed table go into dead loop

Author: JackShi148

src/main/java/com/alipay/oceanbase/rpc/protocol/payload/impl/execute/query/AbstractQueryStreamResult.java

@@ -240,16 +240,21 @@ protected ObPayload commonExecute(ObTableClient client, Logger logger,
                             throw e;
                         }
                     } else if (e instanceof ObTableException) {
-                        if ((((ObTableException) e).getErrorCode() == ResultCodes.OB_TABLE_NOT_EXIST.errorCode || ((ObTableException) e)
-                            .getErrorCode() == ResultCodes.OB_NOT_SUPPORTED.errorCode || ((ObTableException) e)
-                                .getErrorCode() == ResultCodes.OB_SCHEMA_ERROR.errorCode)
-                            && ((request instanceof ObTableQueryAsyncRequest && ((ObTableQueryAsyncRequest) request).getObTableQueryRequest().getTableQuery().isHbaseQuery())
-                            || (request instanceof ObTableQueryRequest && ((ObTableQueryRequest) request).getTableQuery().isHbaseQuery()))
+                        if ((((ObTableException) e).getErrorCode() == ResultCodes.OB_TABLE_NOT_EXIST.errorCode
+                             || ((ObTableException) e).getErrorCode() == ResultCodes.OB_NOT_SUPPORTED.errorCode || ((ObTableException) e)
+                            .getErrorCode() == ResultCodes.OB_SCHEMA_ERROR.errorCode)
+                            && ((request instanceof ObTableQueryAsyncRequest && ((ObTableQueryAsyncRequest) request)
+                                .getObTableQueryRequest().getTableQuery().isHbaseQuery()) || (request instanceof ObTableQueryRequest && ((ObTableQueryRequest) request)
+                                .getTableQuery().isHbaseQuery()))
                             && client.getTableGroupInverted().get(indexTableName) != null) {
                             // table not exists && hbase mode && table group exists , three condition both
                             client.eraseTableGroupFromCache(tableName);
-                            indexTableName = client.tryGetTableNameFromTableGroupCache(tableName,
-                                true);
+                            String newIndexTableName = client.tryGetTableNameFromTableGroupCache(tableName, true);
+                            if (indexTableName.equalsIgnoreCase(newIndexTableName)) {
+                                throw new ObTableNotExistException("multi column-family operations contain not existed table name", ResultCodes.OB_ERR_UNKNOWN_TABLE.errorCode);
+                            } else {
+                                indexTableName = newIndexTableName;
+                            }
                         }
                         if (((ObTableException) e).isNeedRefreshTableEntry()) {
                             needRefreshTableEntry = true;

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

@@ -589,7 +589,12 @@ public void partitionExecute(ObTableSingleOpResult[] results,
                         // TABLE_NOT_EXIST + tableName is tableGroup + TableGroup cache is not empty
                         // means tableGroupName cache need to refresh
                         obTableClient.eraseTableGroupFromCache(tableName);
-                        realTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, true);
+                        String newRealTableName = obTableClient.tryGetTableNameFromTableGroupCache(tableName, true);
+                        if (realTableName.equalsIgnoreCase(newRealTableName)) {
+                            throw new ObTableNotExistException("multi column-family operations contain not existed table name", ResultCodes.OB_ERR_UNKNOWN_TABLE.errorCode);
+                        } else {
+                            realTableName = newRealTableName;
+                        }
                     }
                     if (obTableClient.isRetryOnChangeMasterTimes()
                             && (tryTimes - 1) < obTableClient.getRuntimeRetryTimes()) {