This is an automated email from the ASF dual-hosted git repository.

xxyu pushed a commit to branch kylin5
in repository https://gitbox.apache.org/repos/asf/kylin.git

commit b4496549e3054d58f786cf0b3a3c7ffe568a13c5
Author: yihuawu1986 <59810358+yihuawu1...@users.noreply.github.com>
AuthorDate: Mon Dec 19 13:06:22 2022 +0800

    [DIRTY] Resolve missing code of metadata dump due to opencore merge
---
 .../java/org/apache/kylin/engine/spark/job/NTableSamplingJob.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git 
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/NTableSamplingJob.java
 
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/NTableSamplingJob.java
index 125274ace7..480c691a72 100644
--- 
a/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/NTableSamplingJob.java
+++ 
b/src/spark-project/engine-spark/src/main/java/org/apache/kylin/engine/spark/job/NTableSamplingJob.java
@@ -96,7 +96,13 @@ public class NTableSamplingJob extends 
DefaultExecutableOnTable {
         final String table = getParam(NBatchConstants.P_TABLE_NAME);
         final TableDesc tableDesc = NTableMetadataManager.getInstance(config, 
getProject()).getTableDesc(table);
         final ProjectInstance projectInstance = 
NProjectManager.getInstance(config).getProject(this.getProject());
-        return Sets.newHashSet(tableDesc.getResourcePath(), 
projectInstance.getResourcePath());
+        Set<String> dumpList = Sets.newHashSet(tableDesc.getResourcePath(), 
projectInstance.getResourcePath());
+        final TableExtDesc tableExtDesc = 
NTableMetadataManager.getInstance(config, getProject())
+                .getTableExtIfExists(tableDesc);
+        if (tableExtDesc != null) {
+            dumpList.add(tableExtDesc.getResourcePath());
+        }
+        return dumpList;
     }
 
     @Override

Reply via email to