Sign in
apache
/
fluss
/
HEAD
79bd890
[client] Clear VectorSchemaRoot to release buffer ASAP after a batch read finished (#2728)
by Hongshun Wang
· 7 hours ago
main
17f5400
[helm] Add extraVolumes, extraVolumeMounts, initContainers (#3034)
by Lorenzo Affetti
· 2 days ago
2c031c4
[server] Update leader election process and improve coordinator epoch handling
by Jark Wu
· 3 days ago
04e1a9f
[server] Coordinator supports coordinator epoch protection (#2781)
by whenzhou.zc
· 9 months ago
8df3873
[helm] Fix wrong resource name in coordinator sts (#3044)
by Muhammet Orazov
· 2 days ago
ab618ea
[server] Fix TableChangeWatcher missing CreateTableEvent due to CuratorCache async getData race (#2710)
by yunhong
· 3 days ago
450aeee
[client] Catch and handle the exception for list offsets api. (#3027)
by Hongshun Wang
· 3 days ago
17285ef
[Blog] Fluss Rust SDK introduction blog (#2934)
by Anton Borisov
· 3 days ago
0913317
chore: fix docusaurus webpack issue with new version (#3035)
by Anton Borisov
· 3 days ago
e9bfd72
[helm] Fix Zookeeper client config path (#3015)
by Muhammet Orazov
· 3 days ago
f8885f1
[lake/paimon] Resolve partition eagerly in record writer (#3023)
by yuxia Luo
· 3 days ago
3d8df9f
[server] Add server-side filter execution and client-side integration (#2951)
by Yang Wang
· 3 days ago
520ce89
[client] Skipping stale schema change event. (#3028)
by Hongshun Wang
· 3 days ago
a81966a
[docs] Fix pull request template comment formatting (#3024)
by yuxia Luo
· 3 days ago
400577a
[spark] Add union read for lake-enabled log tables (#2956)
by Anton Borisov
· 3 days ago
8136127
[filesystem] Support AssumeRole STS for RustFS (#2989)
by Anton Borisov
· 4 days ago
0431be8
[docs] Add Insert If Not Exists section to Lookup Joins documentation (#2991)
by Yang Wang
· 4 days ago
852737e
[server] Allow user to alter partition num retention. (#2964)
by Hongshun Wang
· 4 days ago
8d757da
[server] Fix OOB in partial update/delete after ADD COLUMN (#3000)
by Anton Borisov
· 4 days ago
183685c
[blog] Fix rust client release blog: save avatars locally and add truncate (#3014)
by yuxia Luo
· 4 days ago
dbd7f5c
[spark][bugfix] Use pk index for comparator align with SortMergeReade (#2987)
by Yang Zhang
· 5 days ago
10e9368
[blog] Fluss rust / python / c++ client release blog draft (#2730)
by Keith Lee
· 5 days ago
b45de98
[build] Update version to 1.0-SNAPSHOT (#2999)
by Jark Wu
· 5 days ago
81a1ec8
[git] Add ".qoder" directory to the .gitignore
by Jark Wu
· 7 days ago
82b14f2
Revert "[BugFix] Fix ArrayIndexOutOfBoundsException in partial updates after ADD COLUMN (#2594)"
by Jark Wu
· 7 days ago
5ede2fc
[BugFix] Fix ArrayIndexOutOfBoundsException in partial updates after ADD COLUMN (#2594)
by Anton Borisov
· 9 days ago
cec9650
[rpc] Client zero-copy lazy parse ByteBuf to avoid deep memory copy (#2948)
by Anton Borisov
· 9 days ago
455d6f3
[lake/paimon] use paimon PK row type as comparator (#2980)
by yuxia Luo
· 10 days ago
57cb378
[server] Fix PeriodicSnapshotManager.start() silently disables snapshot (#2978)
by Yang Wang
· 10 days ago
079b78a
[lake] Allow enabling lakehouse for log tables without bucket key created before cluster-level lakehouse is enabled (#2973)
by yuxia Luo
· 10 days ago
89860e0
[agents] Add AGENTS.md - AI agent coding guide (#2922)
by vaibhavk1992
· 10 days ago
c49b848
[server] Improve the implementation of Coordinator HA
by Jark Wu
· 11 days ago
bbc445a
[server] Support Coordinator High Availability
by whenzhou.zc
· 6 weeks ago
f45f41b
[lake/tiering] add total bytes read tracking and metrics for tiering service (#2933)
by Junbo Wang
· 11 days ago
2df0914
[client][backport] Skip blocked bucket instead of stopping drain loop in idempotent writer (#2953)
by Anton Borisov
· 11 days ago
596efc8
[fs/azure] Set auth.type=Custom for token delegation (#2947)
by Lorenzo Affetti
· 11 days ago
9a299db
[docs] Add C++ client documentation (#2923)
by Prajwal banakar
· 13 days ago
47b3818
[flink] Skip LogSplit for empty buckets in lake union read (#2958)
by Anton Borisov
· 13 days ago
bdbbbce
[helm] Enable SASL authenticated connection to Zookeeper nodes (#2700)
by Muhammet Orazov
· 13 days ago
0e265ad
[fluss-common] Validate partition time when creating partition on auto partition table. (#2940)
by Hongshun Wang
· 2 weeks ago
d4748f2
[helm] Fix .helmignore to not package tests (#2847)
by Lorenzo Affetti
· 2 weeks ago
2b207a4
[helm] Enable metrics reporting in helm charts (#2711)
by Muhammet Orazov
· 2 weeks ago
97cc67d
[flink] Remove redundant `bucket.num` and `bucket.key` from custom properties. (#2931)
by Hongshun Wang
· 2 weeks ago
b03cec4
[common] Add V1 log batch format with statistics collection (#2886)
by Yang Wang
· 2 weeks ago
219054e
[hotfix] Fix Netty ByteBuf leak on follower fetchLog timeout (#2926)
by Yang Wang
· 2 weeks ago
fafafa0
[hotfix] Update TableInfo constructor call in LanceTieringTest (#2927)
by Junbo Wang
· 3 weeks ago
e2d0657
[hotfix][lance] Fix compile problem in LanceTieringTest (#2928)
by Jark Wu
· 3 weeks ago
94c131f
[server] Skip datalake prefix validation when datalake format is not null (#2919)
by Hongshun Wang
· 3 weeks ago
05b6f66
[server] Extend metadata models to support per-table/partition remote data directory (#2763)
by Liebing
· 3 weeks ago
649bb41
[lake/lance] Add NestedRow type support for Lance (#2578)
by ForwardXu
· 3 weeks ago
3b95065
[server] return all invalid option in err msg of InvalidAlterTableException. (#2897)
by Hongshun Wang
· 3 weeks ago
c59c0f1
[docs] add links to Python client documentation (#2461)
by Prajwal banakar
· 3 weeks ago
ee03ba7
[docs] Add links to Rust client documentation (#2462)
by Prajwal banakar
· 3 weeks ago
398db17
[doc] Align the doc table (#2901)
by xiaozhou
· 3 weeks ago
0fa75eb
[flink] Allow partial updates for AGGREGATION merge engine (#2888)
by Yang Wang
· 3 weeks ago
14f0f12
[server] Support alter database comment and custom properties (#1172)
by Liebing
· 3 weeks ago
86b1f4c
[test][kv] Ensure ordered inserts for auto-increment ID tests (#2779)
by Junbo Wang
· 3 weeks ago
22ece48
[helm][hotfix] Go template whitespace trimming caused exceptions (#2893)
by Muhammet Orazov
· 3 weeks ago
0825d68
[server] Fix ListDatabaseSummary always return table count as 0 or 1(#2852)
by Hongshun Wang
· 4 weeks ago
aa5d166
[helm] Rewrite README to point to website docs (#2846)
by Lorenzo Affetti
· 4 weeks ago
7b9438f
[server] Still do remove server tag if tablet server not exist (#2883)
by xiaozhou
· 4 weeks ago
0f4d865
[client] Fix infinite retry loop in idempotent writer on lost response with OutOfOrderSequenceException (#2827)
by Liebing
· 4 weeks ago
bfcc249
add trending tag (#2878)
by MehulBatra
· 4 weeks ago
f7e4498
[helm] Enable SASL authentication configurations (#2506)
by Muhammet Orazov
· 4 weeks ago
ac21483
[common] Support Protobuf and RPC for Predicates (#2502)
by Giannis Polyzos
· 4 weeks ago
d72ba3a
[hotfix] Fix serialize modifiedTime field in TableRegistrationJsonSerde (#2810)
by Yang Guo
· 4 weeks ago
bcf8b64
[server] Register ConfigException in Errors to fix misleading UnknownServerException from alterClusterConfigs (#2857)
by Liebing
· 4 weeks ago
96aee59
[lake/paimon] Fix partition expiration never triggered in Paimon lake table managed by Tiering Service (#2862)
by Liebing
· 4 weeks ago
f7fa971
[lake/tiering] Add per-table monitoring metrics for Lake Tiering (#2454)
by Junbo Wang
· 4 weeks ago
8cd9a6f
[Helm] Revert Chart Component Configuration Isolation (#2472) (#2863)
by Lorenzo Affetti
· 4 weeks ago
acd9632
[lake/tiering] fallback to Flink's `io.tmp.dir` when `client.scanner.io.tmpdir` is not set. (#2859)
by Junfan Zhang
· 4 weeks ago
d956e75
[Helm] Chart Component Configuration Isolation (#2472)
by Hemanth Savasere
· 4 weeks ago
cb873e6
[typo] Fix typo in log loading period (#2798)
by xiaozhou
· 4 weeks ago
7bd5a0f
[docs] Update doc in api/java-client about complex type (#2845)
by nhuantho
· 4 weeks ago
17f99e5
[ci] Fix AbfsFileSystemBehaviorITCase fails with "Bind Address already in use" in CI (#2630)
by litiliu
· 4 weeks ago
a89311f
[lake/iceberg] only enable column stats when scan filter exists (#2842)
by Junfan Zhang
· 4 weeks ago
6bde9c3
[log] Support dynamic configuration for log.replica.min-in-sync-replicas-number (#2837)
by xiaozhou
· 4 weeks ago
2f8cada
[fluss-client] Support Complex Data Types on the Java Typed API (Map and Array) (#2814)
by nhuantho
· 4 weeks ago
dd181eb
[helm] Add CI workflow to run Helm tests (#2777)
by Muhammet Orazov
· 5 weeks ago
e6e95ca
[kv] Support dynamic configuration for 'kv.snapshot.interval' (#2820)
by yunhong
· 5 weeks ago
199af0b
[client] Support Scan#createBatchScanner() API to read data from the whole table (#2794)
by Hongshun Wang
· 5 weeks ago
2c49fbc
[helm] Fix wrong resource name in coordinator sts (#2834)
by Muhammet Orazov
· 5 weeks ago
bafba42
[server] Add configuration options for multiple remote data directories (#2757)
by Liebing
· 5 weeks ago
e9dbcf1
[hotfix] log info include table bucket for remote log downloader when downloading (#2817)
by yunhong
· 5 weeks ago
79fd2eb
[lake/tiering] Add CoordinatorServer Monitoring Metrics for Lake Tiering Scheduling (#2815)
by Junbo Wang
· 5 weeks ago
2a393f6
[docs] Fix misaligned tables in the document (#2813)
by Tom
· 5 weeks ago
c93a1f3
[lake/paimon] Support Altering Lake Table Properties (#2799)
by Liebing
· 5 weeks ago
21bcabd
[github] Add Unstable Test Reporter for CI to track flaky tests
by Jark Wu
· 5 weeks ago
62a49a2
[metric] add bucket and partition count metric for table (#2800)
by xiaozhou
· 5 weeks ago
d6aacdd
[server] Fix LogTieringTask to commit successfully copied segments on partial failure (#2767)
by yunhong
· 5 weeks ago
b9c9042
[blog] Fluss for ai (#2788)
by Giannis Polyzos
· 5 weeks ago
d59fdfc
[doc] fix kv.snapshot.num-retained default value (#2797)
by xiaozhou
· 5 weeks ago
3b1dbba
[github] Upgrade Fluss version 0.9.0 in BUG issue template (#2789)
by Liebing
· 6 weeks ago
87db594
[paimon] Improve npe error in FlussRecordAsPaimonRow (#2765)
by Thorne
· 6 weeks ago
15f8382
fix binlog example to match changelog (#2775)
by MehulBatra
· 6 weeks ago
2d69732
release fixes for changefeed to include binlog (#2774)
by MehulBatra
· 6 weeks ago
f39e188
[docs] Add download link for release 0.9.0 (#2682)
by yuxia Luo
· 6 weeks ago
e1ed655
[blog] 0.9 Release announcement (#2590)
by Giannis Polyzos
· 6 weeks ago
0adf1b2
[doc] Mark 0.9.0 as released in document
by luoyuxia
· 6 weeks ago
fbdb7fa
[hotfix] Fix unstable test KvReplicaRestoreITCase.testRowCountRecoveryAfterFailover
by Jark Wu
· 6 weeks ago
Next »