Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat(sink): turn sink writer into higher level log sinker #12152

Merged
merged 22 commits into from
Sep 26, 2023

Conversation

wenym1
Copy link
Contributor

@wenym1 wenym1 commented Sep 7, 2023

I hereby agree to the terms of the RisingWave Labs, Inc. Contributor License Agreement.

What's changed and what's your intention?

Part of #12060.

In this PR, we change the associated type Writer of Sink to LogSinker that implements the trait LogSinker. The LogSinker has a method consume_log_and_sink, which accepts a log reader and return a future. When the future is driven, it will consume the log and sink data to the external sink. The current SinkWriter is kept, and can be ported to the new LogSinker trait with an adapter named LogSinkerOf, whose implementation is the current logic execute_consume_log of SinkExecutor.

Besides, the definition of log store related trait is moved from stream crate to connector crate so that in the log sinker trait can refer to the log reader. The implementation of log store trait is remained in the stream crate out of dependency reason.

Checklist

  • I have written necessary rustdoc comments
  • I have added necessary unit tests and integration tests
  • I have added fuzzing tests or opened an issue to track them. (Optional, recommended for new SQL features Sqlsmith: Sql feature generation #7934).
  • My PR contains breaking changes. (If it deprecates some features, please create a tracking issue to remove them in the future).
  • All checks passed in ./risedev check (or alias, ./risedev c)
  • My PR changes performance-critical code. (Please run macro/micro-benchmarks and show the results.)
  • My PR contains critical fixes that are necessary to be merged into the latest release. (Please check out the details)

Documentation

  • My PR needs documentation updates. (Please use the Release note section below to summarize the impact on users)

Release note

If this PR includes changes that directly affect users or other significant modifications relevant to the community, kindly draft a release note to provide a concise summary of these changes. Please prioritize highlighting the impact these changes will have on users.

@wenym1 wenym1 requested a review from a team as a code owner September 7, 2023 10:15
Copy link
Contributor

@github-actions github-actions bot left a comment

Choose a reason for hiding this comment

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

license-eye has totally checked 4066 files.

Valid Invalid Ignored Fixed
1794 1 2271 0
Click to see the invalid file list
  • src/connector/src/sink/blackhole.rs

src/connector/src/sink/blackhole.rs Outdated Show resolved Hide resolved
@codecov
Copy link

codecov bot commented Sep 7, 2023

Codecov Report

Merging #12152 (90d2028) into main (f38554e) will decrease coverage by 0.03%.
The diff coverage is 19.80%.

@@            Coverage Diff             @@
##             main   #12152      +/-   ##
==========================================
- Coverage   69.43%   69.41%   -0.03%     
==========================================
  Files        1438     1440       +2     
  Lines      238698   238771      +73     
==========================================
  Hits       165740   165740              
- Misses      72958    73031      +73     
Flag Coverage Δ
rust 69.41% <19.80%> (-0.03%) ⬇️

Flags with carried forward coverage won't be shown. Click here to find out more.

Files Coverage Δ
src/connector/src/sink/coordinate.rs 0.00% <ø> (ø)
...m/src/common/log_store_impl/kv_log_store/buffer.rs 87.30% <ø> (ø)
...ream/src/common/log_store_impl/kv_log_store/mod.rs 92.13% <ø> (ø)
...c/common/log_store_impl/kv_log_store/test_utils.rs 100.00% <ø> (ø)
...m/src/common/log_store_impl/kv_log_store/writer.rs 92.85% <ø> (ø)
src/stream/src/executor/error.rs 26.43% <ø> (+0.88%) ⬆️
src/connector/src/sink/mod.rs 55.35% <88.88%> (+13.59%) ⬆️
src/connector/src/sink/redis.rs 0.00% <0.00%> (ø)
src/connector/src/sink/kafka.rs 34.09% <0.00%> (-0.08%) ⬇️
src/connector/src/sink/log_store.rs 89.38% <92.59%> (ø)
... and 16 more

... and 3 files with indirect coverage changes

📣 We’re building smart automated test selection to slash your CI/CD build times. Learn more

Copy link
Collaborator

@hzxa21 hzxa21 left a comment

Choose a reason for hiding this comment

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

LGTM

@wenym1 wenym1 enabled auto-merge September 26, 2023 09:02
@wenym1 wenym1 added this pull request to the merge queue Sep 26, 2023
Merged via the queue into main with commit 471bfa2 Sep 26, 2023
7 of 8 checks passed
@wenym1 wenym1 deleted the yiming/sink-as-log-consumer branch September 26, 2023 09:44
BugenZhao pushed a commit that referenced this pull request Sep 27, 2023
…2123)

feat(java-binding): generate jni method signature with macro (#12487)

feat(streaming): recover `no_shuffle_backfill` (#12493)

feat(test): support customized source logic in deterministic test (#12456)

refactor(storage): reorg selector (#12392)

feat(frontend): add rw_catalog.rw_hummock_sstables (#12532)

chore: bump risingwave version in docker compose to 1.2.0 (#12530)

Signed-off-by: Bugen Zhao <[email protected]>

refactor(sink): decouple sink formatter and payload writer (#12515)

chore(java-binding): refine stream chunk benchmark (#12504)

feat(meta): add create_type to `Table` (#12529)

refactor(sink): refine sink trait and macro (#12478)

refactor(backup): refine error message (#12388)

feat(sink): turn sink writer into higher level log sinker (#12152)

fix(over window): don't expect stream keys in UpdateDelete and UpdateInsert the same (#12536)

Signed-off-by: Richard Chien <[email protected]>

refactor(expr): separate function implementations into a new crate (#12485)

Signed-off-by: Runji Wang <[email protected]>

fix(config): make metrics_level opt backward compatible (#12541)

refactor(connector): replace sink writer rpc with jni (#12480)

refactor(connector): remove `WriteGuard` and `fulfill_meta_column` from parser (#12542)

Signed-off-by: Bugen Zhao <[email protected]>

feat(sink): handle stream key sink pk mismatch (#12458)

feat(optimizer): support apply hop window transpose rule (#12338)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants