Gopal V created HIVE-20764:
------------------------------
Summary: Tez: ReduceRecordProcessor::init() can avoid doing
.waitForAllInputsReady()
Key: HIVE-20764
URL: https://issues.apache.org/jira/browse/HIVE-20764
Project: Hive
Issue Type: Bug
Reporter: Gopal V
The ReduceRecordProcessor waits for all inputs to be ready before starting to
initialize the input operators.
This is not necessary for the unsorted shuffle cases, as just having one input
(the hash side) entirely ready is sufficient to start doing useful work with
the operators (i.e build the hashtable).
{code}
if (shuffleInputs != null) {
l4j.info("Waiting for ShuffleInputs to become ready");
processorContext.waitForAllInputsReady(new
ArrayList<Input>(shuffleInputs));
}
{code}
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
