Google Git
Sign in
apache/fluss/HEAD
  1. 296a0a2 [server] Support plugin discovery for client authentication (#3474) by yunhong · 14 hours ago main
  2. 8c48006 [hotfix] Use short name for ClusterHealth in TestAdminAdapter (#3472) by yunhong · 18 hours ago
  3. fa091e8 [server] Add TableLifecycleThrottler to throttle drops in coordinator queue (#3174) by yunhong · 24 hours ago
  4. 69234c3 [website] Use theme-aware diagram on intro page (#3470) by Prajwal Banakar · 34 hours ago
  5. ad51d97 [server] Add Cluster Health API implementation (#3400) by yunhong · 34 hours ago
  6. db1e86d [flink] Fail fast on batch virtual log table reads (#3402) by QuakeWang · 2 days ago
  7. b7338dd [test] Delete temp dir after cluster shutdown in FlussClusterExtension (#3411) by Dream95 · 2 days ago
  8. b336f2e [server] Allow altering datalake auto-compaction before lake enabled (#3458) by Liurnly · 2 days ago
  9. ba0e627 [spark] Add scan.maxRecordsPerPartition config to split log table input partitions (#3260) by Yang Zhang · 3 days ago
  10. 3067970 [server] Support altering auto partition num-precreate option (#3434) by fhan · 3 days ago
  11. bd1bff3 [test] Fix ComponentClassLoaderTest tmpdir path handling (#3450) by litiliu · 3 days ago
  12. 53ee201 [docs] Update README engine support (#3438) by zhigang · 3 days ago
  13. 0cd9327 [hotfix] Fix typo in scanner metric name (#3448) by Kaiqi Dong · 3 days ago
  14. ab493cd [FIP-37] Add bitmap aggregate functions: rb_build_agg, rb_or_agg, rb_and_agg and register via FlussCatalog (#3398) by Prajwal Banakar · 3 days ago
  15. 0f5909a [flink] Add union read support to datastream (#3432) by Giannis Polyzos · 4 days ago
  16. e3ed5b4 [client] Restrict the use of client.security.sasl.jaas.config to PlainLoginModule exclusively. (#3425) by Hongshun Wang · 4 days ago
  17. 6d3ba38 [server] Keep flushedLogOffset monotonic to fix row count after failover (#3427) by Daeuk Choi · 4 days ago
  18. 02e40ec fix: remote orphan files and directories when tablet starts up (#3388) by Yang Guo · 5 days ago
  19. 91bea7c [server] Add per-task timeout for RebalanceManager to prevent indefinite blocking (#3429) by yunhong · 5 days ago
  20. 0a699b3 [lake/paimon] TieringSourceReader adjust to scan arrow record batch and write arrow record batch to lake (#3430) by yuxia Luo · 6 days ago
  21. 0afc21a [client] Fix tiering hang on first_row merge engine empty batches (#3242) by Kaixuan Duan · 7 days ago
  22. 258e9f1 [fs] Mask S3 delegation token access keys in logs (#3421) by QuakeWang · 7 days ago
  23. e32ba47 [client] Support log scanner scan to arrow record batch (#2995) by yuxia Luo · 8 days ago
  24. 730407d [lake/hudi] Introduce Hudi LakeCatalog to create table (#3395) by fhan · 9 days ago
  25. 1dfa13f [server] Add table-level config for standby replica with ALTER TABLE support (#3257) by yunhong · 9 days ago
  26. 2f77b22 [client] Fix stale metadata on readOnlyGateway by adding RetryableGatewayClientProxy (#3390) by Hongshun Wang · 9 days ago
  27. 5ddb97d [server] Fix flaky RebalanceManagerITCase.testBuildClusterModel (#3306) by Kaixuan Duan · 10 days ago
  28. f01a4ac [client] Abort write batch if table id changes. (#2747) by Hongshun Wang · 10 days ago
  29. 717bee7 [spark] Implement SupportsPushDownLimit DSv2 interface (#3346) by Yang Zhang · 10 days ago
  30. 35beec1 [spark] Split non-partition and partition predicates from pushPredicates to limit pushdown (#3397) by Yang Zhang · 11 days ago
  31. af38e9c [server] Fix flaky RebalanceManagerITCase.testRebalanceWithRemoteLog (#3313) by Kaixuan Duan · 11 days ago
  32. 9f493fa [website] Add Security Updates table to security page (#3408) by Jark Wu · 12 days ago
  33. bb0694c [client] Initialize lake comparator before merge read (#3406) by yuxia Luo · 13 days ago
  34. 8e79903 [server] Optimize RemoteLogFetcher with async prefetch for recovery (#3132) by Kaixuan Duan · 14 days ago
  35. dd4d3fc org-names (#3380) by MehulBatra · 14 days ago
  36. 69eebd0 feat: [FLUSS-2686] Add COS filesystem support (#2836) by ForwardXu · 14 days ago
  37. ba1ce09 [server] Add request queue size metric per processor (#3232) by Junfan Zhang · 2 weeks ago
  38. e0f6cff [log] Output the leader server id and related table ids on fetching log failure (#2792) by Junfan Zhang · 2 weeks ago
  39. 7dd9e8e [server] make RemoteLogManifest sorted with startOffset (#3194) by Junfan Zhang · 2 weeks ago
  40. e736d9a [kv] Treat full-schema partial writes as full row for DefaultRowMerger (#3325) by Junfan Zhang · 2 weeks ago
  41. 02eb7a7 [website] Add how to host community call steps (#2760) by MehulBatra · 2 weeks ago
  42. 03d24f1 [flink] Preserve log-only source restore mode (#3355) by yuxia Luo · 2 weeks ago
  43. b2c4a84 [server]: prevent delete default database (#3312) by Yang Guo · 2 weeks ago
  44. 3d6abab [lake] Handle coordinator disconnect in TieringSourceEnumerator (#3107) by Uğur Tafralı · 2 weeks ago
  45. 32f66f3 [spark] Overwrite paimon dlf authentication configs by spark job level properties by Yang Zhang · 2 weeks ago
  46. aa965b3 [flink][spark] Fix partition pruning for non-string partition keys (#3322) by Anton Borisov · 2 weeks ago
  47. cc89a3d [docker] Add Apache Incubator disclaimer to Dockerfile (#3381) by Jark Wu · 2 weeks ago
  48. 68ad16c [FIP-37] Add bitmap infrastructure: BitmapUtils, RoaringBitmapSerializer, AbstractRbAggFunction (#3319) by Prajwal Banakar · 2 weeks ago
  49. 47cb7c2 [website] Clarify PPMC roles and responsibilities in become-a-committer.md by Jark Wu · 2 weeks ago
  50. e176dbb [client] cancel pending log download when closing remote log downloader. (#2786) by Hongshun Wang · 2 weeks ago
  51. 3b40406 [website] include maven links to specific plugins/connectors pages (#3377) by Anton Borisov · 2 weeks ago
  52. bccb79d [build] Add Apache Incubator disclaimer to Maven POM metadata (#3374) by Anton Borisov · 2 weeks ago
  53. 9fda385 [website] proper links for apache releases, strip maven jar links (#3373) by Anton Borisov · 2 weeks ago
  54. 667dec5 [website] Add verification section to donwload page (#3372) by Michael Koepf · 2 weeks ago
  55. 5d1e18f [lake/iceberg] Support ADD COLUMN schema evolution for Iceberg lake catalog (#2593) by Anton Borisov · 3 weeks ago
  56. 46f14cf [docs] Clarify auto partition retention alter support (#3339) by yuxia Luo · 3 weeks ago
  57. a70f96e [client] call_seq_id should start from zero for ScanKv open and continuation requests by Jark Wu · 3 weeks ago
  58. cce5467 [client] Extend the Java Client to support KvScan requests (#3295) by ipolyzos · 5 weeks ago
  59. 0bac627 [lake] Avoid aborting Paimon commit after failure (#3370) by yuxia Luo · 3 weeks ago
  60. d356cce [server] Integrate remote directory selector into table/partition creation (#2769) by Liebing · 3 weeks ago
  61. fca305f [server] Add disk-usage write protection to TabletServer (#3340) by yunhong · 3 weeks ago
  62. fd0211d [flink] Fix batch fallback generating mixed split types for primary-key tables (#3296) by Howie Wang · 3 weeks ago
  63. 85dba21 [spark] Allow specific plugin impl can use catalog config to overwrite default table prop (#3364) by Yang Zhang · 3 weeks ago
  64. dd11ec3 Update team (#3363) by xiaozhou · 3 weeks ago
  65. c89ba10 [lake/hudi] Introduce HudiBucketingFunction for bucket strategy (#3316) by fhan · 3 weeks ago
  66. 5dc14b9 [website] Update CSS for improved dark mode support and adjust hero section padding by Jark Wu · 3 weeks ago
  67. d7bbf50 [docs] remove the unused maputils rule (#3352) by Junfan Zhang · 3 weeks ago
  68. 522b1b4 [docs] Format SQL examples in security.md for improved readability by Jark Wu · 3 weeks ago
  69. 33730ed fix logo disappear from landing page when in dark mode (#3345) by Giannis Polyzos · 3 weeks ago
  70. c3c953b [Docs] Website Redesign (#3226) by Giannis Polyzos · 3 weeks ago
  71. 305a3a1 [flink] Fix COUNT(column) aggregate pushdown to reject nullable columns (#3271) by Junbo Wang · 4 weeks ago
  72. 4eb4414 [website] Update talks for openxdata summit (#3334) by MehulBatra · 4 weeks ago
  73. b6d0079 [spark] Use kv snapshot in lake-batch fallback (#3317) by Anton Borisov · 4 weeks ago
  74. c108476 [metric] Support influxdb reporter (#2839) by Tom · 4 weeks ago
  75. 170e95f [lake/hudi] Introduce fluss-lake-hudi module and HudiLakeStorage (#3256) by fhan · 4 weeks ago
  76. bff97fe [flink] introduce batched splits assignment mechanism (#3288) by Junfan Zhang · 4 weeks ago
  77. 3e0b71d Update team (#3310) by Liebing · 4 weeks ago
  78. 0ee5f17 [coordinator] Avoid altering lake catalog for tables that never enabled datalake (#3302) by Mahesh Sambaram · 4 weeks ago
  79. fcfeabd [docs] Fix duplicate titles in the Authentication section (#3199) by Tom · 4 weeks ago
  80. 56dc6de [server] Fix TabletServer fails to restart after unclean shutdown due to EOFException in log recovery (#2942) by Liebing · 5 weeks ago
  81. d4cd1a2 [server] Implement JBOD Phase 1 Local Multi-Directory Support (#3030) by hanliu0830 · 5 weeks ago
  82. 6b726d3 [website] Add contribution overview landing page by Jark Wu · 5 weeks ago
  83. e476514 [website] Add contribute a blog post guide (#3182) by Trevin Chow · 5 weeks ago
  84. 682b56e [flink] Avoid creating empty lake writer in TieringSplitReader (#3291) by yuxia Luo · 5 weeks ago
  85. f894a04 [spark] partition filter pushdown for non-lake log and kv tables (#3240) by Anton Borisov · 5 weeks ago
  86. c6a1c2d [kv] Implement KvScan on Server Side (#3151) by Giannis Polyzos · 5 weeks ago
  87. 71e6bb6 [lake/iceberg] Enhance IcebergSplitPlanner to only include filter column stats (#3237) by Junfan Zhang · 5 weeks ago
  88. de693bc [catalog] Preserve exception cause when rethrowing catalog exceptions (#3281) by ForwardXu · 5 weeks ago
  89. 0c50cba Update team (#3285) by Anton Borisov · 5 weeks ago
  90. af0e1bd [flink] Fix batch query on empty datalake-enabled table to return 0 rows instead of failing (#3208) by Howie Wang · 5 weeks ago
  91. cfa8098 [spark] lake table predicate pushdown (#3238) by Anton Borisov · 5 weeks ago
  92. 53732b0 [server] Add metrics of log startOffset (#3229) by Junfan Zhang · 5 weeks ago
  93. 570f09b [client] release pending fetch semaphore on discarding (#3043) by Junfan Zhang · 5 weeks ago
  94. 10a4c51 [ci] Optimize the log prompt of NoticeFileChecker (#3268) by Tom · 5 weeks ago
  95. e3a48fd [kv] Fix flaky KvTabletSnapshotTargetTest.testAddToSnapshotToStoreFail (#3264) by Kaixuan Duan · 5 weeks ago
  96. f706635 [flink] Implement SupportsWatermarkPushDown for FlinkTableSource (#2972) by Liebing · 5 weeks ago
  97. 38943d5 Revert "[fluss/ai agent] enable ai doc agent on website (#3152)" (#3216) by MehulBatra · 5 weeks ago
  98. c7878e8 [test] Fix flaky CoordinatorEventManagerTest by isolating metric group instance (#3252) by yunhong · 5 weeks ago
  99. 4985d42 [server] Add authorization to databaseExists and tableExists RPC call (#3078) by Vaibhav · 5 weeks ago
  100. 01c13e8 [kv] Support elect standby replicas for primary key table (#2829) by yunhong · 5 weeks ago