Refactor InventoryDumper (#32690)

apache · Aug 26, 2024 · 75dd7cf · 75dd7cf
1 parent 8dbc007
commit 75dd7cf
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/...org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java b/...org/apache/shardingsphere/data/pipeline/core/ingest/dumper/inventory/InventoryDumper.java
@@ -123,8 +123,9 @@ protected void runBlocking() {
 
     private void init() {
         if (null == tableMetaData) {
-            tableMetaData = metaDataLoader.getTableMetaData(
-                    dumperContext.getCommonContext().getTableAndSchemaNameMapper().getSchemaName(dumperContext.getLogicTableName()), dumperContext.getActualTableName());
+            String schemaName = dumperContext.getCommonContext().getTableAndSchemaNameMapper().getSchemaName(dumperContext.getLogicTableName());
+            String tableName = dumperContext.getActualTableName();
+            tableMetaData = metaDataLoader.getTableMetaData(schemaName, tableName);
         }
     }