Skip to content

Conversation

@Gabriel39
Copy link
Contributor

Proposed changes

pick #34122 #35454 #35716 #37195

apache#35454)

…d data distribution

This is a follow-up for apache#34122 .
Currently, we use bucket shuffle local exchange to re-distribution data
before a 'colocated' operator. But if no colocate/bucket-shuffle join
followed, bucket-shuffle for this operator is not always suitable
because the parallism will be restricted by the account of buckets
Now we use ``` DataGenOperator (num_instance=1) ->
ResultSinkOperator(num_instance=1) ``` for loading/query tasks.

This PR use a local shuffle to improve its parallelism and the plan is
``` DataGenOperator (num_instance=1) -> LocalExchangeSink (num_instance=1) -> LocalExchangeSource (num_instance=(cores / 2) -> ResultSinkOperator(num_instance=(cores / 2)) ```
@doris-robot
Copy link

Thank you for your contribution to Apache Doris.
Don't know what should be done next? See How to process your PR

Since 2024-03-18, the Document has been moved to doris-website.
See Doris Document.

@Gabriel39
Copy link
Contributor Author

run buildall

@github-actions
Copy link
Contributor

clang-tidy review says "All clean, LGTM! 👍"

@Gabriel39 Gabriel39 merged commit 7155711 into apache:branch-2.1 Aug 29, 2024
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants