> Long running query : Are you running this on MapReduce or Tez?
Please post the output of explain - if you are seeing > 1 shuffle edge in your query while having only one window for OVER(), that might be the reason. OVER ( PARTITION BY m_d_key , sb_gu_key ORDER BY t_ev_st_dt) The multiple PTF operators should have been collapsed by the reduce sink-deduplication. Cheers, Gopal