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 352e7f68bc16da256d8202770f5c578b8ed91aae Author: Yu Gan <yu....@kyligence.io> AuthorDate: Tue May 30 15:33:22 2023 +0800 KYLIN-5699 support special character for computed column --- .../kylin/engine/spark/job/stage/build/FlatTableAndDictBase.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) 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 aecced663b..7b06b362f5 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 @@ -26,7 +26,7 @@ import org.apache.kylin.engine.spark.application.SparkApplication import org.apache.kylin.engine.spark.builder.DFBuilderHelper._ import org.apache.kylin.engine.spark.builder._ import org.apache.kylin.engine.spark.builder.v3dict.DictionaryBuilder -import org.apache.kylin.engine.spark.job.NSparkCubingUtil.convertFromDot +import org.apache.kylin.engine.spark.job.NSparkCubingUtil.{convertFromDot, convertFromDotWithBackTick} import org.apache.kylin.engine.spark.job.stage.{BuildParam, StageExec} import org.apache.kylin.engine.spark.job.{FiltersUtil, SegmentJob, TableMetaManager} import org.apache.kylin.engine.spark.model.SegmentFlatTableDesc @@ -625,7 +625,7 @@ abstract class FlatTableAndDictBase(private val jobContext: SegmentJob, var tableWithCcs = table matchedCols.foreach(m => tableWithCcs = tableWithCcs.withColumn(convertFromDot(m.getBackTickIdentity), - expr(convertFromDot(m.getBackTickExp)))) + expr(convertFromDotWithBackTick(m.getBackTickExp)))) tableWithCcs }