-
Notifications
You must be signed in to change notification settings - Fork 6.9k
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Made parallel_reading_from_replicas
work with localhost replica
#36281
Made parallel_reading_from_replicas
work with localhost replica
#36281
Conversation
@Mergifyio update |
✅ Branch has been successfully updated |
checkStackSize(); | ||
|
||
auto query_plan = std::make_unique<QueryPlan>(); | ||
auto mutable_context = const_pointer_cast<Context>(context); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
That does not seem to be safe to me.
Note, here inside InterpreterSelectQuery we copy context:
, context(Context::createCopy(context_)) |
Maybe it would be better to:
- create InterpreterSelectQuery first
- add a method inside InterpreterSelectQuery which setMergeTreeReadTaskCallback
- buildQueryPlan
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
everything else is ok
Intergration tests: |
Changelog category (leave one):
Changelog entry (a user-readable short description of the changes that goes to CHANGELOG.md):
We create a local interpreter if we want to execute query on localhost replica. But for when executing query on multiple replicas we rely on the fact that a connection exists so replicas can talk to coordinator. It is now improved and localhost replica can talk to coordinator directly in the same process