Google Git
Sign in
apache/fluss/HEAD
  1. 70892a3 [test] Wait for local leader readiness (#4053) by Jark Wu · 3 hours ago main
  2. 3a000ba [test] Wait for KV flush before limit scan by Jark Wu · 5 hours ago
  3. eaeae17 [common] Fix equals/hashCode contract for DefaultValueRecordBatch and DefaultKvRecordBatch (#3952) by vbhanuchander-lang · 6 hours ago
  4. fccf047 [server] Propagate table config updates through TableInfo by Jark Wu · 24 hours ago
  5. e51b5ee [test] Verify altered log TTL cleanup end to end by Jark Wu · 26 hours ago
  6. 21b1bb5 [server] Support altering table.log.ttl table option (#3233) by duankaixuan · 4 months ago
  7. 0bd725c [rpc] Fix RequestChannel backpressure race by Xiaobing Fang · 11 hours ago
  8. fbd3d33 [flink] Fix ClassNotFoundException for RoaringBitmap in shaded Flink connector JAR (#3981) by Prajwal Banakar · 20 hours ago
  9. cda2bb0 [docs] Use a non-expiring Slack invitation link (#4040) by Leonard Xu · 28 hours ago
  10. 4f8c95b [server] Support independent local log TTL (#3778) by Yang Guo · 30 hours ago
  11. 2cf81dc [flink] Fix batch log scan with empty buckets (#4007) by Gezi-lzq · 31 hours ago
  12. c3d56c4 [client] Include original partition name in historical lookup errors (#4032) by Junfan Zhang · 2 days ago
  13. a145eea [gateway] Add the Gateway runtime, common HTTP layer, lifecycle, and test infrastructure (#3963) by Junbo Wang · 2 days ago
  14. 5feb55f [flink] Preserve complete undo recovery baselines (#3953) by Yang Wang · 2 days ago
  15. ec517fe [client] Scope sender failures to per-table requests by Yang Wang · 2 days ago
  16. bdef64d [rust] Add LICENSE and NOTICE to the source release (#3803) by Anton Borisov · 3 days ago
  17. 1cf42c5 [flink] Support ALTER TABLE to modify watermark (#2718) by Liebing · 3 days ago
  18. cc02289 [lake/paimon] Support clean and legacy Paimon lake table schemas (#3982) by fhan · 3 days ago
  19. d694d38 [spark] Support time-range incremental batch reads (#3883) by Yang Zhang · 3 days ago
  20. 8e2f670 [rust] Fix Arrow limit scan across schema evolution (#3821) by slfan1989 · 3 days ago
  21. 37ad1af [rust] Wire the scan filter through to the log fetcher (#3971) by Keith Lee · 3 days ago
  22. 0ebc9f2 [log] Recover segments containing a single empty batch by Yang Wang · 6 days ago
  23. 2ba95fa [gateway] Introduce the fluss-gateway module scaffolding (#4002) by Junbo Wang · 6 days ago
  24. a749a19 [iceberg] fast fail when creating table of iceberg with multi key fields (#2499) by Junfan Zhang · 6 days ago
  25. fc81870 [rust] Support cooperative KV backpressure (client side of #3463) (#3964) by Junbo Wang · 6 days ago
  26. 526fd96 [rust] ignore missing partitions during scanner metadata updates (#3935) by Junfan Zhang · 7 days ago
  27. 8dd23f9 [fs] Relocate commons in S3/GS/Azure fs plugins to fix Spark conflict (#3960) by Yang Zhang · 7 days ago
  28. 5209c27 [client] Cache synchronously fetched schemas (#3335) by leon.jeon · 8 days ago
  29. 9ee87d0 [server] Manage historical lookup local cache capacity (#3864) by yuxia Luo · 8 days ago
  30. b2c511c [server] Fix ISR shrink race during leader transition (#3920) by hanliu0830 · 8 days ago
  31. 7876de0 [server] Fall back to rack-unaware assignment for partial rack info (#3946) by yunhong · 8 days ago
  32. 7f7fe24 [server] Fix remote log start offset of RemoteLogManifest may expose an expired physical prefix (#3956) by Yang Guo · 8 days ago
  33. b671dc3 [flink] Support batch scan for virtual log tables (#3925) by naivedogger · 8 days ago
  34. 9826b44 [test] Add multi-version compatibility test selection (#3913) by Jark Wu · 8 days ago
  35. 6e38147 [CI] Wait for table metadata in authorization test (#3875) by litiliu · 8 days ago
  36. 9e3fa8f [common] Extract NO_SNAPSHOT_ID sentinel to fluss-common (#3928) by Yang Zhang · 8 days ago
  37. afc34bb [flink] Route undo offsets by sink subtask by Yang Wang · 8 days ago
  38. 471160e [rust] add support of iceberg format key encoder (#3934) by Junfan Zhang · 9 days ago
  39. c4ccaf6 [doc] documentation for gravitino integration (#3669) by Vladyslav Banar · 9 days ago
  40. c9a6c5c [flink] Track consumed progress during undo recovery (#3910) by Yang Wang · 9 days ago
  41. b119fd7 [server] Paimon schema compatibility check is too strict for comments and options when alter table. (#3890) by Hongshun Wang · 9 days ago
  42. fb1e9f6 [server] Refine remote log manifest overlap handling (#3937) by Jark Wu · 9 days ago
  43. 5b58834 [server] Support hot update for active segment retention roll (#3940) by Jark Wu · 9 days ago
  44. 2aad8b5 [flink] Commit tiered offsets for buckets that finished without data (#3893) by Junbo Wang · 9 days ago
  45. 39e9ce2 [flink] Validate database existence when resolving catalog functions in FlinkCatalog (#3906) by Prajwal Banakar · 10 days ago
  46. e8a0a1b [server] Ignore lake snapshot refresh failures during leader election (#3922) by yuxia Luo · 10 days ago
  47. e0fe960 [rust] Fix log append rejecting NOT NULL columns (#3899) by Kaiqi Dong · 10 days ago
  48. c43511b [rust] Encode predicates into their protocol representation (#3900) by Keith Lee · 10 days ago
  49. cd6ea11 [server] Roll expired active segments for remote retention (#3831) by Xiaobing Fang · 10 days ago
  50. ca703ac [server] Support RemoteLogManifest to handle overlap RemoteLogSegments (#3822) by Yang Guo · 10 days ago
  51. ffa665a [flink] Support projection and filter pushdown for $changelog and $binlog virtual tables (#3759) by naivedogger · 10 days ago
  52. 6a43bd4 [docs] Add Apache Doris to homepage (#3924) by Jark Wu · 10 days ago
  53. 8bcf22e [flink] Support batch delete and update in flink sink (#3863) by Hongshun Wang · 10 days ago
  54. 5bee00a [docs] Rename Streamhouse to Lakestream and add Hudi (#3911) by Jark Wu · 11 days ago
  55. 4259349 [docs] Expand bitmap SQL function usage by Jark Wu · 11 days ago
  56. 7faea75 [docs] Use rb_build in bitmap SQL examples by Jark Wu · 11 days ago
  57. ba96a05 [docs] Add RoaringBitmap SQL functions to aggregation documentation (#3823) by pbanakar · 3 weeks ago
  58. 4a3a60c [FIP-37] Add bitmap Phase 2 functions and register via FlussCatalog (#3777) by Prajwal Banakar · 11 days ago
  59. 8d326bc [rust] Add predicates as part of filter pushdown (#3847) by Keith Lee · 13 days ago
  60. 82670bf [lake/tiering][follow] Allow overriding tiering remote-first read preference (#3886) by Junbo Wang · 13 days ago
  61. 4105e24 [server] Fix spurious ISR shrink after leader election (#3702) by Xiaobing Fang · 13 days ago
  62. a72ef62 [server] batch fetch latest bucket snapshots to reduce latency (#3811) by Junfan Zhang · 14 days ago
  63. d0120f3 [server] fix KV snapshot restoring fallback (#3790) by Junfan Zhang · 2 weeks ago
  64. a75f23c [client] Prevent EOF during concurrent remote log downloads (#3816) by Xiaobing Fang · 2 weeks ago
  65. abad51f [server] Expose local log physical size at bucket level (#3841) by yunhong · 2 weeks ago
  66. 22cb196 [tiering] introduce the option of `lake.tiering.io.tmpdirs` to avoid disk exhaustion (#3569) by Junfan Zhang · 2 weeks ago
  67. bf25bee [test] Align prefix lookup test with async flush semantics (#3853) by Yang Wang · 2 weeks ago
  68. 394a7b2 [flink][client] Close writer immediately on sink failover (#3817) by naivedogger · 2 weeks ago
  69. 4f89e3e [kv] Skip RocksDB flushes during Tablet Server shutdown (#3807) by Yang Wang · 2 weeks ago
  70. 9973e6c [lookup] Support historical partition lookup for lake tables (#3630) by yuxia Luo · 2 weeks ago
  71. b39c61e [flink] respect flink io tmp multi dirs to fix disk exhaustion (#3617) by Junfan Zhang · 2 weeks ago
  72. 8d7ed5a [lake/paimon] Make PaimonSplit state survive Paimon class relocation (#3825) by Junbo Wang · 2 weeks ago
  73. a5d79f7 [flink] Remove the default exposure of client-side bucket-level metrics to reduce metrics storage pressure for existing Flink jobs. (#3828) by Hongshun Wang · 2 weeks ago
  74. b7fb6ec [flink] Flink batch read based on SST merge. (#3677) by Hongshun Wang · 3 weeks ago
  75. 21ac93f [server][client] Add cooperative KV backpressure based on RocksDB L0 (#3463) by Yang Wang · 3 weeks ago
  76. 505482e [client][rust] Align fixed-schema scans by column ID (#3771) by slfan1989 · 3 weeks ago
  77. 9428f82 [lake/tiering] Avoid chaining tiering source with tiering committer (#3802) by Junbo Wang · 3 weeks ago
  78. d951e4d [FIP-43][client] Support log scanner and writer for multiple tables (#3140) by Hongshun Wang · 3 weeks ago
  79. 917c3f3 [rpc] Bound length-delimited field length against readable bytes (#3756) by Anton Borisov · 3 weeks ago
  80. 0d52da8 [ci] Split Spark lake tests from compatibility lane (#3717) by litiliu · 3 weeks ago
  81. 24ee218 [rust] Update release tooling and documentation for TLP releases (#3791) by naivedogger · 3 weeks ago
  82. 5703676 [flink] Fix TableNotExistException when listing partitions on changelog / binlog virtual tables (#3641) by naivedogger · 3 weeks ago
  83. 631c6ec [build] Remove Apache Incubator branding after graduation to TLP (#3750) by naivedogger · 3 weeks ago
  84. c77ca8b [website] Add consent-gated kapa.ai "Ask AI" widget to docs site (#3760) by MehulBatra · 3 weeks ago
  85. 3a7c144 [website] Sort Fluss team members by role and name by Jark Wu · 4 weeks ago
  86. efc7a6e [docs] Fix Docker RC version format in release guide by Jark Wu · 4 weeks ago
  87. 158b810 [website] Adapt website and README for Apache Fluss top-level project (#3764) by Michael Koepf · 4 weeks ago
  88. 6bb470c [test] Wait for server tag cleanup (#3705) by litiliu · 4 weeks ago
  89. c190060 [server] release remote log index cache entries on deletion (#3737) by Junfan Zhang · 4 weeks ago
  90. ea37c95 [client][rust] Retry bootstrap initialization on retriable errors (#3758) by slfan1989 · 4 weeks ago
  91. b80b643 [server] fix zk notification purge race (#3752) by Yang Guo · 4 weeks ago
  92. 555f407 [server] Fix tmp file cleanup in remote log index cache init (#3755) by Anton Borisov · 4 weeks ago
  93. d688bbd [docs] hive and glue fixes and adjustments by Anton Borisov · 4 weeks ago
  94. 8e2f317 [docs] Add AWS Glue and Hive Metastore catalog guides with Mermaid diagrams by Jared Yu · 4 weeks ago
  95. 9f33db4 [rust][client] Support comma-separated bootstrap servers (#3711) by slfan1989 · 4 weeks ago
  96. ed859e9 [server] include time index in remote log cache weight (#3733) by Junfan Zhang · 4 weeks ago
  97. 6e07668 [server] prevent remote log cache size overflow (#3734) by Junfan Zhang · 4 weeks ago
  98. cf3b7b8 [spark] Fix empty projection causing Invalid metadata length for COUNT(*)/COUNT(1) (#3227) by Kaixuan Duan · 4 weeks ago
  99. 5cacbb0 [client] Add log read preference for remote-first fetch (#3606) by Junfan Zhang · 4 weeks ago
  100. 1ca13b4 [lake/hudi][docs] Add Hudi tiering service documentation (#3549) by fhan · 4 weeks ago