Произошла ошибка при вызове o188.showString - PullRequest
0 голосов
/ 31 мая 2019

Я выполняю запрос куста в ядре Pyspark и получаю ошибку

"Произошла ошибка при вызове o188.showString"

df_tic = hiveContext.sql("""select t.*,j.*
from  efms_gold.ms_task t join efms_gold.ms_job j 
on t.wf_job_id =  j.wf_job_id
where t.name RLIKE 'Error|Correct|Create AOTS Ticket' 
and t.  ORIGINAL_START_DATE is not null 
and j.entered_date 
between  date_sub(current_date(),12) and date_sub(current_date(),10)""")

Я получаю приведенную ниже ошибку после запуска df_tic.show (1)

An error occurred while calling o188.showString.
: org.apache.spark.sql.catalyst.errors.package$TreeNodeException: execute, tree:
Exchange hashpartitioning(wf_job_id#905, 200)
+- *(1) Filter (((isnotnull(name#907) && name#907 RLIKE Error|Correct|Create AOTS Ticket) && isnotnull(ORIGINAL_START_DATE#913)) && isnotnull(wf_job_id#905))
   +- HiveTableScan [ms_task_id#904, wf_job_id#905, wf_task_id#906, name#907, template_name#908, scheduled_interval#909, display_name#910, .....
...