[fix][dingo-calcite] NullPointer caused by concurrent transactions

Author: guojn1

dingo-calcite/src/main/java/io/dingodb/calcite/utils/MetaServiceUtils.java

@@ -16,6 +16,7 @@
 
 package io.dingodb.calcite.utils;
 
+import io.dingodb.calcite.DingoTable;
 import io.dingodb.common.CommonId;
 import io.dingodb.meta.MetaService;
 import org.apache.calcite.plan.RelOptTable;
@@ -31,15 +32,19 @@ private MetaServiceUtils() {
     }
 
     public static @NonNull CommonId getTableId(RelOptTable table) {
-        String tableName = getTableName(table);
-        MetaService metaService = getMetaService(table);
-        return metaService.getTable(tableName).getTableId();
+        //String tableName = getTableName(table);
+        //MetaService metaService = getMetaService(table);
+        //return metaService.getTable(tableName).getTableId();
+        DingoTable dingoTable = table.unwrapOrThrow(DingoTable.class);
+        return dingoTable.getTable().tableId;
     }
 
     public static @NonNull TableInfo getTableInfo(RelOptTable table) {
-        String tableName = getTableName(table);
+        //String tableName = getTableName(table);
         MetaService metaService = getMetaService(table);
-        CommonId tableId = metaService.getTable(tableName).getTableId();
+        DingoTable dingoTable = table.unwrapOrThrow(DingoTable.class);
+        CommonId tableId = dingoTable.getTable().tableId;
+        //CommonId tableId = metaService.getTable(tableName).getTableId();
         return new TableInfo(
             tableId,
             metaService.getRangeDistribution(tableId)

dingo-exec/src/main/java/io/dingodb/exec/transaction/util/TransactionUtil.java

@@ -125,7 +125,11 @@ public static Map<CommonId, List<byte[]>> multiKeySplitRegionId(CommonId tableId
 
     public static IndexTable getIndexDefinitions(CommonId tableId) {
         MetaService root = MetaService.root();
-        return (IndexTable) root.getTable(tableId);
+        Table table = root.getTable(tableId);
+        if (!(table instanceof IndexTable)) {
+            LogUtils.error(log, "except indexTable, bug not, tableId:{}, act table", tableId, table);
+        }
+        return (IndexTable) table;
     }
     public static List<byte[]> mutationToKey(List<Mutation> mutations) {
         List<byte[]> keys = new ArrayList<>(mutations.size());