Получение этой ошибки: несоответствующий ввод "от", ожидающий <EOF>, в то время как Spark SQL

При запуске 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)

Что я могу сделать, чтобы решить эту проблему?

ты проверил знак "$"?

Sathiyan S 21.12.2020 11:49
Почему в Python есть оператор &quot;pass&quot;?
Почему в Python есть оператор "pass"?
Оператор pass в Python - это простая концепция, которую могут быстро освоить даже новички без опыта программирования.
Коллекции в Laravel более простым способом
Коллекции в Laravel более простым способом
Привет, читатели, сегодня мы узнаем о коллекциях. В Laravel коллекции - это способ манипулировать массивами и играть с массивами данных. Благодаря...
JavaScript Вопросы с множественным выбором и ответы
JavaScript Вопросы с множественным выбором и ответы
Если вы ищете платформу, которая предоставляет вам бесплатный тест JavaScript MCQ (Multiple Choice Questions With Answers) для оценки ваших знаний,...
Массив зависимостей в React
Массив зависимостей в React
Все о массиве Dependency и его связи с useEffect.
Toor - Ангулярный шаблон для бронирования путешествий
Toor - Ангулярный шаблон для бронирования путешествий
Toor - Travel Booking Angular Template один из лучших Travel & Tour booking template in the world. 30+ валидированных HTML5 страниц, которые помогут...
0
1
4 582
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Ничего страшного, разобрался с проблемой. Поскольку я использовал переменные в запросе, мне просто нужно добавить «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)

Другие вопросы по теме