[
https://issues.apache.org/jira/browse/HIVE-19849?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deepak Jaiswal reassigned HIVE-19849:
-------------------------------------
> ReduceRecordSource should flush the last record when reader runs out of
> records
> -------------------------------------------------------------------------------
>
> Key: HIVE-19849
> URL: https://issues.apache.org/jira/browse/HIVE-19849
> Project: Hive
> Issue Type: Task
> Reporter: Deepak Jaiswal
> Assignee: Deepak Jaiswal
> Priority: Major
>
> ReduceRecordSource pushes all the records to the reducer operator. It is upto
> that operator to forward it down the pipeline. Incase of operators such as
> GBY, the last record is flushed only when the operator is closed which may
> cause joins to miss records.
> This has been fixed for SMB Join when it happens on reducer, however, it
> maybe good idea to just flush out recursively (see flushRecursive) when
> reader is exhausted to ensure that last record or set of records is not held.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
