[ https://issues.apache.org/jira/browse/HIVE-6700?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13941039#comment-13941039 ]
Siddharth Seth commented on HIVE-6700: -------------------------------------- Looks good, only question I have is whether the try block needs to enclose setting up Inputs in the ReduceProcessor. {code} if(shuffleInputs.size() == 1){ //no merging of inputs required kvsReader = (KeyValuesReader) shuffleInputs.get(0).getReader(); }else { //get a sort merged input kvsReader = new InputMerger(shuffleInputs); } {code} > In some queries inputs are closed on Tez before the operator pipeline is > flushed > -------------------------------------------------------------------------------- > > Key: HIVE-6700 > URL: https://issues.apache.org/jira/browse/HIVE-6700 > Project: Hive > Issue Type: Bug > Reporter: Gunther Hagleitner > Assignee: Gunther Hagleitner > Attachments: HIVE-6700.1.patch > > > Group by operators won't flush their last row until operator is closed. In > Tez it's possible that the input is already closed at this point. -- This message was sent by Atlassian JIRA (v6.2#6252)