Google Git Google Git
Sign in
apache/fluss/HEAD
  1. 5bdb567 [server] Support configurable concurrent rebalance tasks (#4097) by yunhong · 5 hours ago main
  2. 14e36ca [client] Support oss fallback for ossj file system URIs (#5079) by Hongshun Wang · 8 hours ago
  3. 014a7ab [docs] Archive Incubator release download links (#5122) by Jark Wu · 9 hours ago
  4. 04c603e [server] Make RocksDB compaction readahead configurable (#5127) by Yang Wang · 9 hours ago
  5. 3196563 [spark] Skip fluss-spark-ut tests on Java 8 by Vincent · 2 days ago
  6. d431834 [hotfix][test] Fix consumer offset test compilation (#5116) by yunhong · 28 hours ago
  7. 65261d6 [server] Simplify consumer offset commits on tablet workers by Jark Wu · 3 days ago
  8. 7563804 [server] Implement consumer offset commits (#4850) by pisceslj · 3 weeks ago
  9. aa433c1 [server] Make timed-out rebalance tasks recoverable (#3860) by yunhong · 32 hours ago
  10. 9677ca2 [lake] Propagate Hadoop configuration to Hudi writer (#4584) by Gezi-lzq · 34 hours ago
  11. 1839f1e [server] Reduce default writer ID expiration to one day (#4816) by Xiaobing Fang · 2 days ago
  12. f79bf52 [elixir] Support column comments in Fluss.Schema (#5070) by Nicoleta Lazar · 3 days ago
  13. 2c94d54 [log] Revert compression for COMPACTED log format (#4814) (#5095) by Jark Wu · 3 days ago
  14. e556282 [kafka] Add request metrics for Kafka produce and metadata APIs (#4896) by Yang Guo · 3 days ago
  15. a031515 [rust] Skip invalidating leaders that are already dropped (#5086) by Anton Borisov · 3 days ago
  16. d981680 [rust] Reuse Arrow columns for identity schema alignment (#4614) by lz · 4 days ago
  17. a79175e [common] Fix negative timestamp decoding in Iceberg keys (#4296) by Xiaobing Fang · 4 days ago
  18. 5df4012 [rust] Serialize metadata changes without blocking readers (#5083) by Anton Borisov · 4 days ago
  19. d58f27e [flink] Checkpoint only unread lake splits of streaming hybrid splits (#5075) by Giannis Polyzos · 4 days ago
  20. 5744045 [rust] Clear stale bucket leaders when refreshing metadata (#5042) by yangyang · 4 days ago
  21. 883cd9f [lake] Surface repeated tiering commit failures (#5065) by Giannis Polyzos · 4 days ago
  22. 0689a1b [build] Add a local development kit for contributors (#3851) by Gezi-lzq · 4 days ago
  23. 151882d [client] Share bucketing function with the writer by Anton Borisov · 5 days ago
  24. a938a13 [Trino][Client] Support equivalent bucket pruning, add unified BucketCalculator in client by Shangqing Yang · 3 weeks ago
  25. e8bb79e [elixir] Add methods for getting offsets (#4972) by Nicoleta Lazar · 5 days ago
  26. 9222107 [lake] Keep rewrite files when the Iceberg commit outcome is unknown (#5064) by Giannis Polyzos · 5 days ago
  27. 250c18d [lake] Bundle commons-io in the Iceberg 1.12 plugin (#5063) by Giannis Polyzos · 5 days ago
  28. cef7883 [log] Add compression for COMPACTED log format (#4814) by Dionysis Stolis · 5 days ago
  29. 6094292 [server] Move snapshot directory I/O outside the KV tablet lock (#4954) by Xiaobing Fang · 5 days ago
  30. a61d2e4 [client][server] Use explicit routing bucket counts (#4984) by Yang Wang · 5 days ago
  31. 9ab518b [client] Prune Arrow buffers before client-side decompression. (#4883) by Hongshun Wang · 5 days ago
  32. bd52cc1 [flink/lake] Commit tiering tables concurrently (#5031) by Junbo Wang · 5 days ago
  33. 90e0205 [client] Skip unnecessary KV snapshot metadata queries (#5048) by Junbo Wang · 6 days ago
  34. 98298c6 [rust] Close idle cached RPC connections (#5045) by Nicholas Jiang · 6 days ago
  35. bc91e4f [rust] Decode only selected columns in remote Arrow logs (#4922) by lz · 6 days ago
  36. 427988d [flink] Advance bucket baselines after successful undo recovery (#4955) by Yang Wang · 6 days ago
  37. 185d1ff [server] Fix stale metadata served for missing and re-created tables (#4758) by Dionysis Stolis · 6 days ago
  38. f16f037 [security] Make SASL mechanisms extensible (#3865) by litiliu · 6 days ago
  39. 5dcd9d8 [lake] Support creating primary-key tables from Paimon (#4956) by yuxia Luo · 6 days ago
  40. c52d777 [helm] Support advertised listeners for out-of-cluster clients (#4108) by Kaiqi Dong · 6 days ago
  41. a2e0c76 [server] Fix stale coordinator metrics after leadership re-election (#5039) by Hongshun Wang · 6 days ago
  42. 0661d7e [rust] Return decoded scan batches before later errors (#4606) by lz · 7 days ago
  43. 0fe9aa7 [flink] Support Cache ALL for lookup. (#4482) by Hongshun Wang · 7 days ago
  44. 0d35dbe [client] Back off lookups for buckets without a leader (#4991) by Giannis Polyzos · 7 days ago
  45. 1780431 [helm] First-class coordinator HA: standby-aware readiness gate (#4115) by Muhammet Orazov · 7 days ago
  46. ef64ce9 [common] Support InternalRow#createFieldToString (#4990) by Shuai Liu · 7 days ago
  47. 31f7309 [client] Complete pending writes when the writer is closed (#5009) by Nicholas Jiang · 7 days ago
  48. 04794bd [rust] Add exponential backoff to lookup retries (#4994) by Nicholas Jiang · 7 days ago
  49. 2309bfb [flink] Filter undo recovery records before row materialization (#5005) by Yang Wang · 7 days ago
  50. a060315 [rust] Make cached RPC connections endpoint-aware (#4986) by Nicholas Jiang · 7 days ago
  51. cb11cfe [server] Support COUNT in the aggregation merge engine (#4998) by Yang Wang · 7 days ago
  52. 1332c80 [build] Upgrade fluss-rocksdb to 11.8.1-fluss-5 (#5015) by Yang Wang · 7 days ago
  53. 7cc3890 [client] Support prefix lookups with multiple keys (#4981) by Giannis Polyzos · 7 days ago
  54. 9ae427a [client] Expose standby coordinators via DescribeCluster (#4391) by Mahesh Sambaram · 7 days ago
  55. adef89b [build] Add action to process stale pull requests (#5011) by Nicholas Jiang · 7 days ago
  56. 1009288 [kv] Run MultiGet outside the KV lock with snapshot read views (#4768) by Yang Wang · 8 days ago
  57. b6f0727 [client] Fail log fetch again on INVALID_BUCKET_ROUTING (#5003) by Giannis Polyzos · 8 days ago
  58. 75a26e1 [client] Retry log fetch on INVALID_BUCKET_ROUTING instead of failing (#4988) by Nicholas Jiang · 8 days ago
  59. 7028f81 [server] RemoteStorageCleaner support clean for multiple remote directories (#2787) by Liebing · 8 days ago
  60. 06aa8da [test] Wait for Kafka Metadata visibility in alias test (#4978) by CodingOtter · 8 days ago
  61. 82deb67 [client] Add exponential backoff to lookup retries (#4970) by Giannis Polyzos · 8 days ago
  62. 80c22e8 [server] Add collect and merge_map aggregations (#2388) by Yang Wang · 9 days ago
  63. 1090a53 [lake/iceberg] Support custom Iceberg lake table path (#4253) by litiliu · 9 days ago
  64. da4e266 [server] Move leader during reassignment when old leader stays (#4869) by Muhammet Orazov · 9 days ago
  65. 0d3262c [rust] Lookup requests are not drained when batch timeout is zero (#4893) by slfan1989 · 9 days ago
  66. 35d861b [rust] Align timestamp partition names with Java (#4969) by slfan1989 · 9 days ago
  67. c972972 [rust] Create missing partitions on write instead of retrying forever (#4941) by Nicholas Jiang · 9 days ago
  68. 8f87620 [lake/paimon] Allow creating PaimonLakeSource from a loaded table (#4958) by bryndenZh · 10 days ago
  69. 0010029 [docs] Clarify FIRST_VALUE null handling in aggregation (#4946) by Yang Wang · 11 days ago
  70. dc31141 [lake] Fail fast on duplicate lake format plugins (#4916) by Hachiman566 · 11 days ago
  71. 1992f39 [kv] Share RocksDB Statistics per table on each TabletServer (#4948) by Yang Wang · 11 days ago
  72. e3a5c2a Revert "[kv] Fail multiGet on read errors instead of reporting missing keys (…" (#4951) by Giannis Polyzos · 11 days ago
  73. 7392085 [rpc] Isolate internal listener resources from client backpressure (#4857) by Yang Wang · 11 days ago
  74. 22615b2 [client] Recover Admin writes after coordinator failover (#4200) by sakshichitnis27 · 11 days ago
  75. c1043dd [rpc] Avoid retaining failed connections in the connection pool (#4884) by Junbo Wang · 11 days ago
  76. 60e2f34 [rust] Add schema ID test and docs by Anton Borisov · 12 days ago
  77. 157d38c [rust] Expose source schema IDs in Arrow batch scans by liuzhuo · 4 weeks ago
  78. 40d9480 [server] Splice binary arrays in last_n merges (#4923) by Anton Borisov · 12 days ago
  79. 2e55dcf [helm] Support several Fluss clusters in one namespace (#4424) by Lorenzo Affetti · 12 days ago
  80. 0c5d68a [kv] Fail multiGet on read errors instead of reporting missing keys (#4488) by Arvin · 12 days ago
  81. bd4d0bc [metrics] Expire idle histogram samples across reporters (#4829) by Yang Wang · 12 days ago
  82. b742e46 [docs] Align documented configuration keys with code (#4917) by Zhe Wang · 12 days ago
  83. 0f2f17d [test] Replace Mockito in metadata bootstrap tests (#4935) by yunhong · 12 days ago
  84. 9c15c19 [rpc] Handle endpoint changes for cached server connections (#4263) by P_K · 12 days ago
  85. 9ec85dd [helm] Publish not-ready addresses on headless Services (#4925) by Muhammet Orazov · 12 days ago
  86. dc3eb23 [elixir] Refactor Fluss.Admin module to use keyword opts (#4868) by Nicoleta Lazar · 14 days ago
  87. 191869d [rust] Fix projection of remote logs with older schemas (#4881) by lz · 14 days ago
  88. 8a92b4f [filesystems] Implement obtainSecurityToken for Google filesystem (#4790) by falsity · 2 weeks ago
  89. 1c4231e [docs] Simplify GET_METADATA description in authorization.md (#4908) by Jark Wu · 2 weeks ago
  90. e79e5bf [client] Unify cluster inspection in DescribeCluster (#4901) by yunhong · 2 weeks ago
  91. 3a41bbe [server] Retry kv snapshot lease metadata file writes (#4892) by Muhammet Orazov · 2 weeks ago
  92. 52480eb [server] Complete delayed fetches after log appends (#3412) by Yang Guo · 2 weeks ago
  93. c07dcc6 [kafka] Serve Metadata from a consistent table property cache (#4825) by Yang Guo · 2 weeks ago
  94. 1b99b80 [flink] Add source ITCase to cover restoration from savepoint(#4537) by Anurag Vaibhav · 2 weeks ago
  95. 1da0ead [kafka] Miscellaneous Kafka compatibility improvements (#4865) by Yang Guo · 2 weeks ago
  96. b85258c Revert "[Client] Support bounded log scanning (#4545)" (#4876) by Giannis Polyzos · 2 weeks ago
  97. 3062864 [hotfix] Fix daemon shutdown timeout message (#4872) by shuyouZZ · 2 weeks ago
  98. 4e09265 [client] Retry getServerNodes on stale coordinator address (#4873) by Giannis Polyzos · 2 weeks ago
  99. 05b215c [docs] Add newly appointed Fluss committers (#4827) by Junbo Wang · 2 weeks ago
  100. c5ca7d3 [FLUSS-4821][client] Skip lake snapshot recovery for old table IDs (#4822) by yuxia Luo · 2 weeks ago