sql - 不匹配的输入“来自”预期

Question

好的，所以我正在尝试运行这段代码：

%%spark

spark.sql(f'''select t2.ANOT_PDA_PRD
         ,t2.VLR_PDA_PRD AS MAX_VLR_PDA
         ,(CASE t1.cd_gr_mdld_prd_pd
                WHEN 7 THEN t3.DEF_B4
                WHEN 8 THEN t3.DEF_B4
                WHEN 9 THEN t3.DEF_B4
                WHEN 10 THEN t3.DEF_B5
                WHEN 11 THEN t3.DEF_B4
                WHEN 12 THEN t3.DEF_B5
                WHEN 13 THEN t3.DEF_B4
                WHEN 14 THEN t3.DEF_B4
                WHEN 15 THEN t3.DEF_B5
                WHEN 16 THEN t3.DEF_B4
                WHEN 17 THEN t3.DEF_B4
                WHEN 18 THEN t3.DEF_B4
                WHEN 22 THEN t3.DEF_B5
                ELSE 0 END) AS TMP_QUALI
          ,T3.ANOT_PDA_CLI
          from temp_vars_qlt as t1
          left join temp_vars_qlt as t2
          on t1.dt_mvtc = t2.dt_mvtc and t1.cd_cli = t2.cd_cli and T1.cd_gr_mdld_prd_pd=t2.cd_gr_mdld_prd_pd
          left join temp_vars_qlt as t3
          on t1.dt_mvtc = t3.dt_mvtc and t1.cd_cli = t3.cd_cli
          where t1.dt_mvtc between({data_inicial} , {data_final})
          ''').createOrReplaceTempView("temp_safras_qlt_aux")

但我收到以下错误：

SparkStatementException: "\nmismatched input 'from' expecting <EOF>(line 19, pos 14)\n\n== SQL 
==\nselect t2.ANOT_PDA_PRD\n             ,t2.VLR_PDA_PRD AS MAX_VLR_PDA\n             ,(CASE 
t1.cd_gr_mdld_prd_pd\n                    WHEN 7 THEN t3.DEF_B4\n                    WHEN 8 
THEN t3.DEF_B4\n  .................

whi 很多其他的行，但不是完全可读，我相信重要的部分在第一行。但我不知道"\nmismatched input 'from' expecting <EOF>无论如何应该是什么意思。

所以，问题很简单：出了什么问题？

标签： sqlpysparkapache-spark-sql

Answer 1

between语法是BETWEEN 2 AND 5，试着把你的改成between {data_inicial} and {data_final}