Google Git
Sign in
apache/fluss/HEAD
  1. c77ca8b [website] Add consent-gated kapa.ai "Ask AI" widget to docs site (#3760) by MehulBatra · 11 hours ago main
  2. 3a7c144 [website] Sort Fluss team members by role and name by Jark Wu · 2 days ago
  3. efc7a6e [docs] Fix Docker RC version format in release guide by Jark Wu · 2 days ago
  4. 158b810 [website] Adapt website and README for Apache Fluss top-level project (#3764) by Michael Koepf · 2 days ago
  5. 6bb470c [test] Wait for server tag cleanup (#3705) by litiliu · 3 days ago
  6. c190060 [server] release remote log index cache entries on deletion (#3737) by Junfan Zhang · 3 days ago
  7. ea37c95 [client][rust] Retry bootstrap initialization on retriable errors (#3758) by slfan1989 · 3 days ago
  8. b80b643 [server] fix zk notification purge race (#3752) by Yang Guo · 3 days ago
  9. 555f407 [server] Fix tmp file cleanup in remote log index cache init (#3755) by Anton Borisov · 3 days ago
  10. d688bbd [docs] hive and glue fixes and adjustments by Anton Borisov · 3 days ago
  11. 8e2f317 [docs] Add AWS Glue and Hive Metastore catalog guides with Mermaid diagrams by Jared Yu · 8 days ago
  12. 9f33db4 [rust][client] Support comma-separated bootstrap servers (#3711) by slfan1989 · 4 days ago
  13. ed859e9 [server] include time index in remote log cache weight (#3733) by Junfan Zhang · 4 days ago
  14. 6e07668 [server] prevent remote log cache size overflow (#3734) by Junfan Zhang · 4 days ago
  15. cf3b7b8 [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1) (#3227) by Kaixuan Duan · 4 days ago
  16. 5cacbb0 [client] Add log read preference for remote-first fetch (#3606) by Junfan Zhang · 4 days ago
  17. 1ca13b4 [lake/hudi][docs] Add Hudi tiering service documentation (#3549) by fhan · 5 days ago
  18. 92b8edc [lake/tiering] Fix lake writer resource leak in TieringSplitReader close chain (#3720) by Junbo Wang · 5 days ago
  19. f2fa4f8 [tiering] Use exponential delay restart strategy for Flink tiering job (#3683) by Shawn Huang · 5 days ago
  20. 6267ec8 [rust] Fix lost wakeup in LogFetchBuffer::await_not_empty (#3712) by Anton Borisov · 5 days ago
  21. 3f7bd25 [rust] Hash-distribute log-table appends by declared bucket key (#3643) by Anton Borisov · 5 days ago
  22. 59217b2 add links (#3736) by Giannis Polyzos · 5 days ago
  23. 05cec32 [hotfix][docs] Recommend 8MB for KV leader replica memory protection (#3730) by yunhong · 5 days ago
  24. db35df5 [FIP-37] Add bitmap scalar functions and register via FlussCatalog (#3492) by Prajwal Banakar · 5 days ago
  25. 6f80600 [tiering] Reduce LakeSnapshot log verbosity in TieringSplitGenerator (#3700) by Junbo Wang · 6 days ago
  26. 3a4c316 [docs] Fix misaligned rowspans in Table/Bucket metrics table (#3624) by NekoPunch · 6 days ago
  27. 3e64ce7 Added documentation for Resource protection (#3701) by Mahesh Sambaram · 6 days ago
  28. 5c74107 [doc] Modify Operations and Resources on Protocols. (#3707) by Hongshun Wang · 6 days ago
  29. 51e1b7e [website]add theme-aware images and fix broken links (#3497) by Prajwal Banakar · 6 days ago
  30. 04b4e88 [server] Support local log segment TTL (#3623) by Yang Guo · 6 days ago
  31. e21a035 [common][helm] helm support for config providers (#3685) by Anton Borisov · 6 days ago
  32. b50b597 [docs] Document statefulset and service annotations in helm chart (#3708) by Anton Borisov · 6 days ago
  33. 4c89491 [build] Split Flink CI stages by major version to reduce ci time (#3714) by yuxia Luo · 6 days ago
  34. 3162111 [rust] Add into_stream() to bounded readers (#3664) by Anton Borisov · 7 days ago
  35. e6587f1 [rust][tests] Fix flaky test_poll_batches by using retry loop for projection test (#3694) by Liebing · 7 days ago
  36. d7057f5 [helm] Support statefulset and service annotations (#3687) by Anton Borisov · 8 days ago
  37. 67e7341 [rust] Fix clippy::for_kv_map warnings in RecordAccumulator (#3696) by Liebing · 8 days ago
  38. 7d410bc [kv] Close KV tablets concurrently during shutdown (#3651) by yunhong · 8 days ago
  39. 9880307 [server] Batch LeaderAndIsr updates for controlled shutdown (#3654) by yunhong · 8 days ago
  40. 3b1f2c1 [lake]Tolerate Iceberg lake table existent if the schema and properties matches (#3601) by GuoYu · 8 days ago
  41. 42c301e [security] Require ALL permission to modify ACLs (#3680) by Hongshun Wang · 9 days ago
  42. 29afa74 Preserve exception cause in RpcServiceBase error handling (#3329) by ForwardXu · 9 days ago
  43. 668721d [server] Add authorization to listOffsets for TABLE/DESCRIBE operations (#3298) by Vaibhav · 9 days ago
  44. cc93a86 [docs] Add docs for env.* JVM and process options (#3618) by NekoPunch · 9 days ago
  45. 1ac927f [hotfix][test] Fix DynamicConfigManager constructor invocation (#3684) by Anton Borisov · 10 days ago
  46. 6f3c563 [common] Add config providers to resolve secrets in configuration (#3658) by Anton Borisov · 10 days ago
  47. c41a96a [server] Wait for coordinator leader cleanup during shutdown (#3649) by Hongshun Wang · 10 days ago
  48. c1c36f5 [helm] Refactor validation warning and error checks (#2902) by Muhammet Orazov · 10 days ago
  49. 6ce5d9d [lake/tiering] Add tieredTimestamp metric exposing the last successful lake tiering time (#3678) by Junbo Wang · 10 days ago
  50. 412c92b [hotfix][test] Fix AutoPartitionManagerTest constructor invocation (#3674) by yunhong · 10 days ago
  51. 2c8b975 [server] Add resource-based KV leader replica capacity control (#3614) by yunhong · 11 days ago
  52. e1a70de [server] Auto partition time format supporting yyyy-MM-dd (#3558) by Yang Guo · 11 days ago
  53. 10342f5 [server] skip adding fetchers for followers without a leader (#3671) by Junfan Zhang · 11 days ago
  54. 5be0cc8 [spark] Consolidate scan builders into Append/Upsert with SplitPlanner (#3559) by Yann Byron · 11 days ago
  55. 486e5d5 [client] Retry KV snapshot lease operations after metadata refresh. (#3661) by Hongshun Wang · 11 days ago
  56. f6aff1a [server] Coordinator standby tracks dynamic config changes to avoid stale config after becoming leader .(#3645) by fhan · 11 days ago
  57. 3da87ca [server] Offload NotifyLeaderAndIsr to dedicated single-thread executor (#3647) by Junfan Zhang · 11 days ago
  58. 8a51f21 [tiering][iceberg] Validate partition spec before lake tiering (#3639) by litiliu · 11 days ago
  59. 4fadc8e [test] Fix unstable test: KvReplicaRestoreITCase#testRowCountRecoveryAfterFailover (#3667) by yunhong · 12 days ago
  60. 775e921 rust] Support schema evolution for log scanner. (#654) (#3662) by Hongshun Wang · 12 days ago
  61. 8b078d8 [elixir] Support complex types (Array/Map/Row) and nullability (#3636) by Nicoleta Lazar · 12 days ago
  62. 641e5a3 [rust] Add SnapshotId type alias and use it in snapshot metadata paths (#3642) by Femi · 14 days ago
  63. 89b7c0c [lake/paimon] Support custom Paimon path (#3523) by Liurnly · 2 weeks ago
  64. e5e6bb4 [server] Add configurable disk write-limit recover ratio (#3612) by yunhong · 2 weeks ago
  65. 52c1678 [client] Fix data hole in primary key table batch read (#3627) by Junbo Wang · 2 weeks ago
  66. 3acc1c1 [server] Manage multiple users for sasl/plain authentication via cluster properties (#3047) by Hongshun Wang · 2 weeks ago
  67. 02cc35f [hotfix][dist] Disable Log4j shutdown hook in foreground mode (#3634) by yunhong · 2 weeks ago
  68. 671d2bb [lake/tiering] Add pendingRecordLag metric for lake tiering (#3469) by Junbo Wang · 3 weeks ago
  69. dd653f0 [rust][tests] Add DynamicWriteBatchSizeEstimator integration tests (#3588) by Prajwal Banakar · 3 weeks ago
  70. c4d6c49 [cpp] Encode CreateTable column types losslessly (#3603) by Anton Borisov · 3 weeks ago
  71. e1b0907 [server] Require new leader ack for leader-only rebalance (#3556) by yunhong · 3 weeks ago
  72. 8b7cd09 [server] Add negative cache for non-existent partition IDs in metadata requests (#3511) by yunhong · 3 weeks ago
  73. 4da3ebf [tiering] fix flink tiering duplicate write result (#3608) by Junfan Zhang · 3 weeks ago
  74. e929eda [server] Periodically checkpoint log recovery points (#3547) by yunhong · 3 weeks ago
  75. d1591a3 chore: bump arrow stack to 59 (#3600) by Mitchell · 3 weeks ago
  76. 6320400 [server] Reject KV leader promotion under disk write lock (#3539) by yunhong · 3 weeks ago
  77. c5a0c00 [docs] Document S3 custom AWS credentials provider mode by Anton Borisov · 3 weeks ago
  78. bfaaffb [fs] Support AWS S3 credentials provider mode by litiliu · 3 weeks ago
  79. 9f0284d [docs] Add rust/python/c++/elixir component tags (#3602) by Anton Borisov · 3 weeks ago
  80. 20b008c [server] Limit max bucket num per table partition (#3597) by yunhong · 3 weeks ago
  81. ceb2f65 [ci] Fix stale elixir NIF cache; run client suites on workflow change (#3598) by Anton Borisov · 3 weeks ago
  82. 27bdac4 [test] Raise disk write-limit ratio in FlussClusterExtension to avoid test flakiness (#3594) by Xuyang · 3 weeks ago
  83. cf18027 [server] Apply ZooKeeper max buffer size without config path by yunhong · 4 weeks ago
  84. dbdef8e [common] Limit default max bucket count to 20000 by yunhong · 4 weeks ago
  85. dfa33de [docs] Reorganize Streaming Lakehouse documentation to higlight deployment and core features (#2699) by MehulBatra · 3 weeks ago
  86. 6ecf55c [rust/elixir] Align rustler version to 0.38.0 in mix.exs and mix.lock (#3587) by Junbo Wang · 3 weeks ago
  87. 400e132 [FIP-40] Adapt imported fluss-rust to the monorepo (proto, CI, docs, release) by Anton Borisov · 8 weeks ago
  88. 89eafb9 [FIP-40] Import fluss-rust under fluss-rust/ with preserved history by Anton Borisov · 3 weeks ago
  89. 8cd8d16 [lake] Fix union read duplicating rows for non-String partition columns (#3500) by bryndenZh · 3 weeks ago
  90. c1e528a [dist] Fix incorrect package name of ZK in logger conf (#2768) by Junfan Zhang · 3 weeks ago
  91. 38fae34 [client] Avoid per-record AutoPartitionStrategy construction in WriterClient.doSend in log tables (#3529) by Evan · 3 weeks ago
  92. c70a4a6 [elixir] feat: Support full table descriptor options in create_table (#647) by Nicoleta Lazar · 3 weeks ago
  93. 6238daa [metrics][docs] Support Basic Auth for Prometheus PushGateway reporter (#3552) by GuoYu · 3 weeks ago
  94. e2a4403 [server] Support adding aggregation columns (#3459) by Liurnly · 3 weeks ago
  95. 32bd2c1 [docs] Add PrometheusPushGateway and InfluxDB to Metrics Storage in overview (#3560) by GuoYu · 3 weeks ago
  96. 549a739 [lake/iceberg] Fix predicate push-down for TINYINT / SMALLINT into Iceberg (#3565) by GuoYu · 3 weeks ago
  97. cd98681 [flink-action][server][client] Add remove_orphan_files action for remote storage (#3404) by Yang Wang · 4 weeks ago
  98. 7ed81de [flink]Newly discovered partition read from earliest rather than scan.startup.mode (#3548) by Hongshun Wang · 4 weeks ago
  99. 16a5b32 [server] Set table_id on prepareLakeTableSnapshot error response (#3550) by Anton Borisov · 4 weeks ago
  100. e426f40 [lake/iceberg] Fix listener leak in IcebergLakeCommitter (#3542) by GuoYu · 4 weeks ago