[kylin] 33/38: KYLIN-5530 [FOLLOW UP] fix config kylin.engine.persist-flat-use-snapshot-enabled

[xx...@apache.org]

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 <7m...@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)