必须验证db1.table.a\u timestamp中的utc时间是否在db2.table2.a\u est\u ts中正确转换为est时间。
SELECT dsr_ticket_number, from_utc_timestamp(acknowledgement_timestamp, 'EST') from data_prcy_pds_sanitized.dsr_sor_delete_request
where dsr_ticket_number, from_utc_timestamp(acknowledgement_timestamp, 'EST')
in (select dsr_ticket_num,acknowledgement_est_ts from data_prcy_dsr_conformed.data_subj_rqst_delete)
给我一个错误信息: org.apache.spark.sql.catalyst.parser.ParseException: mismatched input ',' expecting <EOF>(line 2, pos 23)
1条答案
按热度按时间dtcbnfnu1#
使用join而不是in: