This is an automated email from the ASF dual-hosted git repository.
jark pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/fluss.git
from ffe7da0e2 docs: updated Flink SQL Client startup and cluster shutdown
instructions (#2522)
add 3a803dfd8 [lake] Fix lake encoder causing prefix lookup to miss data
when bucket key is a subset of primary key (#2464)
No new revisions were added by this update.
Summary of changes:
.../fluss/client/lookup/PrefixKeyLookuper.java | 41 +++++++-
.../fluss/client/lookup/PrimaryKeyLookuper.java | 12 ++-
.../client/table/writer/AppendWriterImpl.java | 10 +-
.../client/table/writer/UpsertWriterImpl.java | 13 ++-
.../fluss/client/admin/FlussAdminITCase.java | 37 ++++---
.../client/table/AutoPartitionedTableITCase.java | 11 +-
.../fluss/client/table/FlussLakeTableITCase.java | 100 ++++++++++++++----
.../fluss/client/table/FlussTableITCase.java | 47 ++++++---
.../batch/KvSnapshotBatchScannerITCase.java | 6 +-
.../fluss/client/write/HashBucketAssignerTest.java | 3 +-
.../org/apache/fluss/config/ConfigOptions.java | 24 +++++
.../java/org/apache/fluss/config/TableConfig.java | 9 ++
.../org/apache/fluss/row/encode/KeyEncoder.java | 81 ++++++++++++++-
.../flink/sink/FlinkRowDataChannelComputer.java | 2 +-
.../shuffle/StatisticsOrRecordChannelComputer.java | 2 +-
.../fluss/flink/catalog/FlinkCatalogITCase.java | 4 +
.../sink/shuffle/PartitionAssignmentTest.java | 3 +-
.../flink/tiering/source/TieringTestBase.java | 6 +-
.../fluss/flink/utils/CatalogTableTestUtils.java | 2 +
.../flink/FlinkUnionReadPrimaryKeyTableITCase.java | 69 +++++++++++++
.../org/apache/fluss/rpc/protocol/ApiKeys.java | 20 +++-
.../server/coordinator/CoordinatorService.java | 24 +++++
.../apache/fluss/server/kv/KvRecoverHelper.java | 9 +-
.../org/apache/fluss/server/replica/Replica.java | 6 ++
.../fluss/server/replica/ReplicaManager.java | 53 +++++++++-
.../apache/fluss/server/tablet/TabletService.java | 3 +
.../server/coordinator/TableManagerITCase.java | 26 +++--
.../fluss/server/replica/ReplicaManagerTest.java | 115 ++++++++++++++++++++-
website/docs/engine-flink/options.md | 57 +++++-----
.../maintenance/operations/upgrade-notes-0.8.md | 2 +
.../maintenance/operations/upgrade-notes-0.9.md | 39 +++++++
.../operations/upgrade-notes-archive.md | 11 ++
32 files changed, 721 insertions(+), 126 deletions(-)
create mode 100644 website/docs/maintenance/operations/upgrade-notes-archive.md
