Google GitGoogle Git
Sign in
apache/fluss/HEAD
  1. 233092a [kv] Bound prefix lookups with an exclusive upper limit (#4744) by Yang Wang · 5 hours ago main
  2. 26717b0 [server] Register external KV snapshots and restore replicas (#4242) by Yang Wang · 6 hours ago
  3. d8a3d5b [test] Stabilize cluster health test setup (#4734) by Yang Guo · 23 hours ago
  4. 1831d26 [client] Back off writes rejected by disk protection (#4293) by fhan · 26 hours ago
  5. cbb3ea6 [hotfix][rpc] Revert Netty shutdown optimization #4645 (#4746) by yunhong · 28 hours ago
  6. 6be68dd [kv] Support partitioned metadata with HyperClockCache (#4612) by Yang Wang · 30 hours ago
  7. 7f50969 [trino] Add predicate constraint handling and equality partition pruning (#4689) by yangshangqing · 2 days ago
  8. 6f4ed05 [server] Fix stale remote log metrics on repeated leader updates (#4618) by Xiaobing Fang · 2 days ago
  9. dbd6dd7 [kafka] Define DDL table mapping for Kafka compatibility (#4277) by Yang Guo · 2 days ago
  10. 1f352b9 fix smaller race by Anton Borisov · 2 days ago
  11. c3b462a [rpc] Fix race in Netty client disconnection test by Shangqing Yang · 4 days ago
  12. 70efa0b [FIP-29][security] Add SslPrincipalMapper for certificate DN to principal mapping (#4641) by Muhammet Orazov · 2 days ago
  13. 496fd5a [ci] Fix race in rebalance cluster model test (#4696) by yangshangqing · 2 days ago
  14. d3e50c0 [python] Add prefix lookup example and documentation (#4632) by Jandy · 2 days ago
  15. 0529ab0 [rust] Support ossj scheme alias for OSS remote logs (#4577) by naivedogger · 3 days ago
  16. 33d1020 [cpp] Allow starting lookups without blocking (#4559) by Anton Borisov · 3 days ago
  17. bbf2f28 [build] Extract Spark CI into a separate workflow (#4654) by Yang Zhang · 3 days ago
  18. 6b52163 [elixir] Don't block a scheduler in AppendWriter.append (#4691) by Nicoleta Lazar · 3 days ago
  19. 6b43eab [Server] improve CI test time for netty (#4645) by Giannis Polyzos · 4 days ago
  20. 10355ba [rust] Keep one unavailable server from stalling every lookup (#4563) by Anton Borisov · 4 days ago
  21. c751131 [rust] remove the duplicate proto definition (#4636) by Junfan Zhang · 4 days ago
  22. 31852d4 [server] Eliminate global lock for LOG tablet creation/deletion/load (#4621) by Junfan Zhang · 4 days ago
  23. 55a6138 [client] Fix corruption after zero-copy lazy parse ByteBuf (#3008) by Anton Borisov · 4 days ago
  24. 6225c4d [server] Enable active segment retention rolling by default (#4668) by Yang Guo · 4 days ago
  25. caa0679 [rpc] Add contiguous ID tests for Errors and ApiKeys (#4688) by Jark Wu · 4 days ago
  26. 8aada62 [docs] Fix DeepWiki badge image in README (#4690) by Jark Wu · 4 days ago
  27. dcb831c [rpc] Add consumer offset protocol and error definitions (#4664) by pisceslj · 4 days ago
  28. 4e846bd [kafka] Serve ApiVersions from registered capabilities (#4260) by Yang Guo · 4 days ago
  29. 0ca57ce [server] Add consumer offset table foundations (#4626) by pisceslj · 4 days ago
  30. 09eeaaf [lake] Add Iceberg 1.12 plugin (#4671) by Dionysis Stolis · 5 days ago
  31. 33d3263 [elixir] Add UpsertWriter for primary key tables (#4628) by Nicoleta Lazar · 5 days ago
  32. 651a343 [flink] Respect DISTRIBUTED BY when creating tables (#4635) by Ramin Gharib · 5 days ago
  33. ac710a7 [lake] Add versioned v2 format for Iceberg split and tiering state (#4660) by Dionysis Stolis · 5 days ago
  34. 132cf6e [flink] Skip empty lake snapshot splits (#4649) by jonah-rpo · 5 days ago
  35. b450e4c [lake][paimon] Resolve DV offsets from committed COMPACT (#4583) by yuxia Luo · 5 days ago
  36. 25306d8 [build] Split Iceberg plugin into common, 1.10 and 1.12 modules (#4646) by Giannis Polyzos · 6 days ago
  37. 431bc17 [flink] Support SHOW MATERIALIZED TABLES on Flink 2.2+ (#4634) by Ramin Gharib · 6 days ago
  38. 7fbda7a [server] Resume pending replica deletion after server restart (#4505) by yunhong · 6 days ago
  39. 79ca19a [trino] Add initial connector build and plugin skeleton (#4207) by yangshangqing · 6 days ago
  40. d33fe99 [rust] Share the test cluster remote directory across servers (#4652) by naivedogger · 6 days ago
  41. 96eed14 [security] Fix concurrent ACL cache access in DefaultAuthorizer (#4501) by fhan · 6 days ago
  42. 2d6d114 [test] Avoid network retries in AzureFileSystemPluginTest (#4640) by Dionysis Stolis · 7 days ago
  43. dfe8f5d [lake] Name the Flink lake reader's Iceberg catalog like the server's (#4564) by Firas Bouzazi · 7 days ago
  44. c3cebc8 [build] Fix Java 8 nightly failures for flink2 and spark3-lake by Giannis Polyzos · 8 days ago
  45. c108f34 [build] Move Spark Scala 2.13 tests to nightly by litiliu · 2 months ago
  46. 4c553b7 [docs] Clarify RustFS key login in Flink quickstart (#4631) by Jandy · 7 days ago
  47. 6af19e6 [elixir] Set up HexDocs and add usage guides (#4633) by Nicoleta Lazar · 7 days ago
  48. 31848eb [docs] Fix Lance Log Table example (#4581) by Gezi-lzq · 7 days ago
  49. 6e3559e [kafka] Add request dispatch and transport framework (#4259) by Yang Guo · 7 days ago
  50. 368d91a [flink] Exclude bundled SLF4J API from Flink connector JARs (#4624) by Hongshun Wang · 7 days ago
  51. 60c1b56 [lake] Support partition mark-done for lakehouse tiering (processing-time) (#3635) by Junbo Wang · 7 days ago
  52. cc3aa44 [flink] Make source plan assertions independent of Flink version (#4630) by Gustavo de Morais · 7 days ago
  53. ce93334 [flink] Add regression test and docs for nested NOT NULL constraints (#4198) by Keith Lee · 7 days ago
  54. 70384ea [server] Update Tablet Server to use per-table/partition remote data directory (#2782) by Liebing · 8 days ago
  55. 0912b1a [server] Upgrade paimon 2.1 to activate concurrent SST lookup for historical partition (#4620) by Junfan Zhang · 8 days ago
  56. 5f1466f [kv] Use HyperClockCache for the shared RocksDB block cache (#4611) by Yang Wang · 9 days ago
  57. d251066 [spark] Reuse Fluss connections across Spark tasks (#4520) by Yang Zhang · 9 days ago
  58. a85c6a1 [server] Add last_n aggregate function to aggregation merge engine (#4570) by Anton Borisov · 9 days ago
  59. 9bba686 [website] Update hongshun role as PMC member. (#4609) by Hongshun Wang · 9 days ago
  60. 64f89d3 [website] Add Yang Wang to Fluss team page (#4604) by Yang Wang · 9 days ago
  61. 51303ad [rust] Expose Arrow batch commit timestamps in client bindings (#4575) by lz · 9 days ago
  62. 0a46dc5 [flink] Persist lake split state for restore (#4589) (#4594) by Giannis Polyzos · 9 days ago
  63. ca005cb [server] Balance replicas and leaders within each table (#3917) by Xiaobing Fang · 9 days ago
  64. dad779f [test] Wait for KV flush before tagged lookup assertions (#4485) by leon.jeon · 9 days ago
  65. 4b87b14 [lake/iceberg] Fix temporal literals in Iceberg filter push-down (#4596) by Daeuk Choi · 10 days ago
  66. 9ddf633 [kv] Keep KV snapshots readable by FRocksDB 6.20.3 for uniform keys (#4598) by Muhammet Orazov · 10 days ago
  67. de88057 [docs] Add StarRocks user story (#4587) by Jark Wu · 10 days ago
  68. 586ae8e Revert "[flink] Persist lake split state for restore (#4589)" by Giannis Polyzos · 10 days ago
  69. f41185c [flink] Persist lake split state for restore (#4589) by Giannis Polyzos · 10 days ago
  70. e85399d [kv] Bump RocksDB version to 11.8.1 (#4133) by Yang Wang · 11 days ago
  71. f085a00 [flink] Support BUCKET_BALANCE shuffle strategy for table with bucket kyes. (#4450) by Hongshun Wang · 11 days ago
  72. cafca32 [hotfix][build] Exempt ConfigOptions from the file length check (#4579) by yunhong · 12 days ago
  73. 98343e4 [hotfix][test] Wait for bucket leaders in bounded source test (#4568) by yunhong · 12 days ago
  74. bed6c3d chore: update pins to make CI clients integration to work again (#4560) by Anton Borisov · 12 days ago
  75. 49b9c05 [server] Use default NettyAllocationManager for read contexts in server side. (#4468) by Hongshun Wang · 13 days ago
  76. 673c7cc [python][gateway] Fix clippy 1.99 lints (#4565) by Anton Borisov · 14 days ago
  77. f9ab87f update company (#4561) by Giannis Polyzos · 14 days ago
  78. 28d4afe [docs] Clarify Fluss overview, architecture, and table layout (#4555) by Jark Wu · 2 weeks ago
  79. faf37fb [rpc] Accept a keystore used as the truststore by Anton Borisov · 2 weeks ago
  80. 2f1d36c [FIP-29] Add SSL config parsing and SslContext/SslHandler factory by MicheleGuerriero · 2 weeks ago
  81. b8342e9 [docs] Align sidebar carets and active indicators (#4554) by Jark Wu · 2 weeks ago
  82. 64b3b46 Update website concepts page (#4546) by Giannis Polyzos · 2 weeks ago
  83. fd7fd47 [cpp] Allow sharing one Lookuper across threads (#4541) by Anton Borisov · 2 weeks ago
  84. 3053673 [python] Accept lookup config keys (#4543) by Anton Borisov · 2 weeks ago
  85. 648d86f [rust] Allow concurrent lookups on one Lookuper (#4500) by Anton Borisov · 2 weeks ago
  86. bb8dfca [rust] Route partitions by their own bucket count (#4527) by Anton Borisov · 3 weeks ago
  87. f989afb [rust] Pace metadata refreshes for buckets without a leader (#4536) by Anton Borisov · 3 weeks ago
  88. a234bd6 [test] Stabilize Netty client disconnection test (#4344) by litiliu · 3 weeks ago
  89. b4fe91b [rust] Send table stats requests to bucket leaders (#4529) by Anton Borisov · 3 weeks ago
  90. f8b3e1c [rust] Fix bounded read hang on pruned tail (#4498) by Anton Borisov · 3 weeks ago
  91. 9d0d7a6 [rust] Fix bucket hash sign extension (#4496) by Anton Borisov · 3 weeks ago
  92. 23f2ec5 Add explanations for streamhouse and lakestream (#4494) by Giannis Polyzos · 3 weeks ago
  93. 9e7bb2c [github] Upgrade Fluss version 1.0.0 in BUG issue template (#4523) by Muhammet Orazov · 3 weeks ago
  94. 79d576f [common] Make boolean config parsing locale-independent (#4515) by fhan · 3 weeks ago
  95. 8ffd7dd [server] Prevent remote directory round-robin overflow (#4521) by fhan · 3 weeks ago
  96. e88b111 [docs] Improve historical partition restart warning (#4441) by yuxia Luo · 3 weeks ago
  97. 5fe06ed [server] Keep replica fetcher count within configured limit (#4508) by fhan · 3 weeks ago
  98. fdec34f [server] Prevent schema cache pollution during schema updates (#4506) by fhan · 3 weeks ago
  99. e63767d [client] Replace Unsafe with Netty direct memory in ChunkedAllocationManager and expose metrics. (#4448) by Hongshun Wang · 3 weeks ago
  100. a6468e4 [server] Add support of sharable file cache capacity for historical partition lookup (#4113) by Junfan Zhang · 3 weeks ago