Merged
Conversation
07f6203 to
25e0b25
Compare
Contributor
25e0b25 to
8fd35ae
Compare
Member
Author
|
I looked at test |
07e94f9 to
323fc70
Compare
b04c0ff to
7467a76
Compare
cde7cac to
457c1e0
Compare
4706987 to
a27fb47
Compare
CheSema
commented
Apr 2, 2025
CheSema
commented
Apr 2, 2025
CheSema
commented
Apr 2, 2025
30fa6b0 to
18ff169
Compare
Member
Author
|
|
9000bfd to
e2488f5
Compare
Member
Author
|
Stateless tests release: Stateless test msan: |
Michicosun
requested changes
Apr 11, 2025
tests/queries/0_stateless/02124_insert_deduplication_token_materialized_views.sql
Show resolved
Hide resolved
636ed03 to
3c509fd
Compare
Michicosun
approved these changes
Apr 25, 2025
4b55b78 to
92b8268
Compare
This was referenced May 6, 2025
github-merge-queue bot
pushed a commit
that referenced
this pull request
May 7, 2025
Revert "rework pushing to views #77309"
CheSema
added a commit
that referenced
this pull request
May 8, 2025
1 task
github-merge-queue bot
pushed a commit
that referenced
this pull request
May 16, 2025
…-to-views Revert "Revert "rework pushing to views #77309""
This was referenced May 21, 2025
This was referenced May 26, 2025
1 task
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Add this suggestion to a batch that can be applied as a single commit.This suggestion is invalid because no changes were made to the code.Suggestions cannot be applied while the pull request is closed.Suggestions cannot be applied while viewing a subset of changes.Only one suggestion per line can be applied in a batch.Add this suggestion to a batch that can be applied as a single commit.Applying suggestions on deleted lines is not supported.You must change the existing code in this line in order to create a valid suggestion.Outdated suggestions cannot be applied.This suggestion has been applied or marked resolved.Suggestions cannot be applied from pending reviews.Suggestions cannot be applied on multi-line comments.Suggestions cannot be applied while the pull request is queued to merge.Suggestion cannot be applied right now. Please check back later.
This PR contains the preparation step on a way to implement deduplication with async inserts with materialized views.
Here I changed:
InsertDependenciesBuilder::createPostSinkcallscreatePostSink.ThreadStatus::internal_threadis removed. InsteadThreadGroup::createForMaterializedViewis used. For each MV a new designatedThreadGroupis created. All the stats are accumulated in the counters inside the thread group.logToQueryViewsLog. Now there is less code/classes to write the logs. NoViewRuntimeStatsclass is needed.materialized_views_ignore_errors, this PR includes changes from fix setting materialized_views_ignore_errors #73802*StorageLogsthat resulted in dropping the data when MV is removed.Also I faced and fixed:
LocalConnectiondid not send final stats at the endPushingAsyncPipelineExecutorhanged at the timeout withBREAKpolicy*Logstorages had wrong implementation ofcheckDependenciesmethod. It returnedtruewhen there are no dependencies at all.StorageURLSinkconnected remote url at the creating pipeline stage. I moved it to the execution stage.StorageSystemZooKeeper::writehad strange header configuration.A bit more explanation about guarantees when exception happen:
NOT_OKExample: exception happened in MV, than the data may be or may not be inserted in landing table.materialized_views_ignore_errors=true, than all exceptions in dependent tables have no effect on query execution. The landing table should have all data inserted. Query would have statusOK,system.query_views_logwould have the actual status for each dependent table.Related issue: #73015
Changelog category (leave one):
Changelog entry (a user-readable short description of the changes that goes to CHANGELOG.md):
Refactoring pushing to views.
Documentation entry for user-facing changes