Skip to content

Comments

storage: allow sinks on multi-replica clusters#32066

Merged
petrosagg merged 2 commits intoMaterializeInc:mainfrom
petrosagg:multi-replica-sinks
Apr 2, 2025
Merged

storage: allow sinks on multi-replica clusters#32066
petrosagg merged 2 commits intoMaterializeInc:mainfrom
petrosagg:multi-replica-sinks

Conversation

@petrosagg
Copy link
Contributor

This PR extends the approach of
#31890 to the case of sinks. The handling is identical to that of single replica sources.

Motivation

Tips for reviewer

Checklist

  • This PR has adequate test coverage / QA involvement has been duly considered. (trigger-ci for additional test/nightly runs)
  • This PR has an associated up-to-date design doc, is a design doc (template), or is sufficiently small to not require a design.
  • If this PR evolves an existing $T ⇔ Proto$T mapping (possibly in a backwards-incompatible way), then it is tagged with a T-proto label.
  • If this PR will require changes to cloud orchestration or tests, there is a companion cloud PR to account for those changes that is tagged with the release-blocker label (example).
  • If this PR includes major user-facing behavior changes, I have pinged the relevant PM to schedule a changelog post.

@petrosagg petrosagg requested review from a team as code owners April 1, 2025 12:39
@petrosagg petrosagg requested a review from ParkMyCar April 1, 2025 12:39
This PR extends the approach of
MaterializeInc#31890 to the case of
sinks. The handling is identical to that of single replica sources.

Signed-off-by: Petros Angelatos <petrosagg@gmail.com>
@petrosagg petrosagg force-pushed the multi-replica-sinks branch from 123aec3 to 699cfdf Compare April 1, 2025 13:30
Copy link
Contributor

@ParkMyCar ParkMyCar left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Maybe get a second look at the storage-controller bits, but as far as I understand how the controller works, it all LGTM!

@@ -411,12 +473,17 @@ where
///
/// If `send_commands` is true, will send commands for newly-scheduled
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

This doc comment only references ingestions, it would be nice to update it to all talk about exports. Specifically I'm thinking a description of how a Kafka ingestion is multi-replica, but a Kafka export is single-replica

Copy link
Contributor Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Good catch, wlll fix

Signed-off-by: Petros Angelatos <petrosagg@gmail.com>
@petrosagg petrosagg enabled auto-merge April 2, 2025 09:17
@petrosagg petrosagg merged commit 89f7fe1 into MaterializeInc:main Apr 2, 2025
82 checks passed
@petrosagg petrosagg deleted the multi-replica-sinks branch April 2, 2025 10:08
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