[
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