From 52d999eed4dd4d48925c22df8b1d88e02a8abb6d Mon Sep 17 00:00:00 2001
From: zhangliang <zhangliang@apache.org>
Date: Fri, 3 Nov 2023 23:57:37 +0800
Subject: [PATCH] Rename DumperCommonContext

---
 .../data/pipeline/core/task/PipelineTaskUtils.java              | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskUtils.java b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskUtils.java
index 572728f123522f..acc37e36d2f9e1 100644
--- a/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskUtils.java
+++ b/kernel/data-pipeline/core/src/main/java/org/apache/shardingsphere/data/pipeline/core/task/PipelineTaskUtils.java
@@ -43,7 +43,7 @@ public final class PipelineTaskUtils {
      * @return inventory task id
      */
     public static String generateInventoryTaskId(final InventoryDumperContext inventoryDumperContext) {
-        String result = String.format("%s.%s", inventoryDumperContext.getDataSourceName(), inventoryDumperContext.getActualTableName());
+        String result = String.format("%s.%s", inventoryDumperContext.getCommonContext().getDataSourceName(), inventoryDumperContext.getActualTableName());
         return result + "#" + inventoryDumperContext.getShardingItem();
     }