Google Git
Sign in
apache / fluss / HEAD
  1. 640f40c [server] Coordinator should reject the AdjustIsr request if the adjusted isr contains shutdown TabletServers (#1734) by yunhong · 10 hours ago main
  2. 47e3248 [lake] The bucket of PaimonSplit should be -1 for bucket unwared paimon table (#1732) by CaoZhen · 28 hours ago
  3. 058cf13 [lake/paimon] Support tiering paimon deletion vector enabled table (#1725) by yuxia Luo · 30 hours ago
  4. 221db5e [server] Introduce plugin.classloader.parent-first-patterns.additional configuration (#1222) by yuxia Luo · 30 hours ago
  5. 05458a3 [common] Change Cluster#getRandomTabletServer() to really random retrieve tabletServer (#1719) by yunhong · 2 days ago
  6. 79d9dbb [server] TabletServer support controlled shutdown (#1159) by yunhong · 2 days ago
  7. 67eefc4 [common] Fix serverConnection that has already been set to disconnected is still processing requests error (#1722) by yunhong · 4 days ago
  8. e1ff522 [common] Introduce AlignedRow for row data encoding (#1620) by Yang Wang · 4 days ago
  9. 69ba18e [hotfix] Add debug log for NettyServerHandler to trace the request process time (#1720) by yunhong · 4 days ago
  10. 9f0fbf5 [lake/iceberg] Iceberg read implementation supports filter push down (#1715) by Junbo Wang · 4 days ago
  11. a8cef41 [server] Updated Default RocksDB Log Directory to a separate directory (#1675) by Rion Williams · 5 days ago
  12. 2a3381b [hotfix] Add bucket info for error info while loading the stored index file (#1713) by Liebing · 5 days ago
  13. ece2fe3 [lake] Lake tiering service report the max timestamp of fluss record (#1700) by Liebing · 6 days ago
  14. 283b3b8 [client] Add result verification for the typed partition IT cases (#1714) by Jark Wu · 6 days ago
  15. baa53d9 [lake] LakeSourceSplit should be backcompatible (#1703) by CaoZhen · 6 days ago
  16. 164542f [lake/iceberg] Iceberg support union read for primary key table in streaming mode (#1708) by Junbo Wang · 6 days ago
  17. 340d955 [infra] Add hacktober GitHub tag (#1710) by MehulBatra · 7 days ago
  18. 5095236 [metrics] Adding Server-Level Storage Aggregation Metrics (#1548) by yunhong · 7 days ago
  19. 8449d47 [docs] Add Metrics Updates to the Upgrade Notes v0.8 (#1698) by yunhong · 7 days ago
  20. 05ab5e8 [server] Handle uncaught exceptions in TabletServer during log recovery from residual data corresponding to already dropped tables (#1487) by Yang Wang · 7 days ago
  21. 7f3b266 [hotfix] add tableBucket info for the print log while shrinking isr (#1704) by yunhong · 7 days ago
  22. 97d6f34 [client] Fix the MetadataRequest sent by LogFetcher timeout exception when upgrading cluster (#1666) by yunhong · 8 days ago
  23. e5f3ea7 [coordinator] Coordinator report event metrics of enqueue rate and event process time labeled by event_type (#1466) by Yang Wang · 8 days ago
  24. 776cb89 Issue 489 parition key more types apache (#1264) by Maggie Cao · 8 days ago
  25. 1f4ad5b [lake/iceberg] Support iceberg log table union read (#1684) by Junbo Wang · 8 days ago
  26. cbc083e [hotfix] Move Lance tests from alibaba package to apache (#1701) by Liebing · 8 days ago
  27. 4798022 [hotfix] Enhance the log of rebuildWriterState (#1618) by Liebing · 8 days ago
  28. 02a8f55 [docs] Update datalake related doc for support iceberg and lance (#1686) by CaoZhen · 8 days ago
  29. 8b9d293 [server] Use async zk operations to improve performance of CoordinatorServer initCoordinatorContext() (#1381) by xiaozhou · 8 days ago
  30. d6a01f5 [docs] Add Upgrade Notes for v0.8 (#1695) by Jark Wu · 8 days ago
  31. 6567deb [server] Fix ReplicaFetcherThread keeps throwing OutOfOrderSequenceException because of writer id expire (#1639) by Liebing · 8 days ago
  32. e6d877b [protogen] Fix infinite recursion in RecordsFieldFinder (#1282) by Yang Wang · 9 days ago
  33. 03313a9 [metric] Change some metrics from bucket-level to table-level and server-level (#1531) by xiaozhou · 11 days ago
  34. cb11779 [flink] Disable count push down for lake enabled table and catch exception when create lake source (#1679) by CaoZhen · 11 days ago
  35. cf5d24e [hotfix] Fix unstable testUnionReadLogTableFailover test (#1680) by yuxia Luo · 12 days ago
  36. 4c2ddc3 [flink] Add restore test for streaming union read pk table (#1674) by CaoZhen · 12 days ago
  37. 409a955 [hotfix] Paimon should always write bucket0 for bucket-unwared log table (#1661) by yuxia Luo · 12 days ago
  38. d863bb4 [flink] Add restore test for streaming union read log table (#1663) by CaoZhen · 13 days ago
  39. ee29bc4 [lake/iceberg] Add iceberg documents for lakehouse support in fluss (#1640) by MehulBatra · 13 days ago
  40. 5a7933c [lake/iceberg] Introduce IcebergRecordAsFlussRow for iceberg union read (#1672) by yuxia Luo · 13 days ago
  41. 517cf70 [server] Make ZK Partition and Table Assignment Deletion Asynchronous (#1477) by Liebing · 13 days ago
  42. 83dfdf1 [connector/flink] Throw Exception If catalog default database is not existed (#1608) by Hongshun Wang · 13 days ago
  43. a25c64b [log] Bump LogRecordBatch's CURRENT_LOG_MAGIC_VALUE to V1 to support leaderEpoch (#778) by yunhong · 13 days ago
  44. 231f1f7 [lake/iceberg] Add IT for Iceberg files compaction for primary key table (#1658) by Junbo Wang · 2 weeks ago
  45. 08758e9 [kv] Commit kv snapshot to zk should be done asynchronously and not block coordinator (#1375) by yuxia Luo · 2 weeks ago
  46. 49eeec1 [lake/lance] add documentation for Lance connector (#1587) by xx789 · 2 weeks ago
  47. 2c73e76 [kv] TabletSever must handle inconsistency or broken snapshot scenarios. (#1482) by Yang Wang · 2 weeks ago
  48. df77b5c [server] Add configuration options to disable PK or Log table creation (#1503) by Yang Wang · 2 weeks ago
  49. bc20370 [kv] coordinator must handle inconsistency or broken snapshot scenarios (#1470) by Yang Wang · 2 weeks ago
  50. a7bf007 [lake/iceberg] implement Iceberg log table compaction IT (#1651) by xx789 · 2 weeks ago
  51. 58292a0 [hotfix] Don't print waiting info in waitForNextWithTimeout & try to fix unstable testCreateAlreadyExistsLakeTable (#1650) by yuxia Luo · 3 weeks ago
  52. 5f61f47 [paimon] Avoid cast to KeyValueFileStore to get keyComparator in paimon (#1649) by Junbo Wang · 3 weeks ago
  53. 5c8f781 [flink] Union read support primary key table in streaming mode (#1613) by CaoZhen · 3 weeks ago
  54. 4a35533 [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() (#1638) by Junbo Wang · 3 weeks ago
  55. ab841ba [client] Change the default value of 'netty.client.num-network-threads' to 3 to avoid netty channel congestion (#1642) by yunhong · 3 weeks ago
  56. f0b697e [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics doc (#1611) by Junbo Wang · 3 weeks ago
  57. 3a48f6d [test/flink] Collect flink rows should always be with timeout (#1622) by yuxia Luo · 3 weeks ago
  58. 30dc6e3 [docs] Use a remote path instead of local path for "data.remote.dir" in distributed cluster guide (#1484) by leosanqing · 3 weeks ago
  59. dc3608c [blog] Publish the "PrimaryKey Tables" blog post (#1609) by Giannis Polyzos · 3 weeks ago
  60. 434a4f4 Change features to heading on 2nd level (#1623) by Michael Koepf · 3 weeks ago
  61. 1965b06 [lake] Introduce table.datalake.auto-compaction options (#1612) by xx789 · 4 weeks ago
  62. 5bd41ca [hotfix] Fix jar download links to alibaba path (#1614) by CaoZhen · 4 weeks ago
  63. 1f9de70 [flink] Union read in stream mode should support read from given timestamp (#1598) by yuxia Luo · 4 weeks ago
  64. dbbfc79 [lake/iceberg] Introduce IcebergRewriteDataFiles to compact files (#1552) by MehulBatra · 4 weeks ago
  65. 3d95c40 [docs] Fix the output result of the default merge engine example (#1551) by Rafael Sousa · 4 weeks ago
  66. 7937996 [flink] Union read support log table in streaming mode (#1575) by CaoZhen · 4 weeks ago
  67. faa0815 [iceberg] Upgrade iceberg version to 1.9.1 (#1520) by yuxia Luo · 4 weeks ago
  68. eb19eea [server] Enhance ReplicaManager#getReplicaOrException to return more accurate error messages (#1573) by Liebing · 4 weeks ago
  69. c57158c [server] Accelerate deleting table or partition (#1081) by xiaozhou · 4 weeks ago
  70. d378179 [hotfix] Fix unstable test IcebergTieringITCase (#1584) by yuxia Luo · 4 weeks ago
  71. c1dc8e3 [license] Remove unnecessary dependencies from NOTICE files by Jark Wu · 4 weeks ago
  72. b284d86 [license] Add rat-check to the mvn package phase and ban Alibaba license by Jark Wu · 4 weeks ago
  73. 5d70f00 [infra] Update package and groupId and spotless for org.apache.fluss by Jark Wu · 4 weeks ago
  74. bb0e12b [infra] Update project package name to org.apache.fluss by Jark Wu · 4 weeks ago
  75. 420194a [client] RemoteLogDownloader supports download log files in parallel and in priority (#1579) by Jark Wu · 4 weeks ago
  76. 4b14844 [lake/iceberg] add full data type integration test (#1577) by xx789 · 4 weeks ago
  77. 20549dc [hotfix] Fix import package name (#1585) by xx789 · 4 weeks ago
  78. 9cdc9b7 [lake/lance] Lance lake writer and committer implementation (#1441) by xx789 · 4 weeks ago
  79. f9e875d [common] Upgrade fluss-shaded to org.apache.fluss:1.0-incubating (#1494) by CaoZhen · 4 weeks ago
  80. f94f8e2 [flink] Support Flink 2.1 (#1176) by Hongshun Wang · 4 weeks ago
  81. ae7387e [lake/iceberg] Add iceberg it case (#1572) by yuxia Luo · 5 weeks ago
  82. 11a5c67 [server] force unmap mmap file on linux when call AbstractIndex.resize() (#1382) by yunhong · 5 weeks ago
  83. cf799e2 [hotfix] Modify file header to licensed to Apache Software Foundation (#1530) by yuxia Luo · 5 weeks ago
  84. 7eefe4a [flink] Apply partition filter to lake in flink source (#1549) by SeungMin · 5 weeks ago
  85. cc6c4e5 [client] Fluss Flink Lookup function return null rather than PartitionNotException when partition not exists. (#1344) by Hongshun Wang · 5 weeks ago
  86. c06affb [lake/iceberg] Support partitioned table (#1565) by yuxia Luo · 5 weeks ago
  87. 52936e9 [metric] fix a wrong metric calculation (#1566) by xiaozhou · 5 weeks ago
  88. 8a93663 [lake/iceberg] implement lake writer for iceberg pk table (#1555) by xx789 · 5 weeks ago
  89. c97813c [lake/iceberg] Support pass hadoop configuration (#1541) by yuxia Luo · 5 weeks ago
  90. 1a48571 [flink] Remove legacy union read code for batch mode (#1563) by Junbo Wang · 5 weeks ago
  91. 19073f8 [client] Fix the bug where the loss of writeBatch was caused by the origin batchLocation forget to update ServerNode info (#1258) by yunhong · 5 weeks ago
  92. eb3b5f8 [flink] Union read decouple with paimon for pk table (#1543) by Junbo Wang · 5 weeks ago
  93. 8317cd9 [hotfix] Fix typo: excepted -> expected and sever->server (#1557) by Junbo Wang · 5 weeks ago
  94. d4dfb45 [Iceberg/lake] Iceberg supports append-only non-partitioned table (#1524) by MehulBatra · 6 weeks ago
  95. 49d6ae8 [lake/Iceberg] Support use type to load iceberg catalog (#1536) by jackylee · 6 weeks ago
  96. 4cf486d [flink] Union read decouple with paimon for log table (#1527) by CaoZhen · 6 weeks ago
  97. 1c358ef [lake] pass table custom table property to lake writer (#1521) by xx789 · 6 weeks ago
  98. ac1569c [lake/iceberg] Support Log Table in IcebergLakeCatalog (#1508) by SeungMin · 6 weeks ago
  99. 17d69ff [lake/lance] Throw exception for create primary key table when datalake.format = lance (#1444) by naivedogger · 6 weeks ago
  100. d2dc98f [lake] Store partition name in lake snapshot property (#1485) by yuxia Luo · 6 weeks ago