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 b10a87b65d4e2127f2975baacd9792128c8f5fd9 Author: Mingming Ge <7mmi...@gmail.com> AuthorDate: Tue Mar 7 11:13:54 2023 +0800 KYLIN-5530 [FOLLOW UP] fix config kylin.engine.persist-flat-use-snapshot-enabled --- .../kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/spark-project/engine-spark/src/main/scala/org/apache/kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala b/src/spark-project/engine-spark/src/main/scala/org/apache/kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala index 93df9cf9a4..eba207c7bc 100644 --- a/src/spark-project/engine-spark/src/main/scala/org/apache/kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala +++ b/src/spark-project/engine-spark/src/main/scala/org/apache/kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala @@ -435,7 +435,7 @@ abstract class FlatTableAndDictBase(private val jobContext: SegmentJob, val fs = HadoopUtil.getWorkingFileSystem if (snapshotResPath == null || !fs.exists(snapshotResFilePath) - || config.isPersistFlatUseSnapshotEnabled) { + || !config.isPersistFlatUseSnapshotEnabled) { newTableDS(tableRef) } else { sparkSession.read.parquet(snapshotResFilePath.toString).alias(tableRef.getAlias)