Github user zzcclp commented on a diff in the pull request:
https://github.com/apache/carbondata/pull/1469#discussion_r152729132
--- Diff:
integration/spark2/src/main/scala/org/apache/spark/sql/parser/CarbonSparkSqlParser.scala
---
@@ -38,7 +40,26 @@ import org.apache.carbondata.spark.util.CommonUtil
*/
class CarbonSparkSqlParser(conf: SQLConf, sparkSession: SparkSession)
extends AbstractSqlParser {
- val astBuilder = new CarbonSqlAstBuilder(conf)
+ val parser = new CarbonSpark2SqlParser
+ val astBuilder = getAstBuilder()
+
+ def getAstBuilder(): AstBuilder = {
+ if (sparkSession.version.contains("2.1")) {
--- End diff --
use startsWith instead of contains
---
