Google Git
Sign in
apache / fluss / HEAD
  1. 6655bdc [client] Support list database summaries (#2515) by Hongshun Wang · 16 hours ago main
  2. f92fa2c [doc/build] Fix iceberg quickstart to build on flink standard image (#2555) by MehulBatra · 18 hours ago
  3. 4fb5973 [docs] Automate configuration documentation via fluss-docgen module (#2474) by Prajwal banakar · 19 hours ago
  4. 2ab3ce2 [server] print snapshot size in snapshot finish log (#2516) by Junfan Zhang · 19 hours ago
  5. 62ada45 [spark] Add startup mode for batch read (#2532) by Yang Zhang · 21 hours ago
  6. 981111f [docs] Add documentation for $binlog virtual table (#2565) by MehulBatra · 21 hours ago
  7. 1b674ca [flink] Add and improve Delta Join IT tests (#2546) by xuyang · 4 days ago
  8. fa9927e [flink] Delta Join additional IT tests and docs improvement (#2546) by Anton Borisov · 6 weeks ago
  9. fb6765a [iceberg] Bump Iceberg version to 1.10.1 (#2415) by Eduard Tudenhoefner · 23 hours ago
  10. 73d8042 [paimon] Exclude paimon-bundle jar from fluss-lake-paimon to avoid class conflict (#2531) by yuxia Luo · 23 hours ago
  11. bdb44c7 [server] Fix rebalance may cause remote file deleted error (#2570) by yunhong · 24 hours ago
  12. 7ad353f [lake/lance] Add Array type support for Lance (#2537) by ForwardXu · 2 days ago
  13. b853efd [test] Fix FlinkTableSinkITCase#testWalModeWithAutoIncrement to correct assert changelogs of WAL image mode (#2568) by Jark Wu · 2 days ago
  14. 84b2044 [kv] Improve validation for target columns on auto-increment tables by Jark Wu · 3 days ago
  15. ec5078e [kv] Implement lookup with insertIfNotExists on tablet server (#2485) by Junbo Wang · 8 days ago
  16. 4408d2c [hotfix][docs] Revert documentation link changes to remove "next" version references by Jark Wu · 3 days ago
  17. a8b38a6 [spark] Rename parser to FlussSqlExtension and add generated class into source code by Jark Wu · 3 days ago
  18. af547f3 [spark] Support Spark CALL procedure command framework (#2408) by forwardxu · 3 weeks ago
  19. ff3cab9 [helm] Add `tabletServer.count` configuration option (#2456) by Muhammet Orazov · 3 days ago
  20. 4e88a91 [docker] Upgrade base image to Eclipse Temurin 17-jre-noble version (#2520) by Muhammet Orazov · 3 days ago
  21. 303af6d [lake] Add metric of LAKE_TABLE_COUNT (#2528) by Junfan Zhang · 4 days ago
  22. dba644d [flink] Basic $binlog read support without pushdown optimizations for pk table (#2525) by MehulBatra · 4 days ago
  23. f2ab4b5 fix image urls (#2547) by Giannis Polyzos · 4 days ago
  24. b1f0ad3 [website] feat blog: fraud detection with fluss flink and iceberg (#2535) by Jacopo Gardini · 4 days ago
  25. ed1e8f8 [lake/iceberg] Support MAP type in Iceberg tables (#2367) by HONGGEUN JI · 4 days ago
  26. b8551bc [flink] Bump flink 1.19 minor version to 1.19.3 (#1969) by Yang Guo · 4 days ago
  27. 27ac618 [docs] Add docs for rack-aware rebalance goal (#2540) by yunhong · 4 days ago
  28. 2671af6 [kv] Return log end offset in UpsertResult and DeleteResult for exactly-once semantics (#2530) by Yang Wang · 5 days ago
  29. 657d19b [kv] Add RocksDB memory metrics by component type (#2392) by Yang Wang · 5 days ago
  30. d3a935f [spark] support merge-read between kv snapshot and log for primary-key table (#2523) by Yann Byron · 5 days ago
  31. 65e4f37 [server] Support RackAwareGoal for rebalance (#2380) by yunhong · 5 days ago
  32. 84b40ec [script] Improve "local-cluster.sh" script to bind hostnames defined in "server.yaml" (#2284) by Yang Guo · 5 days ago
  33. fd82007 [test] Improve testing time for FlinkRecordEmitterTest by removing unnecessary FlinkTestBase dependency (#2533) by Jark Wu · 5 days ago
  34. 71b625f [website] Fix css style for 'code' in list (#1949) by Yang Guo · 7 days ago
  35. 1e84897 [kv] Add OVERWRITE MergeMode support for undo recovery in aggregation tables (#2492) by Yang Wang · 7 days ago
  36. 3a803df [lake] Fix lake encoder causing prefix lookup to miss data when bucket key is a subset of primary key (#2464) by yuxia Luo · 7 days ago
  37. ffe7da0 docs: updated Flink SQL Client startup and cluster shutdown instructions (#2522) by Nikhil Negi · 7 days ago
  38. d70dced [docs] Add Azure Blob Storage documentation (#2507) by gkatzioura · 8 days ago
  39. 96faf08 [lake/paimon] Compare paimon schema and Fluss schema before alter table. (#2331) by Hongshun Wang · 8 days ago
  40. e16f625 [common] Support DataTypes#parse(typeString) to parse datatype string into DataType (#2501) by Hongshun Wang · 8 days ago
  41. 215bd21 [observability] Introduce prometheus-push metric report (#2317) by Junfan Zhang · 8 days ago
  42. 194ed4f [FLUSS-2473][server][test] Fix flaky test FlussAuthorizationITCase.testRebalance (#2487) by Zübeyir Eser · 8 days ago
  43. 9252e10 [s3] fix the size of fluss-fs-s3 is too big (#2419) by Pei Yu · 9 days ago
  44. 087a05b [spark] Add sparksql lake table catalog DDL suite for paimon (#2438) by Yang Zhang · 9 days ago
  45. 336216c [flink] Fix Flink connector failure caused by unknown table options (#2431) by Liebing · 9 days ago
  46. 23d1594 [fs/azure] Support Azure Blob Storage (#1941) by gkatzioura · 9 days ago
  47. 4e91db4 [test] Add additional assertion to tests for TimestampLtz/Ntz to partition string conversion (#2481) by Keith Lee · 10 days ago
  48. 9ce7ed8 [hotfix] Fix unstable tiering source enumerator test (#2490) by yuxia Luo · 10 days ago
  49. 81e3f3a [kv] Add Producer Offset Snapshot for Exactly-Once semantics (#2434) by Yang Wang · 10 days ago
  50. 62db319 [lake] Tiering service support commit by time (#2185) by yuxia Luo · 10 days ago
  51. 3c7f502 [build] Upgrade GitHub Actions for Node 24 compatibility (#2349) by Pei Yu · 10 days ago
  52. de648d2 [hotfix] update messaging on github page (#2478) by Giannis Polyzos · 11 days ago
  53. 9592d03 [spark] Add Spark SQL ALTER table support for set/remove table properties (#2437) by Yang Zhang · 11 days ago
  54. 275a2ec [test] Fix unstable test ReplicaTest.testRestore (#2469) by Jark Wu · 11 days ago
  55. 0f39159 [doc/website] virtual tables documentation - $changelog for PK/Log Tables (#2476) by MehulBatra · 11 days ago
  56. 6eef968 [test] Fix flaky AdjustIsrITCase#testIsrShrinkAndExpand by using acks=1 (#2468) by Zübeyir Eser · 11 days ago
  57. 2cc7d7e [helm] Remove `tablet-server.id` from coordinator configuration options (#2458) by Muhammet Orazov · 11 days ago
  58. 7af1a1c [flink] changelog read support for log table without pushdown optimizations (#2467) by MehulBatra · 12 days ago
  59. 1eff229 [hotfix] Remove unstable "latest" scan startup mode test in ChangelogVirtualTableITCase (#2470) by Jark Wu · 12 days ago
  60. 6e014ad [test] Fix failed testPkCompactedPollFromLatestNoRecords. (#2465) by SeungMin · 12 days ago
  61. 86a283a [server] Update tablet server metadata cache when TableRegistration changed (#2378) by Liebing · 13 days ago
  62. 669841e [server] Fix FirstRowMergeEngine hang caused by empty log entries in projection pushdown queries (#2370) by Hongshun Wang · 13 days ago
  63. 729ac99 [lake] Make FlussLakeTiering pluggable to customize tiering job construct (#2364) by yuxia Luo · 13 days ago
  64. 604bd2d [flink] changelog read support for pk table without pushdown optimizations (#2347) by MehulBatra · 13 days ago
  65. 2185afb [coordinator] Refactor SchemaUpdate to delegate schema changes to Schema.Builder (#2416) by Prajwal banakar · 14 days ago
  66. 795b7d9 [hotfix][helm] Update image repository to use 'apache/fluss' instead of 'fluss' (#2340) by Muhammet Orazov · 14 days ago
  67. 69258dc [lake] report pending records even though no tiering is finished (#2453) by yuxia Luo · 14 days ago
  68. 905590e [docs] Add client feature support matrix documentation (#2445) by Keith Lee · 14 days ago
  69. 8eaad3b [minor][flink] Remove unnecessary java notes (#2444) by Leonard Xu · 14 days ago
  70. 518ae7f [website] Update Fluss messaging (#2428) by Giannis Polyzos · 2 weeks ago
  71. 29a071b [spark] support batch read from fluss cluster (#2377) by Yann Byron · 2 weeks ago
  72. dc6e747 [test] Support manually trigger and wait for KV snapshots for FlussClusterExtension (#2429) by Jark Wu · 2 weeks ago
  73. d44a1cc [hotfix] Catalog related lake options should overwrite table lake related options (#2432) by yuxia Luo · 2 weeks ago
  74. bb84256 [client] move OffsetsInitializer to fluss-client (#2424) by Yann Byron · 2 weeks ago
  75. 864bbe6 [kv] Add roaring bitmap aggregate function for aggregation merge engine (#2390) by Yang Wang · 2 weeks ago
  76. d10cb35 [flink] Flink integration with Aggregation Merge Engine (#2307) by Yang Wang · 2 weeks ago
  77. 2fc820d [lake] Support alter table.datalake.freshness (#2365) by zhaomin1423 · 2 weeks ago
  78. 7cdb733 [docs] Add docs for rebalance (#2382) by yunhong · 3 weeks ago
  79. 04470ee [hotfix] Fix union read fail when from timestamp and projection enabled (#2383) by yuxia Luo · 3 weeks ago
  80. a8308b5 [tests] Cleanup ZK state in TableChangeWatcherTest to not let current tests be impacted by leftover events from previous tests. (#2249) by vamossagar12 · 3 weeks ago
  81. 4f3c457 [flink] Fix the distribution mode support for FlussSink for DataStream API by Jark Wu · 3 weeks ago
  82. 029bc13 [flink] Optimize sink statistics calculation to run only when necessary by Jark Wu · 3 weeks ago
  83. 13af6bf [flink] Support PARTITION_DYNAMIC sink dynamic shuffle based on partition traffics (#1784) by Hongshun Wang · 3 weeks ago
  84. 42ccb87 [test] Fix unstable test RebalanceITCase#testRebalanceForLogTable (#2407) by yunhong · 3 weeks ago
  85. e4f694d Add RocksDB block cache configuration options for index and filter blocks (#2394) by Yang Wang · 3 weeks ago
  86. 344e38f [spark] Add spark streaming write support (#2357) by Yang Zhang · 3 weeks ago
  87. a6b0b85 [server] Prevent remote log TTL expiration until tiering completes (#1940) by Liebing · 3 weeks ago
  88. be01cff [kv] Improve the implementation of AUTO_INCREMENT column by Jark Wu · 3 weeks ago
  89. dc8cc65 [kv] Add basic implementation of AUTO_INCREMENT column (#2161) by Junbo Wang · 4 weeks ago
  90. 8799308 [lake/lance] Refactor LanceArrowWriter to reuse fluss-common ArrowWriters (#2345) by ForwardXu · 3 weeks ago
  91. 053b8f7 [spark] Add Spark show/add/drop partition support (#2314) by Yang Zhang · 3 weeks ago
  92. c1f7a11 Change the ListRebalanceProcessProcedure result from String[] to row[] (#2341) by Pei Yu · 3 weeks ago
  93. c9370ae [Flink] Support Partial Updates to the Flink Sink (#2042) by Giannis Polyzos · 3 weeks ago
  94. 3c53a20 Rebalance procedure docs (#2355) by yunhong · 3 weeks ago
  95. d2ac422 [paimon] Add IT case for union read with evolved schema for Paimon (#2368) by Zübeyir Eser · 3 weeks ago
  96. 2ce8378 [lake] Re-initial tiering splits for tables if reader failover happen (#1984) by Junbo Wang · 3 weeks ago
  97. 4dba604 [doc] fix typo of 'table.datalake.enabled' in options.md (#2366) by zhaomin1423 · 3 weeks ago
  98. 8b11e00 [hotfix] Add authentication to the admin APIs that currently lack it (#2350) by yunhong · 4 weeks ago
  99. 7fd7b33 [docs] Add alter table feature link in getting-started.md (#2348) by yunhong · 4 weeks ago
  100. 3db4bfe [Task] Enhance tests for cluster rebalancing (#2315) (#2337) by Prajwal banakar · 4 weeks ago