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