streaming: eliminate usages of RwError
#3116
Labels
component/streaming
Stream processing related issue.
difficulty/medium
Issues that need some knowledge of the whole system
good first issue
Good for newcomers
help wanted
Issues that need help from contributors
type/refactor
When we were refactoring the streaming executors with async-stream, we decided to also refactor the error type with the per-crate manner. For compatibility, we still capsulate some
RwError
s in theStreamExecutorError
.https://github.com/singularity-data/risingwave/blob/f2c5758789ddd22ba6edbfeb6d7f5279ac919f9c/src/stream/src/executor/error.rs#L35-L57
After #2366 was introduced, we can start to eliminate these usages now.
AggStateError(RwError)
variant in stream executor error. #3133TopNStateError(RwError)
variant in stream executor error. #3134HashJoinError(RwError)
variant in stream executor error. #3135SourceError(RwError)
variant in stream executor error. #3136The text was updated successfully, but these errors were encountered: