risingwavelabs / risingwave

Best-in-class stream processing, analytics, and management. Perform continuous analytics, or build event-driven applications, real-time ETL pipelines, and feature stores in minutes. Unified streaming and batch. PostgreSQL compatible.
https://go.risingwave.com/slack
Apache License 2.0
6.99k stars 575 forks source link

system table for source health status #17163

Open neverchanje opened 4 months ago

neverchanje commented 4 months ago

Is your feature request related to a problem? Please describe.

It's very common that the source is connectible but somehow just not consumable. In this case, we need a interface to see what's going on rather than checking the system logs. Even as a system admin of RisingWave, I would feel frustrating to check the logs, not to mention the users.

Describe the solution you'd like

Either adding the extra information to rw_sources or introducing a new system table called rw_source_status will be fine to me.

Describe alternatives you've considered

No response

Additional context

No response

BugenZhao commented 4 months ago

Just to clarify, source is not a physical concept until #16003 get completed. It's possible that one source executor encounters failure, while another executor for the same source (in another streaming job) is still healthy.

st1page commented 3 months ago

Just to clarify, source is not a physical concept until #16003 get completed. It's possible that one source executor encounters failure, while another executor for the same source (in another streaming job) is still healthy.

Yes, and since shared source needs to implement the backfill operator for each kind of source. We must have some kinds of sources that don't implement shared source for a long time. so the system table's item must be a physical source.