Skip to content

Conversation

@antiguru
Copy link
Member

@antiguru antiguru commented Jan 29, 2025

Combine all logging dataflows into a single dataflow.

This allows easier sharing between the dataflows as events can be send through streams, instead of injecting them into the log events for later processing. The change looks substantial, but shouldn't alter behavior other than that injected commands pass through actual streams instead of injecting them into the logging dataflows.

This has some benefits: The injected commands are consistent, i.e., they arrive at the expected time, and this change enables us to share information across logging dataflows more easily, for example to do analysis such as #31246.

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.

Copy link
Contributor

@teskje teskje left a comment

Choose a reason for hiding this comment

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

Looks good, my comments are mostly about removing/simplifying stuff. There is one about not naming the logging regions Dataflow: * that I think is important though.

@antiguru antiguru force-pushed the watchdog_dataflow branch 3 times, most recently from 39a02cb to da857ac Compare February 26, 2025 15:12
@antiguru antiguru requested a review from teskje February 26, 2025 15:17
Copy link
Contributor

@teskje teskje left a comment

Choose a reason for hiding this comment

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

LGTM once CI agrees. Might be a good idea to run the Nightlies as well.

Pass compute events through a stream instead of injecting them into the
compute event log.

Signed-off-by: Moritz Hoffmann <[email protected]>
@antiguru antiguru merged commit 2fb003f into MaterializeInc:main Feb 28, 2025
243 of 245 checks passed
@antiguru antiguru deleted the watchdog_dataflow branch February 28, 2025 18:39
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