При запуске Spark SQL я получаю ошибку mismatched input 'from' expecting <EOF>
.
Я проверил распространенные синтаксические ошибки, которые могут возникнуть, но не нашел их.
val prevPartitionDate = spark.sql(
"select to_date(concat(year_p,'-',month_p,'-',day_p))
from ips.command_room_table
where
to_date(concat(year_p,'-',month_p,'-',day_p)) < to_date(concat($yearAsInt,'-',$monthAsInt,'-',$dayAsInt))
group by year_p, month_p, day_p
order by to_date(concat(year_p,'-',month_p,'-',day_p)) desc limit 1"
).first.getDate(0)
Что я могу сделать, чтобы решить эту проблему?
Ничего страшного, разобрался с проблемой. Поскольку я использовал переменные в запросе, мне просто нужно добавить «s» в начале запроса следующим образом:
val prevPartitionDate = spark.sql(s
"select to_date(concat(year_p,'-',month_p,'-',day_p))
from ips.command_room_table
where
to_date(concat(year_p,'-',month_p,'-',day_p)) < to_date(concat($yearAsInt,'-',$monthAsInt,'-',$dayAsInt))
group by year_p, month_p, day_p
order by to_date(concat(year_p,'-',month_p,'-',day_p)) desc limit 1"
).first.getDate(0)
ты проверил знак "$"?