Google Git
Sign in
apache/fluss/HEAD
  1. dd181eb [helm] Add CI workflow to run Helm tests (#2777) by Muhammet Orazov · 5 hours ago main
  2. e6e95ca [kv] Support dynamic configuration for 'kv.snapshot.interval' (#2820) by yunhong · 5 hours ago
  3. 199af0b [client] Support Scan#createBatchScanner() API to read data from the whole table (#2794) by Hongshun Wang · 16 hours ago
  4. 2c49fbc [helm] Fix wrong resource name in coordinator sts (#2834) by Muhammet Orazov · 20 hours ago
  5. bafba42 [server] Add configuration options for multiple remote data directories (#2757) by Liebing · 2 days ago
  6. e9dbcf1 [hotfix] log info include table bucket for remote log downloader when downloading (#2817) by yunhong · 2 days ago
  7. 79fd2eb [lake/tiering] Add CoordinatorServer Monitoring Metrics for Lake Tiering Scheduling (#2815) by Junbo Wang · 2 days ago
  8. 2a393f6 [docs] Fix misaligned tables in the document (#2813) by Tom · 2 days ago
  9. c93a1f3 [lake/paimon] Support Altering Lake Table Properties (#2799) by Liebing · 2 days ago
  10. 21bcabd [github] Add Unstable Test Reporter for CI to track flaky tests by Jark Wu · 4 days ago
  11. 62a49a2 [metric] add bucket and partition count metric for table (#2800) by xiaozhou · 5 days ago
  12. d6aacdd [server] Fix LogTieringTask to commit successfully copied segments on partial failure (#2767) by yunhong · 6 days ago
  13. b9c9042 [blog] Fluss for ai (#2788) by Giannis Polyzos · 6 days ago
  14. d59fdfc [doc] fix kv.snapshot.num-retained default value (#2797) by xiaozhou · 6 days ago
  15. 3b1dbba [github] Upgrade Fluss version 0.9.0 in BUG issue template (#2789) by Liebing · 7 days ago
  16. 87db594 [paimon] Improve npe error in FlussRecordAsPaimonRow (#2765) by Thorne · 7 days ago
  17. 15f8382 fix binlog example to match changelog (#2775) by MehulBatra · 8 days ago
  18. 2d69732 release fixes for changefeed to include binlog (#2774) by MehulBatra · 9 days ago
  19. f39e188 [docs] Add download link for release 0.9.0 (#2682) by yuxia Luo · 9 days ago
  20. e1ed655 [blog] 0.9 Release announcement (#2590) by Giannis Polyzos · 9 days ago
  21. 0adf1b2 [doc] Mark 0.9.0 as released in document by luoyuxia · 9 days ago
  22. fbdb7fa [hotfix] Fix unstable test KvReplicaRestoreITCase.testRowCountRecoveryAfterFailover by Jark Wu · 11 days ago
  23. 1b760c1 [flink] Fix $changelog and $binlog virtual tables fail (NPE) to complete checkpoint (#2743) by Jark Wu · 12 days ago
  24. ea1f60b [flink] Add IT test for latest scan startup mode for changelog virtual table (#2477) by nhuan.bc · 6 weeks ago
  25. ad037cf [lance] Fix Lance writer to emit Arrow FixedSizeList for array columns to enable native vector search (#2707) by Keith Lee · 11 days ago
  26. 1178d39 [website] Update code styling and add light theme for syntax highlighting (#2742) by Jark Wu · 12 days ago
  27. 9489cce [typo] Fix typos in docs comments and improve code readability (#2734) by xiaozhou · 12 days ago
  28. 9bfa9e2 [docs] Remove external google font to address apache podling website resource check (#2566) by Keith Lee · 12 days ago
  29. 5030f02 [website] Team changes & addition (#2731) by MehulBatra · 13 days ago
  30. 72e85bf [docs] Add documentation for alter table option table.log.tiered.local-segments (#2733) by Hongshun Wang · 13 days ago
  31. c5e6513 [hotfix] Fix retrieve typos (#2727) by xiaozhou · 13 days ago
  32. 7fa0a8d [docs] Add Events link under ASF dropdown (#2567) by Keith Lee · 13 days ago
  33. 75ea749 [kv] Validate non-primary-key table for KvSnapshotLease acquire and release APIs (#2723) by yunhong · 13 days ago
  34. 9ec7152 [client]Fix memory leak if oom when decompress data in VectorLoader. (#2647) by Hongshun Wang · 13 days ago
  35. 4e54416 [hotfix][flink] Fix release kv snapshot lease for log table (#2719) by Liebing · 13 days ago
  36. 575db63 [hotfix][flink] Fix acquire kv snapshot lease cannot work issue for legacy clusters (#2714) by yunhong · 14 days ago
  37. 43f76a5 [helm] Enable pulling from private Docker registry (#2692) by Lorenzo Affetti · 2 weeks ago
  38. 4f74f32 [docs] Update fluss-versions.json for 0.9.0 RC2 by luoyuxia · 3 weeks ago
  39. f9cd71d [release] Fix the LICENSE and NOTICE files for the binary distribution, including transitive dependencies. (#2703) by JB Onofré · 3 weeks ago
  40. 56a8723 [docs] Add documentation for COUNT(*) aggregation on primary key table (#2687) by Jark Wu · 3 weeks ago
  41. 3fb96b3 [hotfix][flink] Fix COUNT(*) aggregation produces wrong result for legacy clusters (#2690) by Jark Wu · 3 weeks ago
  42. 6602038 [log] Fix error message in CompactedRowReader.java (#2694) by nhuantho · 3 weeks ago
  43. d728e24 [docs] Add documentation for complex type mapping between Flink and Fluss (#2685) by ForwardXu · 3 weeks ago
  44. f11b239 [docs] Use versioned tag for RustFs docker image (#2680) by Keith Lee · 4 weeks ago
  45. 074d756 [hotfix][docs] Fix some documentation errors by Jark Wu · 4 weeks ago
  46. bd50f5e [docs] Update docs for release manager to correct wrong part (#2672) by yuxia Luo · 4 weeks ago
  47. 471c394 [website] Introduce "$FLUSS_MAVEN_REPO_URL$" variable for staging maven artifacts by Jark Wu · 4 weeks ago
  48. 3f3142e [docs] Create upgrade notes for 0.10 by luoyuxia · 4 weeks ago
  49. 3fe5d70 [docs] Update local cluster deployment warning (#2654) by Madhur Chandran · 4 weeks ago
  50. e698f6a [spark] Introduce Spark connector documentation (#2668) by Yann Byron · 4 weeks ago
  51. 5dc5288 [docs] Update fluss-versions.json for 0.9.0 RC1 by luoyuxia · 4 weeks ago
  52. 422d422 [kv] Support COUNT(*) pushdown for primary key tables and introduce GetTableStats RPC (#2651) by Jark Wu · 4 weeks ago
  53. 0887cd0 [kv] Introduce TabletState to support persistence of auto-inc buffer and row count (#2651) by Jark Wu · 4 weeks ago
  54. 4d05e8e [lake/flink] Fix lake tiering doesn't work in flink 2.2 (#2657) by yuxia Luo · 4 weeks ago
  55. f97cf6c [docs] Update quickstart-flink doc to use 'kv.snapshot.interval' = 0s to avoid client obtain token issue (#2660) by yuxia Luo · 4 weeks ago
  56. 5fd8d9c [lake/paimon] Skip readable snapshot recomputation when latest compacted snapshot already in ZK (#2640) by yuxia Luo · 4 weeks ago
  57. e58c122 [docs] add introduction for auto-increment column (#2650) by xx789 · 4 weeks ago
  58. a71f045 [license] Keep original license headers for lightproto source code (#2174) by CaoZhen · 4 weeks ago
  59. 057bacc [hotfix] Fix flaky testRescaleUp by fixing race condition in ProducerOffsetsStore.deleteSnapshot by 白鵺 · 4 weeks ago
  60. fc9c52f [test] Fix flaky testUndoRecoveryMultipleKeys by checkpointing keyIndex in FailingCountingSource by 白鵺 · 4 weeks ago
  61. 90a3be3 [lake/iceberg] support RowType conversion in FlussArrayAsIcebergList (#2649) by Junbo Wang · 4 weeks ago
  62. 2f5e208 [hotfix][spark] correct shaded artifact name for fluss-spark-common in fluss-spark-3.x (#2641) by Junbo Wang · 4 weeks ago
  63. 46e3b42 [flink] Add exactly-once sink support with undo recovery for aggregation tables (#2613) by Yang Wang · 4 weeks ago
  64. 1e8cd60 [docs] Fix null value syntax in aggregation merge engine examples (#2645) by Yang Wang · 4 weeks ago
  65. fad97df [client] Thrown exception if ServerType mismatch. (#2606) by Hongshun Wang · 4 weeks ago
  66. 18bda48 [docs] Improve aggregation.md with complete SQL examples for rbm32/rbm64 (#2643) by Yang Wang · 4 weeks ago
  67. d54ac70 [kv] Validate column data types for aggregation function during table creation (#2323) by Jackeyzhe · 4 weeks ago
  68. e591278 [hotfix][server] KvSnapshotLeaseMetadataJsonSerde serialize kv snapshot path use toString() instead of getPath() (#2633) by yunhong · 4 weeks ago
  69. 60d85ca Fix list rebalance procedure throw ClassCastException (#2637) by Pei Yu · 4 weeks ago
  70. 9635f03 [docs] Update Quickstart to Use S3 (via RustFS) Instead of Local File System (#2569) by Keith Lee · 4 weeks ago
  71. 5a4374a [paimon] Fix union read paimon dv table issue (#2326) by yuxia Luo · 4 weeks ago
  72. 139035e [spark] Fix unstable UT caused by CheckLastBatch call (#2628) by Yang Zhang · 4 weeks ago
  73. 1881c2c [kv] Forbid aggregate merge engine with WAL changelog image (#2617) by Yang Wang · 4 weeks ago
  74. c6d9fbb [flink] Drop kv snapshot lease when no checkpoint triggered before (#2610) by yunhong · 4 weeks ago
  75. 06e95db [kv] Add zero-offset bucket keys verification in undo recovery test (#2623) by Yang Wang · 4 weeks ago
  76. 43a5d8a [lake/iceberg] Fix local date and time class cast (#2620) by Giovanny Gutiérrez · 4 weeks ago
  77. 2df2d6b [kv] Add undo recovery support for aggregation tables (#2545) by Yang Wang · 4 weeks ago
  78. 0cee383 [kv] Support kv snapshot lease (#2179) by yunhong · 4 weeks ago
  79. 5c23762 [server] Support alter table config `table.log.tiered.local-segments` (#2508) by Liebing · 4 weeks ago
  80. eb7a0f5 [flink] Fix skipping partition pushdown for primary key lakehouse table in batch mode. (#2585) by Hongshun Wang · 4 weeks ago
  81. ad45868 [flink] Support "lookup.insert-if-not-exists" option for Flink Lookup Join (#2601) by xx789 · 4 weeks ago
  82. 19bea6c [client] Implement Lookup with insert-if-not-exists on the client side (#2573) by xx789 · 4 weeks ago
  83. 5d7630a [spark] Add basic streaming read support for sparksql with latest mode (#2548) by Yang Zhang · 4 weeks ago
  84. cf8bb23 [docs] Add array type support documentation for Lance integration (#2579) by ForwardXu · 4 weeks ago
  85. ec43289 [helm] Allow templating listeners (internal, client) from values (#2460) by Muhammet Orazov · 5 weeks ago
  86. 74ee888 [docs] update compatibility table between versions by yuxia · 5 weeks ago
  87. e632c57 [helm] Bump helm version to 0.10.0 by yuxia · 5 weeks ago
  88. 1beab98 [docs] Add version item for 0.10.0-incubating in fluss-versions.json by yuxia · 5 weeks ago
  89. f288c29 [hotfix][dist] Don't print jindo log when deploy on console mode (#2577) by yunhong · 5 weeks ago
  90. 3fbbee6 [docs] Create upgrade notes for 0.10 by yuxia · 5 weeks ago
  91. aedef8c Update version to 0.10-SNAPSHOT by yuxia · 5 weeks ago
  92. fbf50fd [hotfix] Fix docker file build exception (#1802) by yuxia Luo · 5 weeks ago
  93. 3685519 [docs] update quickstart paimon to align to latest branch by yuxia Luo · 5 weeks ago
  94. 939043e [flink] unify the behavior of different startup mode for lake table (#2572) by yuxia Luo · 5 weeks ago
  95. 6655bdc [client] Support list database summaries (#2515) by Hongshun Wang · 5 weeks ago
  96. f92fa2c [doc/build] Fix iceberg quickstart to build on flink standard image (#2555) by MehulBatra · 5 weeks ago
  97. 4fb5973 [docs] Automate configuration documentation via fluss-docgen module (#2474) by Prajwal banakar · 5 weeks ago
  98. 2ab3ce2 [server] print snapshot size in snapshot finish log (#2516) by Junfan Zhang · 5 weeks ago
  99. 62ada45 [spark] Add startup mode for batch read (#2532) by Yang Zhang · 5 weeks ago
  100. 981111f [docs] Add documentation for $binlog virtual table (#2565) by MehulBatra · 5 weeks ago