Skip to content

Apache Fluss 0.8.0

Latest

Choose a tag to compare

@wuchong wuchong released this 06 Nov 04:00
· 62 commits to main since this release
v0.8.0-incubating
c18e53e

What's Changed

  • [Docs] Add embedded Google calendar for community events by @michaelkoepf in #1089
  • [hotfix] Fix data freshness don't work issue by @luoyuxia in #1090
  • [docs] Add show partitions by given partition spec ddl in ddl.md by @swuferhong in #1093
  • [row] improve test on VectorizedColumnBatch by @gyang94 in #1049
  • [server] Fix Sasl's createPrincipal mismatch username and type by @loserwang1024 in #1099
  • [test] Fix unstable test cases in FlussAuthorizationITCase by @swuferhong in #1102
  • [minor][lake] Set default name for flink tiering service job by @leonardBang in #1105
  • [lake/paimon] Fix than tiering service for paimon missed timestampNtz support by @leonardBang in #1122
  • [lake/docs] Update paimon integration docs in lakehouse section by @leonardBang in #1113
  • [lake/paimon] Fix union read timestamp type issue (#1128) by @luoyuxia in #1130
  • minor paimon page improvements by @polyzos in #1133
  • Add a use cases section in the introduction page by @polyzos in #1134
  • [flink] Move Factory tests which depends on different version of Flink frameworks to submodule by @loserwang1024 in #1132
  • [lake/docs] Update lakehouse storage pages to adapt to new architecture by @luoyuxia in #1139
  • [docs] Add security documents including authentication and authorization. by @loserwang1024 in #1060
  • [hotfix] Add isClosed protect for LogFetcher#handleFetchLogException to avoid throw exception if channel close by @swuferhong in #1107
  • Fluss 0.7 Release Announcement by @polyzos in #1137
  • Update source files use the standard Apache boilerplate headers by @wuchong in #1147
  • [test] Expose Clock to FlussClusterExtension. by @loserwang1024 in #1136
  • Add quickstart: Secure Your Fluss Cluster by @loserwang1024 in #1108
  • [docs]Fix: Fix the formatting error of the coordinator.io-pool.size parameter table in the configuration document by @ZmmBigdata in #1169
  • [doc] Add tips for building fluss with Java 8 by @leonardBang in #1177
  • [connector] pass Fluss schema to lake writer by @xx789633 in #1192
  • [test/flink] Se forkCount=1 for versioned flink e2e tests by @leonardBang in #1179
  • [test/flink] Cover full data types in UnionRead tests and polish some tests by @naivedogger in #1167
  • [doc]The type of Sink is incorrect. FinkSink is not public and cannot be referenced from outside the package by @ZmmBigdata in #1196
  • [docs] fix small typo in security comments by @polyzos in #1199
  • [website] Fix the formatting for other options by @MehulBatra in #1202
  • [doc]The deletion operation requires the equivalence condition of the primary key by @ZmmBigdata in #1201
  • [website] add agenda doc link in the community page by @MehulBatra in #1211
  • [server] Fix zk partition residual when using dynamic partition by @zcoo in #1187
  • [doc]Without switching the query mode of FlinkSQL, an exception will be thrown when deleting data from the fluss primary key table by @ZmmBigdata in #1189
  • [docs] Add docs for racks by @swuferhong in #1148
  • hotfix: typo by @gyang94 in #1174
  • [Website] Remove version from "Building Fluss from Source" by @michaelkoepf in #1164
  • [git] update the latest release version & change the task/feature description by @MehulBatra in #1218
  • [server] Avoid memory copy when follower fetch log from leader by @swuferhong in #1186
  • [hotfix] fix typos in getting-started.md by @yx91490 in #1223
  • [hotfix] Fix the missing brackets in java-client.md by @LiebingYu in #1225
  • [website][docs] Make figures consistent by @michaelkoepf in #1236
  • [doc]Remove 'testcatalog'. 'testdb' from the ddl statement by @ZmmBigdata in #1234
  • [doc]Adjust ddl.md document structure by @ZmmBigdata in #1232
  • [doc]: add download link for tiering service jar by @gyang94 in #1229
  • [doc]The DDL and DQL column names in the context do not match by @ZmmBigdata in #1190
  • [doc]Code structure issues by @ZmmBigdata in #1240
  • Add exception in throwable in lake writer & committer by @polyzos in #1254
  • [blog]: tiering service deep dive by @gyang94 in #1249
  • [lake] Ensure LakeStoragePlugin uses the plugin classloader for all operations by @beryllw in #1224
  • [website] Add apache mailing list info for community by @MehulBatra in #1250
  • [server] Optimize auto drop partition perfomance by @LiebingYu in #1047
  • [HotFix] Class name for logger in RemoteLogIndexCache by @polyzos in #1265
  • [hotfix] Fix typo in server.yaml by @XianmingZhou00 in #1277
  • [client] Fluss client shouldn't load plugin by thread context classloader. by @loserwang1024 in #1267
  • [website] Learn page for talks & videos draft version by @MehulBatra in #1278
  • [Docs] Coordinator event metrics by @zcoo in #1272
  • [File system] Add HuaweiCloud OBS integration by @andybj0228 in #1274
  • [website] update roadmap to account latest requirements by @MehulBatra in #1214
  • [website] create a seperate page for bug report & feature request by @MehulBatra in #1213
  • [blog] Fluss java client guide by @polyzos in #1253
  • Add Fluss ASF Blog Post by @polyzos in #1288
  • [docs] Fix typo in configuration.md by @xiedeyantu in #1300
  • rename fluss to Apache Fluss(Incubating) in readme by @polyzos in #1263
  • [website] Fix community call phrase by @MehulBatra in #1308
  • [website] Fix blog post author titles by @michaelkoepf in #1309
  • [debug] Add coordinator event debug log by @zcoo in #1296
  • Bump org.apache.commons:commons-lang3 from 3.12.0 to 3.18.0 by @dependabot[bot] in #1310
  • [coordinator] add retry for Coordinator Server when register to zk by @zcoo in #1307
  • Limit read permission to license-check.yml workflow by @wuchong in #1312
  • Bump org.apache.kafka:kafka-clients from 3.9.0 to 3.9.1 in /fluss-kafka by @dependabot[bot] in #1294
  • [build] update vcs.xml link addr by @totalo in #1293
  • Potential fix for code scanning alert no. 5: Implicit narrowing conversion in compound assignment by @wuchong in #1313
  • [hotfix] fix error word commitable to committable. by @zhuangchong in #1318
  • [doc]Remove redundant statement terminators in the reads document by @ZmmBigdata in #1336
  • [doc]Modify the table format in the pk-table document by @ZmmBigdata in #1335
  • [docs] update apache fluss slack link by @MehulBatra in #1316
  • [CI] add apache rat for license check of non java files by @MehulBatra in #1219
  • set up fluss-lake-iceberg module and IcebergLakeStorage by @xx789633 in #1339
  • [hotfix] Optimize the error msg when throwing LogOffsetOutOfRangeException by @swuferhong in #1216
  • [docs][blog] fix: blog url and image by @gyang94 in #1349
  • [kv] upgrade rocksdb to community version 10.2.1 by @platinumhamburg in #1338
  • Fluss admin use tablet server for read only operation to reduce the cost of coordinator. by @loserwang1024 in #1303
  • [Docs] consistency & syntax fixes by @polyzos in #1243
  • [hotfix] The DiscardingSink operator after LakeCommitter should always be with parallelism 1 by @luoyuxia in #1356
  • [filesystem] Exclude com.alibaba.fluss.fs.hdfs.HadoopFsPlugin from META-INF for fluss-fs-oss plugin by @MaheshS08 in #1342
  • [filesystem] Exclude com.alibaba.fluss.fs.hdfs.HadoopFsPlugin from META-INF for fluss-fs-gs plugin by @beryllw in #1334
  • [filesystem] Exclude com.alibaba.fluss.fs.hdfs.HadoopFsPlugin from META-INF for fluss-fs-obs plugin by @yunchipang in #1351
  • [website] Update Website According to ASF Requirements by @michaelkoepf in #1251
  • [filesystems] Exclude com.alibaba.fluss.fs.hdfs.HadoopFsPlugin from M… by @zhaozijun109 in #1348
  • [website] Add link to slides for talks by @michaelkoepf in #1373
  • [bug fix] decouple the serializer version of PaimonWriteResult and PaimonCommittable by @xx789633 in #1368
  • Revert "[kv] Upgrade rocksdb to community version 10.2.1 (#1338)" by @platinumhamburg in #1374
  • Bump Paimon version from 1.0.1 to 1.2.0 by @caozhen1937 in #1289
  • fix: Update GitHub link in HomepageHeader by @ZmmBigdata in #1343
  • [lake/iceberg] Iceberg encoding strategy by @MehulBatra in #1350
  • [doc]Remove the extra period at the end of the sentence by @ZmmBigdata in #1384
  • [doc] fix typos, formatting and consistency in architecture.md by @ZmmBigdata in #1390
  • [doc] fix typo in flink.md by @ZmmBigdata in #1387
  • [doc]The SQL keywords are not consistent in case. It is recommended to use uppercase letters uniformly by @ZmmBigdata in #1385
  • [blog]: hands on fluss lakehouse by @gyang94 in #1279
  • [docs] move the directory and website links to apache by @MehulBatra in #1366
  • [docs] fix: code block render issue by @gyang94 in #1395
  • [flink] FlinkSourceSplitReader sends PartitionBucketsUnsubscribedEvent to FlinkSourceEnumerator when subscribing to a removed partition by @platinumhamburg in #1248
  • [docs] refactor blog title and wording by @gyang94 in #1403
  • [typo] fix typos waitUtil-> waitUntil by @zcoo in #1402
  • [docs] Fix warehouse path of paimon inconsistent in lakehouse-storage page by @luoyuxia in #1426
  • [typo] Fix typo in Scheduler.java by @XianmingZhou00 in #1413
  • [connector] introduce lance connector and implement lake catalog by @xx789633 in #1242
  • rename fluss-benchmark directoy to fluss-jmh by @xx789633 in #1430
  • [docs] Fix: Correct column specification in T table INSERT statements by @ZmmBigdata in #1406
  • [doc] fix typos, format in deploying-local-cluster.md by @ZmmBigdata in #1393
  • [doc] fix typos, format in installation overview by @ZmmBigdata in #1391
  • [doc] fix some docs of prefix lookup api by @caozhen1937 in #1447
  • [docs] Add info around community resources including notes and recording by @MehulBatra in #1449
  • [website] Fix image and description metadata of website pages by @wuchong in #1440
  • [website] Adapt website for the blocked third-party resources by @wuchong in #1439
  • [blog] Fix text format of "Tiering Service Deep Dive" by @LiebingYu in #1411
  • store lake synchronized bucket offsets in Paimon snapshot property by @xx789633 in #1405
  • [webiste] Allow YouTube, Google Calendar and Algolia Resources on Fluss Website by @wuchong in #1453
  • [typo] fix typos commited -> committed by @xiaochen-zhou in #1457
  • [doc] Update the copyright name in the documentation from "Alibaba" to "Apache" by @beryllw in #1418
  • [coordinator] optimize coordinator event metric update logic by @platinumhamburg in #1465
  • [docs]fix typos, grammar, casing, and spacing in multiple documents by @ZmmBigdata in #1474
  • Fix the typo in the comment of TableBucketStateMachine#doHandleStateChange by @LiebingYu in #1488
  • [server] Prohibit the creation of TableAssignment with zero buckets by @LiebingYu in #1489
  • Fix typo in "From Stream to Lake" blog by @luoyuxia in #1490
  • [common]Introduce Predicate to do filter and partition push down. by @Alibaba-HZY in #515
  • Introduce Union read base interfaces by @beryllw in #1480
  • [doc] fix: docs about TIMESTAMP_LTZ by @gyang94 in #1416
  • [iceberg]feat: iceberg bucketing function by @gyang94 in #1409
  • [server] Add rack label for tablet server metrics by @LiebingYu in #1468
  • [website] Add How to Release and Verify for fluss-shaded releases by @wuchong in #1500
  • [common] Fix Serialize BinaryString throws NotSerializableException by @wuchong in #1496
  • [docs] Add a section for hadoop related configuration by @caozhen1937 in #1501
  • [lake/iceberg] Implement IcebergLakeCatalog for PK Tables by @MehulBatra in #1372
  • [server] Valid value of LOG_SEGMENT_FILE_SIZE by @LiebingYu in #1504
  • [server] Use batch operations of ZooKeeper to optimize updateLeaderAndIsr by @LiebingYu in #1446
  • [build] Upgrade JDK compile version as 11 by @loserwang1024 in #1197
  • Paimon implement read interfaces by @beryllw in #1505
  • [paimon] Paimon source supports filter push down by @luoyuxia in #1523
  • [blog] The Implementation Practice Of Fluss On Taotian by @caozhen1937 in #1414
  • [hotfix] Optimize the createLogicalScope method by adding empty groupName checks to avoid unnecessary delimiter concatenation. by @pisceslj in #1363
  • [log] Fix the recovery log failed situation because of OutOfOrderSequenceException cause by writerId expire by @swuferhong in #1386
  • [lake] Store partition name by @luoyuxia in #1485
  • [lake/lance] Throw exception for create primary key table when datalake.format = lance by @naivedogger in #1444
  • [lake/iceberg] Support Log Table in IcebergLakeCatalog by @SML0127 in #1508
  • [lake] pass table custom table property to lake writer by @xx789633 in #1521
  • Union read decouple with paimon for log table by @caozhen1937 in #1527
  • [lake/Iceberg][MIRROR] Change the way to load Iceberg Catalog by @jackylee-ch in #1536
  • [Iceberg/lake] Iceberg append-only lake writer-commiter for non-partitioned/non-compacted by @MehulBatra in #1524
  • [server] Fix typo: excepted -> expected and sever->server by @beryllw in #1557
  • [flink] Union read decouple with paimon for pk table by @beryllw in #1543
  • [client] Fix the bug where the loss of writeBatch was caused by the origin batchLocation forget to update ServerNode info by @swuferhong in #1258
  • [flink] Remove legacy union read code for batch mode by @beryllw in #1563
  • [lake/iceberg] Support pass hadoop configuration by @luoyuxia in #1541
  • [lake/iceberg] implement lake writer for iceberg pk table by @xx789633 in #1555
  • [metric] fix a wrong metric calculation by @zcoo in #1566
  • [lake/iceberg] Support partitioned table by @luoyuxia in #1565
  • Fluss Flink Lookup function return null rather than PartitionNotException if paritition not exists. by @loserwang1024 in #1344
  • Apply partition filter to lake in flink source by @SML0127 in #1549
  • [hotfix] Modify file header to licensed to Apache Software Foundation by @luoyuxia in #1530
  • [server] force unmap mmap file on linux when call AbstractIndex.resize() by @swuferhong in #1382
  • [lake/iceberg] Add iceberg it case by @luoyuxia in #1572
  • [flink] Support flink 2.1 by @loserwang1024 in #1176
  • Upgrade fluss-shaded to org.apache.fluss:1.0-incubating by @caozhen1937 in #1494
  • [connector] Lance lake writer and committer implementation by @xx789633 in #1441
  • [hotfix] fix Lance connector import package name by @xx789633 in #1585
  • [lake/iceberg] add full data type integration test by @xx789633 in #1577
  • [client] RemoteLogDownloader supports download log files in parallel and in priority by @wuchong in #1579
  • [infra] Updated project package name to org.apache.fluss by @wuchong in #1589
  • [hotfix] Fix unstable test IcebergTieringITCase by @luoyuxia in #1584
  • [server] Accelerate deleting table or partition by @zcoo in #1081
  • [server] Enhance ReplicaManager#getReplicaOrException to return more accurate error messages by @LiebingYu in #1573
  • [iceberg] Upgrade iceberg version to 1.9.1 by @luoyuxia in #1520
  • Union read support log table in streaming mode by @caozhen1937 in #1575
  • [docs] Update partitioning and merge documentation by @rafaelsmf in #1551
  • [lake/iceberg] Introduce IcebergRewriteDataFiles to compact files by @MehulBatra in #1552
  • [flink] Union read in stream mode should support read from given timestamp by @luoyuxia in #1598
  • [hotfix] Fix jar download links to alibaba path by @caozhen1937 in #1614
  • add table.datalake.auto-compaction options by @xx789633 in #1612
  • [hotfix] Fix README by @michaelkoepf in #1623
  • Pk tables blog post by @polyzos in #1609
  • [docs][Fluss-1483] Fix distributed mode guide, cannot set local path by @leosanqing in #1484
  • [test/flink] Collect flink rows should always be with timeout by @luoyuxia in #1622
  • [docs] Add FETCH_LOG monitoring metrics to Fluss monitor-metrics doc by @beryllw in #1611
  • [client] Change the default value of 'netty.client.num-network-threads' to 3 to avoid netty channel congestion by @swuferhong in #1642
  • [flink] Improve TableAlreadyExistException message for LakeCatalog.createTable() by @beryllw in #1638
  • Union read support primary key table in streaming mode by @caozhen1937 in #1613
  • [lake] Avoid cast to KeyValueFileStore to get keyComparator in paimon by @beryllw in #1649
  • [hotfix] Don't print waiting info in FlinkRowAssertionsUtils.waitForN… by @luoyuxia in #1650
  • [lake/iceberg] implement Iceberg log table compaction IT by @xx789633 in #1651
  • [kv] coordinator must handle inconsistency or broken snapshot scenarios by @platinumhamburg in #1470
  • Add configuration options to control table creation restrictions by @platinumhamburg in #1503
  • [kv] TabletSever must handle inconsistency or broken snapshot scenarios. by @platinumhamburg in #1482
  • [lake/lance] add documentation for Lance connector by @xx789633 in #1587
  • [kv] commit kv snapshot to zk asynchronously, not blocking coordinato… by @luoyuxia in #1375
  • Add IT for Iceberg files compaction for primary key table by @beryllw in #1658
  • Bump LogRecordBatch's CURRENT_LOG_MAGIC_VALUE to V1 to support leaderEpoch by @swuferhong in #778
  • Throw Exception If catalog default database is not existed . by @loserwang1024 in #1608
  • Use background mode for delete partition assignment in zk by @LiebingYu in #1477
  • [lake/iceberg] Introduce IcebergRecordAsFlussRow for iceberg union read by @luoyuxia in #1672
  • [lake/iceberg] Add iceberg documents for lakehouse support in fluss by @MehulBatra in #1640
  • [flink] Add restore test for streaming union read log table by @caozhen1937 in #1663
  • [hotfix] Paimon should always write bucket0 for bucket-unwared log table by @luoyuxia in #1661
  • [flink] Add restore test for streaming union read pk table by @caozhen1937 in #1674
  • [hotfix] Fix unstable testUnionReadLogTableFailover test by @luoyuxia in #1680
  • [flink] Disable count push down for lake enabled table and catch exce… by @caozhen1937 in #1679
  • [metric] metrics aggregation by @zcoo in #1531
  • [bug fix] Avoid infinite recursion in RecordsFieldFinder by @platinumhamburg in #1282
  • [server] Fix ReplicaFetcherThread keeps throwing OutOfOrderSequenceException because of writer id expire by @LiebingYu in #1639
  • [docs] Add Upgrade Notes for 0.8 by @wuchong in #1695
  • [server] improve performance of Coordinator Server initCoordinatorContext() by @zcoo in #1381
  • [docs] Update datalake related doc for support iceberg and lance by @caozhen1937 in #1686
  • [hotfix] Enhance the log of rebuildWriterState by @LiebingYu in #1618
  • [hotfix] Move Lance tests from alibaba package to apache by @LiebingYu in #1701
  • [lake/iceberg] Support iceberg log table union read by @beryllw in #1684
  • Issue 489 parition key more types apache by @MaggieSullivan in #1264
  • [coordinator] coordinator report event enqueue rate and event process time labeled by event_type by @platinumhamburg in #1466
  • [client] Fix the MetadataRequest sent by LogFetcher timeout exception when upgrading cluster by @swuferhong in #1666
  • [hotfix] add tableBucket info for the print log while shrinking isr by @swuferhong in #1704
  • [server] handle uncaught exceptions in TabletServer during log recovery from residual data corresponding to already dropped tables by @platinumhamburg in #1487
  • [docs] Add Metrics Updates to the Upgrade Notes by @swuferhong in #1698
  • [metrics] Adding Server-Level Storage Aggregation Metrics by @swuferhong in #1548
  • [git/repo] add hacktober tag by @MehulBatra in #1710
  • [lake/iceberg] Iceberg support union read for primary key table in streaming mode by @beryllw in #1708
  • [lake] LakeSourceSplit should be backcompatible by @caozhen1937 in #1703
  • [client] Add result verification for the typed partition IT cases by @wuchong in #1714
  • [server] Lake tiering service report the max timestamp of fluss record by @LiebingYu in #1700
  • [hotfix] Add bucket info for error info while loading the stored index file by @LiebingYu in #1713
  • [FLUSS-1542] Updated Default RocksDB Log Directory by @rionmonster in #1675
  • [lake/iceberg] Iceberg read implementation supports filter push down by @beryllw in #1715
  • [hotfix] Add debug log for NettyServerHandler to trace the request process time by @swuferhong in #1720
  • Introduce AlignedRow for row data encoding by @platinumhamburg in #1620
  • [common] Fix serverConnection that has already been set to disconnected is still processing requests error by @swuferhong in #1722
  • [Server] TabletServer support controlled shutdown by @swuferhong in #1159
  • [common] Change Cluster#getRandomTabletServer() to really random retrieve tabletServer by @swuferhong in #1719
  • [server] Introduce plugin.classloader.parent-first-patterns.additional configuration by @luoyuxia in #1222
  • [lake/paimon] Support tiering paimon deletion vector enabled table by @luoyuxia in #1725
  • [lake] The bucket of PaimonSplit should be -1 for bucket unwared paim… by @caozhen1937 in #1732
  • [server] Coordinator reject the adjustIsr request if the expected adjusted isr contains shutdown tabletServers by @swuferhong in #1734
  • [filesystem] Not bundle obs & gfs into fluss dist by @caozhen1937 in #1737
  • [flink] lake tiering support flink 1.18 by @beryllw in #1742
  • [filesystems/hdfs] Publish Bundled HDFS Artifact by @beryllw in #1522
  • [doc] Add streaming union read part for paimon document by @luoyuxia in #1747
  • [server] feat: support alter table properties by @gyang94 in #1625
  • [hotfix] Add bucket info for bucket related logs by @LiebingYu in #1750
  • [hotfix] Add prefix of table_bucket_logicalStorage in monitor-metrics.md by @swuferhong in #1758
  • [metrics] Add partition count metrics for tables and cluster monitoring by @buvb in #1662
  • [hotfix] Also deploy fluss-fs-hadoop by @luoyuxia in #1757
  • [server] Improve the implementation of ALTER TABLE by @wuchong in #1760
  • [hotfix] Revert CURRENT_LOG_MAGIC_VALUE to LOG_MAGIC_VALUE_V0 for compatibility higher version client with lower version server by @swuferhong in #1743
  • [server] server process metadata request in async mode by @platinumhamburg in #1463
  • [flink]Support partition pushdown for more filters in Flink connector by @Alibaba-HZY in #420
  • [flink] Fluss enumerator partition discovery in fixed delay rather than fixed rate. by @loserwang1024 in #1633
  • [client] Fix exception occurs when initializing server connection. by @loserwang1024 in #1740
  • [flink] Support delta join on Flink 2.1 by @xuyangzhong in #1726
  • [lake] Introduce lake lag metrics for datalake enabled table by @caozhen1937 in #1729
  • [Filesystem] Support use Hadoop dependencies from environment variables HADOOP_CLASSPATH by @beryllw in #1359
  • [client] Set the default value of 'scan.partition.discovery.interval' to 1min to reduce the server load by @swuferhong in #1736
  • [KV] Avoid TabletServer to discard already commited kv snapshot by @platinumhamburg in #1738
  • [server] feat: support alter table.datalake.enabled by @gyang94 in #1753
  • [hotfix] Refactor fluss-offsets naming in lake snapshot to align with origin design by @luoyuxia in #1772
  • [hotfix] Fix commit bugs of iceberg and improve document by @luoyuxia in #1770
  • [lake] Paimon lake table support alter table properties by @LiebingYu in #1754
  • [docs][lake/iceberg] Add a part about streaming union read in icebeg doc by @beryllw in #1774
  • [filesystems/hdfs][follow] fix hadoop-common dependency version by @beryllw in #1755
  • [flink] FlinkCatalog supports create and drop materialized table by @lsyldliu in #862
  • [server] feat: support multiple table change types by @gyang94 in #1766
  • [Client] Add PojoConverterUtils by @polyzos in #1404
  • [server] Update ApiKey: ALTER_TABLE_PROPERTIES to ALTER_TABLE by @wuchong in #1779
  • [docs] Automatically update the code of the fluss repository on deepwiki by @caozhen1937 in #1728
  • [FIP-12] add dynamic config to enable lakehouse. by @loserwang1024 in #1567
  • [docs] Add docs for flink materialized table by @lsyldliu in #1798
  • 1794 : Add graceful shutdown documentation by @hemanthsavasere in #1796
  • [hotfix] Fix auto partitioning link for TTL page by @LiebingYu in #1785
  • [hotfix] fix some typos by @beryllw in #1790
  • [build] Introduce flink-quickstart docker file by @luoyuxia in #1759
  • [flink] Supports get iceberg lake table by @beryllw in #1799
  • improve: add detailed context to exception messages by @CodeDrinks270 in #1806
  • [fluss-flink] support for $lake table for iceberg lakehouse by @MehulBatra in #1812
  • [Docs] Fluss/flink - Iceberg quickstart guide by @MehulBatra in #1800
  • [flink] Optimize the getLakeTableFactory in LakeTableFactory by @luoyuxia in #1816
  • [hotfix] Fix iceberg doc display by @luoyuxia in #1818
  • [lake] Paimon lake table support non-string partition keys by @LiebingYu in #1817
  • [helm] Add a helm chart for Fluss #779 by @dreger1997 in #1685
  • [hotfix] Tiering Source Enumerator should clear pending split when failover by @luoyuxia in #1820
  • [hotfix][flink] Use mini operation scope of MaterializedTableChange. by @loserwang1024 in #1808
  • [hotfix] Make lake catalog as protected by @luoyuxia in #1823
  • [lake] Avoid create/drop connection frequently in TieringSourceReader by @luoyuxia in #1828
  • [hotfix][docs] Add steps to avoid import star by @snuyanzin in #1840
  • [hotfix][tests] Fix unstable test IcebergRecordReaderTest#testReadLogTable by @snuyanzin in #1837
  • [hotfix][docs] Update README about java 8 by @snuyanzin in #1838
  • [hotfix][build] Add distributionSha256Sum check for maven wrapper by @snuyanzin in #1841
  • [lake/paimon] Prohibit users from setting Paimon properties that Fluss depends on by @LiebingYu in #1826
  • [lake/iceberg] thrown Exception when partition columns are of non-String type by @beryllw in #1831
  • Make controlled shutdown parameters configurable by @hemanthsavasere in #1830
  • [server] Forbid any table/partition creation that begins with __ by @caozhen1937 in #1706
  • [build] Docker image dependencies for flink/fluss iceberg quickstart by @MehulBatra in #1813
  • [docs] Use FLUSS_VERSION instead of hardcode to 0.7-SNAPSHOT in security.md by @luoyuxia in #1846
  • [docs] Fix typos streaming lakehouse page by @rafaelsmf in #1581
  • Support table.delete.behavior config to disable or ignore deletion on… by @caozhen1937 in #1783
  • [docs] Add lake tiering behavior changes to upgrade notes by @luoyuxia in #1761

New Contributors

Full Changelog: v0.7.0...v0.8.0-incubating