William Wen

perf(storage): reduce calling async method with poll_next in iterator

11

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? In previous benchmark, we have observed that calling too...

feat(storage): handle sync in flush controller

1

I hereby agree to the terms of the [Singularity Data, Inc. Contributor License Agreement](https://gist.github.com/skyzh/0663682a70b0edde7ae991492f2314cb#file-s9y_cla). ## What's changed and what's your intention? In our current code, when we call `clear_shared_buffer` during...

Tracking: improve the robustness of recovery

2

Our current recovery logic is not robust. We have multiple concurrent in-flight barrier and will trigger recovery when any of the barrier failed. The recovery will start clearing the memory...

Ability to pass customized connector for channel with multiple endpoints

1

## Feature Request ### Crates `tonic` https://github.com/hyperium/tonic/tree/master/tonic/src/transport/channel ### Motivation For channel with a single endpoint, we can create the channel with customized connector by calling `Endpoint::connect_with_connector`. However, we are not...

feat(meta): inject and collect barrier in bidi stream

2

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://gist.github.com/TennyZhuang/f00be7f16996ea48effb049aa7be4d66#file-rw_cla). ## What's changed and what's your intention? In this PR, we replace the `inject_barrier`, `collect_barrier` and...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://gist.github.com/TennyZhuang/f00be7f16996ea48effb049aa7be4d66#file-rw_cla). ## What's changed and what's your intention? After https://github.com/risingwavelabs/risingwave/pull/15300 ## Checklist - [ ] I have...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://gist.github.com/TennyZhuang/f00be7f16996ea48effb049aa7be4d66#file-rw_cla). ## What's changed and what's your intention? Previously, to store values of multiple versions of a...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://gist.github.com/TennyZhuang/f00be7f16996ea48effb049aa7be4d66#file-rw_cla). ## What's changed and what's your intention? Previously after we collect a barrier, we call `complete_barrier`...

Feature request: support passing customized connector or connector adapter

3

## Motivation We are using AWS S3 or any S3 compatible object store as our storage backend. Previously we use [aws-sdk-s3](https://github.com/awslabs/aws-sdk-rust/tree/main/sdk/s3) to access the object store, and recently we are...

I hereby agree to the terms of the [RisingWave Labs, Inc. Contributor License Agreement](https://gist.github.com/TennyZhuang/f00be7f16996ea48effb049aa7be4d66#file-rw_cla). ## What's changed and what's your intention? Currently in event handler, when flush task finishes, we...