Hacktoberfest 2026: những issue maintainer đã đánh dấu cho tháng Mười, đang mở và phù hợp người mới. Xem issue Hacktoberfest

Cassandra: TransactWriteItems writes no stream record

Đang mở
  • Có gì không ổn?
#516 0 bình luận 0 reaction 1 người được giao Xem trên GitHub

Maintainer thường phản hồi trong vòng 2 ngày

@LeeroyHannigan đang làm issue này rồi.

Từ ngày 25/10/2026.

  • #576 của @LeeroyHannigan — đang mở

Đánh giá

Độ khó
3/5
Thời gian dự kiến
1-2 ngày
Mức phù hợp với người mới
68/100
Loại issue
Lỗi
Độ rõ ràng
Đặc tả rõ ràng
Mức độ hoạt động
Sôi nổi
Công nghệ
cassandra, rust
Lĩnh vực
database

Hướng nghiên cứu

Read crates/storage-cassandra/src/data/transactions.rs and compare its LOGGED BATCH construction with the write helpers used by single-item and batch writes to see how they capture stream records. Add the transaction stream capture for each item mutation, then run a wire test covering transacted Put, Update and Delete on a streamed table across every backend; done means all three produce stream records alongside their item writes.

Do mô hình lập chỉ mục viết ra từ nội dung của issue.

Mô tả

bug cassandra

Summary

On the Cassandra backend a TransactWriteItems Put, Update or Delete on a table with an enabled stream records nothing to the stream. PutItem and BatchWriteItem on the same table record as expected; SQLite records all five shapes.

Measured on a server built from main 744ea291 against a Cassandra 4.1 node: a fresh table with NEW_AND_OLD_IMAGES, one PutItem, one BatchWriteItem Put, one TransactWriteItems with a Put, an Update and a Delete; GetRecords from TRIM_HORIZON on every shard returned the two single-item writes and none of the three transacted ones. On the service a transacted write produces a stream record like any other write.

Cause

crates/storage-cassandra/src/data/transactions.rs has no stream handling: the LOGGED BATCH it builds carries the item mutations only. The single-item and batch paths go through the write helpers that append the stream record to the batch.

Fix shape

Route the transaction's mutations through the same stream capture the single-item path uses, appending one stream record per item mutation to the LOGGED BATCH, so the record and the item land together. A wire test with a transacted Put, Update and Delete on a streamed table, run on every backend.

Found while reviewing #515.

Ngôn ngữ chính
Rust
Star
517
Fork
60
Merge trung bình
2 ngày 23 giờ
Pull request đã merge (30 ngày)
25

Chuẩn bị môi trường

Bắt đầu từ đâu

  1. Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
  2. Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
  3. Fork repository và làm thay đổi trên một nhánh.
  4. Mở pull request có tham chiếu số hiệu của issue.

Issue khác của ExtendDB/extenddb

Tất cả issue của ExtendDB/extenddb

Issue tương tự

Thêm issue về Rust

Nhận issue mới trong hộp thư của bạn

Bản tóm tắt ngắn những issue GitHub phù hợp với người mới.