Google Git
Sign in
apache/fluss/HEAD
  1. 5b9831a [common] Fix CHAR min/max statistics collection (#4080) by Beetle brank · 12 hours ago main
  2. b9a1653 [rust] Close drained batches before sending (#4258) by naivedogger · 13 hours ago
  3. 0bb363e [rust] Stale out-of-order responses can incorrectly reset the idempotent writer (#4252) by naivedogger · 15 hours ago
  4. dbf908a [server] Detach flushed entries from previousEntry chains in KvPreWriteBuffer by Kaixuan Duan · 2 days ago
  5. 9827cab [server] Fix thread-safety bug in RebalanceManager ZooKeeper recovery path (#4232) by fhan · 2 days ago
  6. a63e55a [server] Restrict superuser credential changes to 'super.users' (#4229) by Hongshun Wang · 2 days ago
  7. 3fea920 [docs] Document security.sasl.plain.credentials for multi-user SASL/PLAIN (#4168) by Keith Lee · 2 days ago
  8. 93bdc42 [docs] Add Fluss Gateway deployment documentation (#4210) by Junbo Wang · 3 days ago
  9. 1e54187 [gateway] Reject duplicate MAP keys in entry arrays (#4205) by Gezi-lzq · 3 days ago
  10. 44e1cdd [server] Keep snapshot metrics safe during cleanup by Yang Wang · 5 days ago
  11. 7be030f [gateway] Add Prometheus identity labels (#4219) by Yang Wang · 5 days ago
  12. 89a69ce [client][server][paimon] Complete historical partition writes (#4120) by yuxia Luo · 6 days ago
  13. 95b3ff1 [server] Refine KV minRetainOffset restoration by Jark Wu · 7 days ago
  14. 32e3668 [server] Restore KV minRetainOffset on follower restart (#4060) by Yang Guo · 9 days ago
  15. 059d7aa [server] Share RocksDB write buffer across KV tablets by Yang Wang · 7 days ago
  16. da69aee Fluss Documentation add CoordinatorServer High Availability (HA) Setup (#4111) by striver619 · 7 days ago
  17. dfd7782 [docs] Document Spark scan.maxRecordsPerPartition (#4049) by kaiwangleo · 7 days ago
  18. 8941d74 [CVE][filesystem] Align Hadoop dependencies to 3.4.3 (#3699) by litiliu · 7 days ago
  19. 3145197 [lake/paimon] Support custom Paimon lake table path (#3476) by Liurnly · 7 days ago
  20. 2af8af6 Revert "[server] Fix alter cluster configs (#4179)" (#4196) by Hongshun Wang · 7 days ago
  21. 8ec4a6c [rust] Reject empty or duplicate primary key columns (#4182) by Junbo Wang · 8 days ago
  22. 305cbcc [docs] Add remove_orphan_files Flink action page (#4193) by Keith Lee · 8 days ago
  23. 6a2bb5b [docs] Document non-full primary key DELETE and UPDATE in Flink batch mode (#4191) by Keith Lee · 8 days ago
  24. 3e67bf2 [docs] Add multi-table scanner and writer documentation for the Java client (#4192) by Keith Lee · 8 days ago
  25. a3b2db8 [server] Add javadoc for the BucketMetadata#isr() method by Jark Wu · 8 days ago
  26. e01a94e [server][rpc] Return ISR and bucket epoch in bucket metadata (#3785) by Yang Guo · 8 days ago
  27. 79c71c2 [rust] Preserve highest_field_id during Schema JSON deserialization (#4184) by Junbo Wang · 8 days ago
  28. 15ff9a0 [server] Fix alter cluster configs (#4179) by Keith Lee · 8 days ago
  29. 2a0ae10 [lake] Support empty commits for Hudi and Lance to persist tiering progress (#3941) by Junbo Wang · 8 days ago
  30. 333dfcc [serve/kv] Support shared RocksDB block cache across KV tablets (#2627) by Yang Wang · 8 days ago
  31. c6210f4 [rust] Return error when table descriptor schema is missing. (#4175) by slfan1989 · 8 days ago
  32. 6f7790a [docs] Clarify Gateway auto-increment writes (#4164) by Junbo Wang · 8 days ago
  33. 843b8e1 [rust][cpp][python] schema serde auto increment (#4171) by Anton Borisov · 9 days ago
  34. 7338a49 [flink] Mark lake and KV snapshots as finished when EOF before logs (#4042) by Shawn Huang · 9 days ago
  35. f1c04b6 [lake/paimon] Prevent concurrent local lookup false misses (#4158) by yuxia Luo · 9 days ago
  36. bd8f4de [rust] Verify the release metadata in CI (#4169) by Anton Borisov · 9 days ago
  37. 404c17c [lake/paimon] Maintain lakestream.enabled with lake acceleration state (#4118) by fhan · 9 days ago
  38. e116bfd [client] Retry stale out-of-order responses instead of resetting the idempotent writer (#4125) by litiliu · 9 days ago
  39. 98adb83 [server] Disable standby replicas by default for new PK tables (#4157) by yunhong · 9 days ago
  40. a5e6a18 [docs] Add Fluss Gateway 1.0 preview documentation (#4162) by Junbo Wang · 9 days ago
  41. 31a2b15 [gateway] Log per-request details at debug level (#4163) by Junbo Wang · 9 days ago
  42. 9f6a698 [server] Remove lookup lock for `PaimonLakeTableLookuper` (#4050) by Junfan Zhang · 10 days ago
  43. 75529ad [rust] Avoid copying the Arrow payload when decoding a batch (#4154) by Anton Borisov · 11 days ago
  44. 2767998 [rust][python][c++] Expose the table's Arrow schema on Table (#4148) by Anton Borisov · 11 days ago
  45. 30f38f2 [rust] Reject append_arrow_batch columns whose type differs from the table (#4147) by Anton Borisov · 11 days ago
  46. 26c65c4 [rust] Stop retrying writes after a cached table is dropped (#4141) by George Stamatakis · 11 days ago
  47. 1725f0c [observability] Introduce the mechanism of filtering metrics (#4135) by Junfan Zhang · 11 days ago
  48. dc54e1d [rust] Return error for invalid table metadata JSON (#4146) by slfan1989 · 11 days ago
  49. a52a6ae [rust] Only excuse nulls a slice or the owning ROW removes by Anton Borisov · 11 days ago
  50. 0bebe9e [rust] Validate append_arrow_batch nullability before enqueue by charlesdong1991 · 11 days ago
  51. ae9ae3d [FLUSS-3483][coordinator] Reject lake snapshot commits for dropped tables (#3494) by Jackeyzhe · 11 days ago
  52. f165b44 [docs] Document clean lake schemas and rolling upgrade requirements (#4112) by fhan · 12 days ago
  53. 4a60ed5 [python] Create Python bindings for log filter pushdown (#4127) by Anton Borisov · 12 days ago
  54. 26db5b7 [gateway] Include concrete path in REST access logs (#4142) by Junbo Wang · 12 days ago
  55. fa5b9fd [gateway] Add binary distribution and container release flow (#4098) by naivedogger · 12 days ago
  56. eb2e50e [docs] Document Paimon tiering issue with externally evolved schema (#4140) by George Stamatakis · 12 days ago
  57. 4e372d5 [gateway] Add the schema-aware batch write endpoint with per-row outcomes (#4126) by Junbo Wang · 12 days ago
  58. f09de85 [rust] Filter pushdown documentation and example (#4131) by Keith Lee · 13 days ago
  59. c841a7c [kv] Convert raw KV values at the storage boundary by Jark Wu · 13 days ago
  60. 3ab6b9c [kv] Add row TTL support (#3621) by 白鵺 · 9 weeks ago
  61. bc2183e [FIP-49][gateway] Add schema-aware JSON row decoder (#4104) by naivedogger · 13 days ago
  62. 3349430 [flink] Support bounded streaming read for Fluss source (#4022) by naivedogger · 13 days ago
  63. 8ae5b07 [c++] Create C++ bindings for log filter pushdown (#4036) by naivedogger · 13 days ago
  64. 0c0b3d3 [lake/paimon] Preserve Arrow column name case in batch writes (#4123) by Junbo Wang · 13 days ago
  65. 4172162 [gateway] Add catalog and DDL backend operations with REST APIs (#4107) by Junbo Wang · 14 days ago
  66. 7ee8824 [docs] Add Real-Time User Profile quickstart tutorial (#2669) by Prajwal Banakar · 14 days ago
  67. 16aa41a [rust] Filter pushdown integration test (#4109) by Keith Lee · 14 days ago
  68. 9a915d9 [server] Support primary-key writes to historical partitions in server (#4001) by yuxia Luo · 2 weeks ago
  69. bc04412 [flink] Fix stale delta join tests and add missing 2.3 coverage by Anton Borisov · 2 weeks ago
  70. 01988d8 [flink] add support for flink 2.3 by Pei Yu · 2 weeks ago
  71. 92f9d48 [client] Reduce connection timeout to 15s for faster metadata recovery (#4095) by Hongshun Wang · 2 weeks ago
  72. 93e0ac4 [lake/hudi] Use a clean lake table schema for Hudi lake storage (#4077) by fhan · 2 weeks ago
  73. 1e74ea2 [FIP-49][gateway] Add the Gateway backend runtime, cluster discovery, and metadata listing (#4078) by Junbo Wang · 2 weeks ago
  74. 6aa096d [lake/paimon] Bump Paimon version to 2.0.0 (#4093) by Junfan Zhang · 2 weeks ago
  75. 9c8b530 [server] Remove unused option of server io tmp (#4096) by Junfan Zhang · 2 weeks ago
  76. 60e2e96 [rust][python] Add LICENSE and NOTICE to the published artifacts (#4090) by Anton Borisov · 2 weeks ago
  77. c32b3f4 [c++] Add bounded RecordBatch log reader APIs (#3988) by naivedogger · 2 weeks ago
  78. ad5dede [rust] Wire batch statistics into the log batch write and read paths (#4074) by Keith Lee · 2 weeks ago
  79. 4403f99 [flink] Fix LakeSource copy isolation (#4059) by Shawn Huang · 2 weeks ago
  80. b8cbb62 [server] Fix orphan segments after full truncation and tolerate sequence gaps during writer recovery (#4013) by yunhong · 2 weeks ago
  81. 1c2c447 [rust] Fix bazel config attribute and tarball regeneration by Anton Borisov · 2 weeks ago
  82. 938f8ff [rust] Check in generated protobuf code and drop protoc requirement by seokjin0414 · 2 weeks ago
  83. ce854ae [lake/iceberg] Support clean and legacy Iceberg lake table schemas (#4019) by fhan · 2 weeks ago
  84. 545c553 [lake/paimon] Bump Paimon version to 1.4.2 (#3545) by Pei Yu · 3 weeks ago
  85. 2b947c9 [rust] Add V1 batch statistics collection (#4011) by Keith Lee · 3 weeks ago
  86. 1ef4182 [gateway] Validate configuration and redact secrets (#3970) by Junbo Wang · 3 weeks ago
  87. 128ab38 Feature/filter pushdown java docs (#4003) by Yang Wang · 3 weeks ago
  88. 77d132b [flink] Name the kv batch read strategy, restore startup guard by Anton Borisov · 3 weeks ago
  89. a66a6e4 [flink] Integrate FIP-17 server-side KV scan into Flink connector by ipolyzos · 3 weeks ago
  90. 70892a3 [test] Wait for local leader readiness (#4053) by Jark Wu · 3 weeks ago
  91. 3a000ba [test] Wait for KV flush before limit scan by Jark Wu · 3 weeks ago
  92. eaeae17 [common] Fix equals/hashCode contract for DefaultValueRecordBatch and DefaultKvRecordBatch (#3952) by vbhanuchander-lang · 3 weeks ago
  93. fccf047 [server] Propagate table config updates through TableInfo by Jark Wu · 3 weeks ago
  94. e51b5ee [test] Verify altered log TTL cleanup end to end by Jark Wu · 3 weeks ago
  95. 21b1bb5 [server] Support altering table.log.ttl table option (#3233) by duankaixuan · 4 months ago
  96. 0bd725c [rpc] Fix RequestChannel backpressure race by Xiaobing Fang · 3 weeks ago
  97. fbd3d33 [flink] Fix ClassNotFoundException for RoaringBitmap in shaded Flink connector JAR (#3981) by Prajwal Banakar · 3 weeks ago
  98. cda2bb0 [docs] Use a non-expiring Slack invitation link (#4040) by Leonard Xu · 3 weeks ago
  99. 4f8c95b [server] Support independent local log TTL (#3778) by Yang Guo · 3 weeks ago
  100. 2cf81dc [flink] Fix batch log scan with empty buckets (#4007) by Gezi-lzq · 3 weeks ago