[ 
https://issues.apache.org/jira/browse/HIVE-4002?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13750638#comment-13750638
 ] 

Phabricator commented on HIVE-4002:
-----------------------------------

yhuai has commented on the revision "HIVE-4002 [jira] Fetch task aggregation 
for simple group by query".

INLINE COMMENTS
  ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java:3631 Seems 
that this line is the same as the line 3633
  ql/src/java/org/apache/hadoop/hive/ql/parse/SemanticAnalyzer.java:6985 Why do 
we need to change getInternalName to field? If we want to use field instead of 
getInternalName, can you also make this to other places of this class?
  ql/src/java/org/apache/hadoop/hive/ql/exec/Operator.java:582 why do we need 
flushOp? I think it is not necessary to have flushOp. Also, can you change "an 
blocking operator" to "a blocking operator"? I am sorry about the typo I made...
  ql/src/java/org/apache/hadoop/hive/ql/exec/FetchOperator.java:493 I think we 
can just use "operator.flush()" to tell GBY to process its buffer.

REVISION DETAIL
  https://reviews.facebook.net/D8739

To: JIRA, navis
Cc: yhuai

                
> Fetch task aggregation for simple group by query
> ------------------------------------------------
>
>                 Key: HIVE-4002
>                 URL: https://issues.apache.org/jira/browse/HIVE-4002
>             Project: Hive
>          Issue Type: Improvement
>          Components: Query Processor
>            Reporter: Navis
>            Assignee: Navis
>            Priority: Minor
>         Attachments: HIVE-4002.D8739.1.patch, HIVE-4002.D8739.2.patch, 
> HIVE-4002.D8739.3.patch
>
>
> Aggregation queries with no group-by clause (for example, select count(*) 
> from src) executes final aggregation in single reduce task. But it's too 
> small even for single reducer because the most of UDAF generates just single 
> row for map aggregation. If final fetch task can aggregate outputs from map 
> tasks, shuffling time can be removed.
> This optimization transforms operator tree something like,
> TS-FIL-SEL-GBY1-RS-GBY2-SEL-FS + FETCH-TASK
> into 
> TS-FIL-SEL-GBY1-FS + FETCH-TASK(GBY2-SEL-LS)
> With the patch, time taken for auto_join_filters.q test reduced to 6 min (10 
> min, before).

--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira

Reply via email to