Skip to content
Open
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
288 commits
Select commit Hold shift + click to select a range
f4b0628
chore: optimize get_char method (#105)
luoyuxia Dec 21, 2025
f553759
feat: support ListOffset/SubscribeBatch/DropTable for cpp bindings (#…
zhaohaidao Dec 21, 2025
3918917
chore: introduce prefetch to improve log poll performance (#103)
luoyuxia Dec 21, 2025
7515f71
chore: fix bug where column prune won't work when compression is enab…
leekeiabstraction Dec 22, 2025
2bf3701
chore: scanner should retry when bucket lead is not available (#102)
leekeiabstraction Dec 25, 2025
02ca3eb
chore: add integration test for list offsets (#52)
pavlospt Dec 25, 2025
4a225d5
feat: Introduce HashBucketAssigner (#117)
leekeiabstraction Dec 29, 2025
eea8da1
chore: rust client to return error when currently unimplemented non-d…
leekeiabstraction Jan 2, 2026
3d8483e
chore: add integration tests for subscribe_batch and project_by_name …
AndreaBozzo Jan 2, 2026
2fc00e2
feat: support bazel build for cpp bindings (#107)
zhaohaidao Jan 2, 2026
9f834df
feat: implement CompactedRowWriter (#121)
Kelvinyu1117 Jan 3, 2026
83c4525
chore: add license header to fix ci (#123)
luoyuxia Jan 3, 2026
526d360
feat: return error for partitioned tables in FlussConnection#get_tabl…
Arnav-panjla Jan 6, 2026
49c3043
chore: fix append hang issue (#126)
zhaohaidao Jan 7, 2026
6459f2c
chore: Fix scanner's example documentation test to allow `cargo test …
leekeiabstraction Jan 9, 2026
305a448
feat: introduce CompactedKeyEncoder (#124)
leekeiabstraction Jan 9, 2026
1f54795
feat: log scanner support poll record batch directly
fresh-borzoni Jan 10, 2026
d61086f
feat: introduce CompactedRowReader, CompactedRow, CompactedRowDeseria…
Kelvinyu1117 Jan 10, 2026
98497be
chore: fix Box leaking and batch API refactor (#136)
fresh-borzoni Jan 10, 2026
0f4f4ec
chore: Improve write path error handling logic (#132)
zhaohaidao Jan 11, 2026
69b3ccc
chore: improve datum, use Cow to reduce verbosity and avoid Box::leak…
leekeiabstraction Jan 11, 2026
e9d16ae
chore: implement zero copy in CompactedRowReader (#138)
luoyuxia Jan 11, 2026
979c0d4
chore: fix potential deadlock with holding lock during await (#145)
fresh-borzoni Jan 12, 2026
63509b1
chore: decrement flushes_in_progress counter in await_flush_comp (#147)
fresh-borzoni Jan 12, 2026
3cdc495
chore: add DEVELOPMENT.md (#155)
leekeiabstraction Jan 14, 2026
d8fdcc7
feat: introduce KvRecordBatchBuilder (#156)
fresh-borzoni Jan 15, 2026
207a7d1
chore: Introduce WriteFormat and various small changes to unblock Ups…
leekeiabstraction Jan 15, 2026
b9cc78b
feat: Introduce CompactedRowEncoder (#161)
leekeiabstraction Jan 15, 2026
c4d5b02
feat: add column projection support to Python LogScanner (#151)
fresh-borzoni Jan 16, 2026
dce62d6
chore: fix read deadlock (#165)
zhaohaidao Jan 16, 2026
93048ed
feat: introduce lookup support for primary key tables (#159)
AndreaBozzo Jan 17, 2026
9ce10ce
feat: Introduce python bindings row-based append API (#142)
fresh-borzoni Jan 17, 2026
a440983
chore: Improve read path error handling logic (#143)
zhaohaidao Jan 17, 2026
ffc026d
chore: correct log record batch checksum bounds (#172)
zhaohaidao Jan 17, 2026
41f824f
feat: Introduce KVReadContext and read path wiring (#174)
fresh-borzoni Jan 17, 2026
f519ad9
feat: introduce KvWriteBatch and PutKvRequest (#176)
luoyuxia Jan 18, 2026
db565f9
feat: support all basic datatypes in compacted key encoder(continuati…
fresh-borzoni Jan 19, 2026
0e31ef4
feat: Introduce UpsertWriter (#169)
leekeiabstraction Jan 20, 2026
d263743
feat: Introduce Kv table example (#181)
leekeiabstraction Jan 20, 2026
76029f7
feat: KvWriteBatch wiring in Sender (#184)
leekeiabstraction Jan 21, 2026
203093c
feat: Fix TableLookup so that SchemaId field bytes are not passed to …
leekeiabstraction Jan 21, 2026
2f3269d
feat: Arrow serialization for decimal and temporal types (#196)
fresh-borzoni Jan 23, 2026
ed9bca6
chore: invalidate leader info on stale metadata error when handling f…
zhaohaidao Jan 23, 2026
e2e0c22
test: Kv Table Integration tests (#192)
leekeiabstraction Jan 23, 2026
add9dd7
test: add it test for put & get kv for all supported datatypes (#204)
linguoxuan Jan 24, 2026
eda19e2
feat: introduce priority queue for downloading remote segments (#187)
fresh-borzoni Jan 25, 2026
d695cb8
feat: Implement Admin APIs for partitioning (#208)
leekeiabstraction Jan 25, 2026
8406db0
chore: add more info for RecordBatches (#211)
fresh-borzoni Jan 25, 2026
9408a03
feat: Support Arrow append operations for decimals, temporal types in…
fresh-borzoni Jan 25, 2026
54ef268
chore: introduce new with capacity to align generic row with java sid…
luoyuxia Jan 25, 2026
24c4634
test: add it for produce & scan log for all supported datatypes (#205)
linguoxuan Jan 26, 2026
bf72035
chore: introduce SecurityTokenManager to update token in the backgrou…
luoyuxia Jan 26, 2026
c80d0aa
chore: Add blocking poll into python bindings (#154)
fresh-borzoni Jan 27, 2026
bc7efea
chore: Introduce PartitionGetter and Partition utils (#214)
leekeiabstraction Jan 27, 2026
9371dcc
[chore] Implement is_auto_partitioned method in table.rs (#48)
beryllw Jan 28, 2026
0fe410e
chore: minor fix for rust code (#218)
luoyuxia Jan 28, 2026
06b30c2
chore: Fix async fn panic in CancellationSafeFuture when future comp…
luoyuxia Jan 28, 2026
9ccf598
chore: support estimated_size_in_bytes for write batch (#219)
luoyuxia Jan 29, 2026
2db8982
feat: support scan from oss (#217)
luoyuxia Jan 30, 2026
80ac6fd
feat: Implement partitioning in Upsert / Lookup (#220)
leekeiabstraction Jan 30, 2026
9a61576
feat: support produce partitioned table (#228)
luoyuxia Jan 30, 2026
b7d511d
feat: support list offset for partitioned table (#229)
luoyuxia Feb 1, 2026
17ba9d1
feat: support list partition offset in cpp binding (#231)
luoyuxia Feb 3, 2026
da22ac8
feat: introduce scan record batch in cpp (#230)
luoyuxia Feb 3, 2026
21585a5
chore: make Config#bootstrap_server required (#233)
luoyuxia Feb 3, 2026
b399e8e
chore: accept Into<String> to improve api usage (#234)
luoyuxia Feb 3, 2026
9231fb4
feat: add table partition scanning (#222)
lemorage Feb 4, 2026
becde55
feat: support subscribe partition in cpp binding (#236)
luoyuxia Feb 4, 2026
2ad9dfe
chore: Reject table scan for INDEXED format or KV table (#238)
leekeiabstraction Feb 4, 2026
f7fb741
feat: introduce kv tables support in python (#239)
fresh-borzoni Feb 4, 2026
a084659
feat: Support different poll methods (#246)
fresh-borzoni Feb 5, 2026
63683f5
chore: Change upsert and delete to use read only self reference by us…
leekeiabstraction Feb 5, 2026
60b86d7
chore: refator to builder pattern to create log scanner for CPP (#249)
fresh-borzoni Feb 5, 2026
4ed23ff
chore: rename subscribe_batch to subscribe_buckets (#255)
luoyuxia Feb 5, 2026
b483647
feat: Support drop_table, partitions and offsets methods in python bi…
fresh-borzoni Feb 5, 2026
28cd8b0
feat: support unsubscribe partition (#257)
luoyuxia Feb 6, 2026
024c1d1
feat: introduce list partitions in cpp binding (#260)
luoyuxia Feb 6, 2026
40f13b1
chore: python binding cleanup and bit of refactor (#264)
fresh-borzoni Feb 7, 2026
5a334bc
chore: Fire-and-forget behaviour for effecient batching (#258)
fresh-borzoni Feb 7, 2026
6ca3bd7
chore: introduce deny to check licenses (#267)
luoyuxia Feb 7, 2026
9202964
ci: Fix unstable poll_batches (#272)
fresh-borzoni Feb 7, 2026
b677a6b
chore: remove async from queueing while writing (#271)
fresh-borzoni Feb 7, 2026
f0a740e
feat: Add unsubscribe_partition to python bindings (#277)
fresh-borzoni Feb 8, 2026
b05a497
build: add how to release doc (#268)
luoyuxia Feb 8, 2026
e9e3db4
feat: support temporal types in CPP (#266)
fresh-borzoni Feb 8, 2026
c68ef03
feat: support decimals in cpp binding (#265)
fresh-borzoni Feb 8, 2026
ac28f8e
feat: Add subscribe_partition_buckets method and partitions support (…
fresh-borzoni Feb 8, 2026
a056cfd
chore: remove async for upsert/delete/append in python (#280)
luoyuxia Feb 8, 2026
6e7aa7c
feat: support database-level ops in python (#279)
luoyuxia Feb 8, 2026
db996f8
chore: introduce getters in CPP Datum (#281)
fresh-borzoni Feb 8, 2026
1c0b97a
feat: introduce database level ops for cpp bindings (#286)
luoyuxia Feb 8, 2026
ecb1228
doc: introduce how to verify a release document (#282)
luoyuxia Feb 8, 2026
f3a42f1
chore: cleanup and fix partial update in python (#292)
fresh-borzoni Feb 9, 2026
d44898e
feat: support kv tables in CPP (#288)
fresh-borzoni Feb 9, 2026
02fc411
feat: Partitioned KV tables python example (#290)
fresh-borzoni Feb 9, 2026
219c016
doc: add python docs and API reference (#291)
fresh-borzoni Feb 10, 2026
f516911
doc: Add documentation for rust (#242)
leekeiabstraction Feb 10, 2026
9c07769
feat: support projection by names in CPP (#294)
fresh-borzoni Feb 10, 2026
de88bbf
chore: Builder pattern, cleanup, consistent API (#296)
fresh-borzoni Feb 11, 2026
ef5f600
chore: refacotr config for CPP and connect -> create in cpp binding(…
fresh-borzoni Feb 11, 2026
309d6ea
chore: Verify API consistent across clients (#302)
fresh-borzoni Feb 12, 2026
2865891
chore: align DataLakeFormat parsing with lake format config option (#…
zuston Feb 13, 2026
7ec82a5
feat: add unsubscribe to all clients (#305)
fresh-borzoni Feb 13, 2026
110690c
chore: Fix issue where FixedSizedBinary type cannot be build in arrow…
leekeiabstraction Feb 13, 2026
80d903f
chore: remove LATEST_OFFSET which isn't handle by server (#312)
leekeiabstraction Feb 14, 2026
815596d
chore: allow propagating hostname as raw bootstrap address (#307)
zuston Feb 14, 2026
bf20af9
[docs] introduce client doc website (#300)
leekeiabstraction Feb 15, 2026
6adf7fe
chore: cleanup after docs review (#313)
fresh-borzoni Feb 16, 2026
32347c7
chore: Fix API error not being propagated on python side. (#340)
leekeiabstraction Feb 16, 2026
e1ec842
chore: added Default Implementations for Missing Types (#326)
niknegi Feb 16, 2026
5333e45
chore: default cpp builds to release mode (#345)
zhaohaidao Feb 16, 2026
c9e72e6
doc: Add missed API documentation update (#337)
leekeiabstraction Feb 17, 2026
919e218
chore: added unit test cases and throw an exception when any field do…
niknegi Feb 17, 2026
1720ca0
chore: avoid data copy in CPP bindings (#330)
fresh-borzoni Feb 17, 2026
9eadba8
test: introduce python integration tests (#341)
leekeiabstraction Feb 17, 2026
56d5ca1
chore: Fix issue where interleaving non-Pk column with PK columns cau…
leekeiabstraction Feb 17, 2026
bb68532
chore: add API reference for CustomProperty (#336)
leekeiabstraction Feb 17, 2026
11299f2
chore: add missing ChangeType enum and doc in C++. Add test coverage …
leekeiabstraction Feb 18, 2026
70160fd
chore: fix sparse to dense representation for CPP lookup (#348)
fresh-borzoni Feb 18, 2026
74c9241
chore: add CI for documentation. Minor improvement and organisation o…
leekeiabstraction Feb 18, 2026
f79a9bd
chore: update docs after opaque types CPP rework (#349)
fresh-borzoni Feb 18, 2026
cb4a9b3
chore: make RowView shared_ptr (#353)
fresh-borzoni Feb 19, 2026
eeb5200
chore: Scan results returned per bucket python/cpp (#351)
fresh-borzoni Feb 20, 2026
0f45560
chore: introduce c++ integration test (#352)
leekeiabstraction Feb 22, 2026
58e9de5
chore: add notes on lake snapshot (#359)
leekeiabstraction Feb 22, 2026
60d3f41
chore: introduce max poll records config option (#355)
fresh-borzoni Feb 22, 2026
30a8bae
chore: fix broken link and version mismatch in README (#364)
charlesdong1991 Feb 22, 2026
d1d8323
chore: fix IT failure from additional table properties (#368)
leekeiabstraction Feb 23, 2026
6fd0ab2
chore: rename BucketView to BucketRecords (#370)
fresh-borzoni Feb 24, 2026
4862442
feat: Add round robin bucket assigner (#360)
charlesdong1991 Feb 25, 2026
81b06ae
chore: Fix panic / crashes in Rust and C++ (#365)
leekeiabstraction Feb 27, 2026
7eb86a7
chore: make batch timeout configurable (#371)
Prajwal-banakar Feb 27, 2026
bb5bdf3
perf: introduce streaming download for file download (#381)
zhaohaidao Feb 27, 2026
39bc209
feat: Add get_server_nodes to Admin (#363)
charlesdong1991 Feb 28, 2026
1f4ff05
feat: support sasl/plain auth (#375)
fresh-borzoni Feb 28, 2026
99d6621
chore:fix test_get_server_nodes to use shared cluster (#392)
fresh-borzoni Feb 28, 2026
e3e9e4e
[doc] Update API Ref following SASL / NoKeyAssigner (#396)
leekeiabstraction Mar 1, 2026
7bb905d
[doc] Update doc after rust / c++ panic fixes (#395)
leekeiabstraction Mar 1, 2026
c100ee3
chore: Add missing python type stubs (#400)
charlesdong1991 Mar 1, 2026
2007207
docs: add cpp build guides with examples (#376)
zhaohaidao Mar 2, 2026
316d1a0
chore: update dependency list for release 0.1.0
luoyuxia Mar 2, 2026
eb60036
Bump version to 0.2.0
luoyuxia Mar 2, 2026
0ea4e07
ci: update verify tag version
luoyuxia Mar 2, 2026
7818f02
chore: update rust docs (#416)
luoyuxia Mar 3, 2026
1fefc8d
chore: error handling fix CPP, for pointer returning methods (#409)
fresh-borzoni Mar 3, 2026
0e86cc3
ci: fix ci build wheel issue for python (#419)
luoyuxia Mar 3, 2026
b9944eb
chore: fix mut schema builder public api (#420)
fresh-borzoni Mar 3, 2026
2f0f517
[doc] Setup workflow for doc publish (#414)
leekeiabstraction Mar 4, 2026
8ba7762
doc: update create a release doc (#421)
luoyuxia Mar 4, 2026
b953ab1
feat: Add getter/setter property for writer_bucket_no_key_assigner co…
charlesdong1991 Mar 5, 2026
8fdccce
chore: update testing fluss image to 0.9.0 (#426)
aicontentcreate2023-star Mar 5, 2026
f2b7d7f
chore: Remove config duplication in examples (#427)
charlesdong1991 Mar 7, 2026
3ddbebe
ci: parallelize cpp integration tests (#434)
fresh-borzoni Mar 8, 2026
036fac0
chore: pre-size Arrow builders and recommend jemalloc for write path …
fresh-borzoni Mar 8, 2026
e3316f6
ci: parallelize python integration tests (#435)
fresh-borzoni Mar 8, 2026
1bf6d96
ci: check tablet server availabitility (#437)
charlesdong1991 Mar 9, 2026
89e77ba
chore: refactor to typed Column Writers (#440)
fresh-borzoni Mar 11, 2026
520c842
feat(python): add get_primary_keys() method to Schema class (#436)
XiaoHongbo-Hope Mar 11, 2026
0fe3978
chore: added is_retriable() to FlussError (#422)
toxicteddy00077 Mar 11, 2026
45be5c1
feat: allow configuring scanner fetch parameters (#417)
Prajwal-banakar Mar 12, 2026
7413fce
[client] Add LookupResult::to_record_batch() (#411)
Prajwal-banakar Mar 15, 2026
ce67b9f
feat: introduce idempotent writes (#404)
fresh-borzoni Mar 15, 2026
5f1d86e
chore: no-op .asf.yaml change to attempt trigger gh page setup
leekeiabstraction Mar 19, 2026
007244e
troubeshooting test commit
clambertus Mar 19, 2026
7d8ab3d
INFRA-27705 - infrastructure test commit
clambertus Mar 19, 2026
fd2de53
INFRA-27705 - remove test label
clambertus Mar 19, 2026
a106cb6
doc: optimize pyfluss description in pypi (#439)
luoyuxia Mar 20, 2026
c5cddd9
Revert "Bump version to 0.2.0"
luoyuxia Mar 20, 2026
7b9a400
[doc] Update fluss-rust readme markdown (#415)
luoyuxia Mar 20, 2026
05b73f4
chore: Idempotency bug: OOO loop when response is lost but subsequent…
fresh-borzoni Mar 21, 2026
ff98cc7
chore: added check to get_admin() before creating new admin (#369)
toxicteddy00077 Mar 23, 2026
ffa14b2
chore: make get admin sync (#450)
luoyuxia Mar 23, 2026
5a230cb
chore: update dependency list for release 0.1.0
Mar 23, 2026
bcea566
Bump version to 0.2.0
Mar 23, 2026
aed85b7
feat: Add array data type support (#433)
charlesdong1991 Mar 28, 2026
f297f2c
[BUG] Fix possible TOCTOU race between leader discovery and server lo…
fresh-borzoni Mar 28, 2026
da7b026
[TASK-470] Optimize null append in Arrow builder (#471)
fresh-borzoni Mar 30, 2026
b2f7326
chore: fix annoying python CI/CD errors due to unsuported action (#473)
fresh-borzoni Apr 1, 2026
8957671
feat: [TASK-315] Proto + RPC for LimitScan (#472)
fresh-borzoni Apr 1, 2026
0010433
ci: fix release rust issue
luoyuxia Apr 3, 2026
037d0a9
ci: pin pypi publish action to ASF-approved SHA
luoyuxia Apr 3, 2026
4de0778
ci: improve read me for python
luoyuxia Apr 3, 2026
7e122e4
feat(iceberg): add IcebergBinaryRowWriter (#366)
charlesdong1991 Apr 5, 2026
0f7cfc1
fix: add missing write_array impl to IcebergBinaryRowWriter (#477)
leekeiabstraction Apr 5, 2026
6c3c4b5
chore: improve cargo cache (#478)
fresh-borzoni Apr 5, 2026
8fa67f6
fix: upgrade testcontainers to 0.27.2 to resolve CVEs (#482)
leekeiabstraction Apr 5, 2026
1d97a10
chore: skip duplicate pyfluss build in Python CI (#483)
fresh-borzoni Apr 5, 2026
cbe878f
feat: add async 'for' loop support to LogScanner (#424) (#438)
qzyu999 Apr 9, 2026
a36bf1b
[test][infra] Unify IT infrastructure for all clients (#476)
fresh-borzoni Apr 9, 2026
411b1dc
fix python 3.11 bug in tests with async wait_for (#488)
fresh-borzoni Apr 10, 2026
d9b5358
chore: fix docusaurus (#486)
fresh-borzoni Apr 11, 2026
1da2c10
[ci] use swatinem/rust-cache (#485)
fresh-borzoni Apr 11, 2026
e43d35a
feat: Add array data type support for Python (#474)
qzyu999 Apr 13, 2026
82d08bc
[ci] Upgrade checkout@v4 to v6 and setup-python@v5 to v6 (#491)
leekeiabstraction Apr 13, 2026
b01930f
feat: Byte-sized cap instead of hard one for ArrowWriter (#443)
fresh-borzoni Apr 13, 2026
d1e6015
feat: Elixir bindings initial PR (#452)
fresh-borzoni Apr 16, 2026
ce1d440
[ci/cd] fix python tests with more strict scoping (#494)
fresh-borzoni Apr 17, 2026
5e13f46
feat: support batch lookup (#216)
linguoxuan Apr 17, 2026
a7c4013
[ci] optimize check_license_and_formatting (#503)
fresh-borzoni Apr 19, 2026
16c8958
[ci] cache C++ build with sccache (#505)
fresh-borzoni Apr 19, 2026
e6f95e6
[rust][chore] fix unknow error code lost for forward compatibility pa…
fresh-borzoni Apr 19, 2026
7b4d711
feat: [rust] prefix lookup support (#500)
fresh-borzoni Apr 19, 2026
61db34e
chore: use the same cache in rust integration tests (#506)
fresh-borzoni Apr 19, 2026
afce912
[c++] Add c++ support for Array data type (#501)
charlesdong1991 Apr 23, 2026
7463913
build(deps): bump actions/download-artifact from 4 to 8 (#408)
dependabot[bot] Apr 25, 2026
035fcfa
feat: [metrics] Create metrics framework and add connection metrics (…
charlesdong1991 Apr 26, 2026
f6517e8
feat: Basic CI/CD for elixir (#497)
fresh-borzoni Apr 26, 2026
cb5908d
feat: [elixir] fine-grained errors (#507)
fresh-borzoni Apr 29, 2026
1257cc8
feat: (Python) Add async context manager (#487)
qzyu999 Apr 30, 2026
4888f49
chore: regenerate Cargo.lock for declared metrics deps (#518)
fresh-borzoni May 2, 2026
0038287
chore: bump rand from 0.9.2 to 0.9.3 (#512)
dependabot[bot] May 3, 2026
93c28cc
chore: bump actions/upload-artifact from 4 to 7 (#521)
dependabot[bot] May 3, 2026
142f9cc
chore: bump rustls-webpki from 0.103.10 to 0.103.13 (#513)
dependabot[bot] May 3, 2026
273c238
fix: [bindings] map RpcError to NetworkException for Java parity (#519)
fresh-borzoni May 3, 2026
f433709
feat: make LogScanner poll methods async to prevent event loop blocki…
fresh-borzoni May 3, 2026
cb367e8
chore: fix context_manager in python for async handling (#527)
fresh-borzoni May 3, 2026
024aebb
feat: Add nullability support in python (#522)
charlesdong1991 May 3, 2026
01c9a22
[rust] lookup decoding schema id (#517)
fresh-borzoni May 3, 2026
47973d1
chore: fix python CI - reduce workers to 2 with loadfile distribution…
charlesdong1991 May 3, 2026
2356cf4
chore: Add validation for numeric config fields (#449)
Prajwal-banakar May 6, 2026
1ff4eec
[c++] Add nullability support for data type in c++ (#525)
charlesdong1991 May 8, 2026
e274bd1
[rust] Support API_VERSION in rust client. (#531)
loserwang1024 May 9, 2026
d0bea1e
Support FixedSizeBinary in python (#538)
charlesdong1991 May 9, 2026
b0c5486
[rust][writer] Add DynamicWriteBatchSizeEstimator (#532)
fresh-borzoni May 10, 2026
55b3e71
[tests] Add integration tests for array data type (#523)
charlesdong1991 May 10, 2026
9704b0c
[python] Add prefix lookup support in python (#540)
charlesdong1991 May 10, 2026
2a6f0a4
capture cluster container logs as CI artifact (#542)
charlesdong1991 May 10, 2026
4a2fded
feat: add end-to-end ROW (nested struct) column serialization support
hemanthsavasere Mar 15, 2026
2c18097
fixes and improvements
fresh-borzoni May 10, 2026
338b6b8
feat: Add RecordBatchLogReader for bounded log reading (#446)
charlesdong1991 May 14, 2026
e17e087
feat: implement MAP data type support
qzyu999 May 15, 2026
5425b93
fix: close Arrow read-path gaps for MAP
fresh-borzoni May 15, 2026
dbf5f80
chore: fix main broken due to new clippy useless_conversion (#548)
fresh-borzoni May 15, 2026
5f452c8
[metrics] Add scanner fetch and remote download metrics (#553)
charlesdong1991 May 19, 2026
29ea5ce
docs: add documentation for MAP dtype (#556)
qzyu999 May 19, 2026
32ae530
[chore] improve ergonomics for MAP dt, docs additions
fresh-borzoni May 23, 2026
50171d4
[ci] scope rust integration job to test_fluss target only (#561)
fresh-borzoni May 23, 2026
e0ecf8b
[rust] integration tests for MAP dt + restructure ITs for complex dts…
fresh-borzoni May 25, 2026
5ef93a8
[test] Add Rust integration coverage for RecordBatchLogReader bounded…
slfan1989 May 25, 2026
88f5648
[metrics] Add scanner poll-timing metrics (#555)
charlesdong1991 May 26, 2026
5a472b2
feat: [metrics] Add database and table labels for scanner metrics (#565)
charlesdong1991 May 26, 2026
b38859e
[elixir] feat: Extend Fluss.Config with writer tuning options (#566)
nicolazar May 27, 2026
087bc99
[tests] replace fixed tokio::time::sleep workarounds with wait_for_ta…
slfan1989 May 28, 2026
634c603
[client] Implement BatchScanner with limit-based scan
Arnav-panjla May 26, 2026
35a6ec6
[client] Fix KV limit-scan decode + enforce limit, support schema evo…
fresh-borzoni May 27, 2026
52ac57a
[elixir] feat: Extend Fluss.Config with scanner tuning options (#574)
nicolazar May 28, 2026
53da6a8
chore: [ci] Fix rustdoc warning and promote warning to error in CI (#…
charlesdong1991 May 28, 2026
2b0c742
[elixir] feat: Extend Fluss.Config with security, SASL and connect ti…
nicolazar May 28, 2026
2d811cd
[FIP-40] Import fluss-rust tree under fluss-rust/ with preserved history
fresh-borzoni May 29, 2026
c232100
[FIP-40] Adapt imported fluss-rust to the monorepo (proto, CI, docs, …
fresh-borzoni May 29, 2026
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
The table of contents is too big for display.
Diff view
Diff view
  •  
  •  
  •  
41 changes: 41 additions & 0 deletions .github/actions/verify-tag-version/action.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,41 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

# Verify that the pushed tag version matches the workspace package version in Cargo.toml.
# Tag v0.2.0 or v0.2.0-rc1; Cargo 0.2.0. Compare base version (strip -rc*): both pass when Cargo is 0.2.0.
# Requires: checkout before this step (Cargo.toml in workspace root). Use on tag push (GITHUB_REF like refs/tags/v0.1.0).

name: 'Verify tag matches crate version'
description: 'Exits with error if GITHUB_REF tag base version does not match [workspace.package] version in Cargo.toml (strips -rc*).'

runs:
using: 'composite'
steps:
- run: |
echo "Tag and crate version match: $TAG_VERSION"
shell: bash
# uncomment for 0.1.0-incubating-rc0, add it back when incubating is not needed anymore
# - run: |
# TAG_VERSION="${GITHUB_REF#refs/tags/v}"
# CRATE_VERSION=$(sed -n '/^\[workspace.package\]/,/^\[/p' Cargo.toml | grep '^\s*version\s*=' | head -1 | sed -E 's/.*"([^"]+)".*/\1/')
# base() { echo "$1" | sed -E 's/-rc(\.[0-9]+|[0-9]+)$//'; }
# if [ "$(base "$TAG_VERSION")" != "$(base "$CRATE_VERSION")" ]; then
# echo "::error::Tag version ($TAG_VERSION) does not match Cargo.toml version ($CRATE_VERSION). Run scripts/bump-version.sh before tagging, or tag the version that is in Cargo.toml."
# exit 1
# fi
# echo "Tag and crate version match: $TAG_VERSION"
# shell: bash
30 changes: 30 additions & 0 deletions .github/dependabot.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,30 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.

version: 2
updates:
# GitHub Actions used by the repository's workflows
- package-ecosystem: "github-actions"
directory: "/"
schedule:
interval: "monthly"

# Rust client workspace
- package-ecosystem: "cargo"
directory: "/fluss-rust"
schedule:
interval: "monthly"
42 changes: 42 additions & 0 deletions .github/release.yml
Original file line number Diff line number Diff line change
@@ -0,0 +1,42 @@
# Licensed to the Apache Software Foundation (ASF) under one or more
# contributor license agreements. See the NOTICE file distributed with
# this work for additional information regarding copyright ownership.
# The ASF licenses this file to you under the Apache License, Version 2.0
# (the "License"); you may not use this file except in compliance with
# the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
#
# Configures "Generate release notes" on GitHub Releases.
# https://docs.github.com/en/repositories/releasing-projects-on-github/automatically-generated-release-notes

changelog:
categories:
- title: Added
labels:
- feat
- feature
- title: Changed
labels:
- refactor
- title: Fixed
labels:
- fix
- bugfix
- title: Docs
labels:
- docs
- documentation
- title: CI / Build
labels:
- ci
- build
- title: Chore
labels:
- chore
2 changes: 2 additions & 0 deletions .github/workflows/ci.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -25,11 +25,13 @@ on:
paths-ignore:
- 'website/**'
- 'helm/**'
- 'fluss-rust/**'
- '**/*.md'
pull_request:
paths-ignore:
- 'website/**'
- 'helm/**'
- 'fluss-rust/**'
- '**/*.md'

concurrency:
Expand Down
Loading
Loading