Venki Korukanti created DRILL-824:
-------------------------------------

             Summary: MergingRecordBatch.next() fails to reallocate the 
outgoing vectors if copyFromSafe returns false
                 Key: DRILL-824
                 URL: https://issues.apache.org/jira/browse/DRILL-824
             Project: Apache Drill
          Issue Type: Bug
            Reporter: Venki Korukanti
            Assignee: Venki Korukanti


{code}
public IterOutcome next()
  while (!pqueue.isEmpty())  {
    // pop next value from pq and copy to outgoing batch
    Node node = pqueue.peek(); 
    if (!copyRecordToOutgoingBatch(node)) {
      break;
    }
    ...
  }
  ...
}
{code}

If the {{copyRecordToOutgoingBatch}} fails, we send the current outgoing batch, 
but we don't reallocate outgoing batch when we reenter {{next}} which leads to 
DeadBuf exceptions.





--
This message was sent by Atlassian JIRA
(v6.2#6252)

Reply via email to