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 eb3b5f8ab [flink] Union read decouple with paimon for pk table (#1543)
add 19073f809 [client] Fix the bug where the loss of writeBatch was caused
by the origin batchLocation forget to update ServerNode info (#1258)
No new revisions were added by this update.
Summary of changes:
.../com/alibaba/fluss/client/admin/FlussAdmin.java | 50 +++++++++----------
.../alibaba/fluss/client/lookup/LookupSender.java | 6 +++
.../fluss/client/metadata/MetadataUpdater.java | 18 ++++---
.../fluss/client/table/scanner/TableScan.java | 1 -
.../table/scanner/batch/LimitBatchScanner.java | 7 ++-
.../fluss/client/table/scanner/log/LogFetcher.java | 16 ++-----
.../client/table/scanner/log/LogScannerImpl.java | 3 --
.../alibaba/fluss/client/utils/MetadataUtils.java | 28 ++++-------
.../fluss/client/write/RecordAccumulator.java | 35 +++++++-------
.../com/alibaba/fluss/client/write/Sender.java | 15 +++---
.../client/metadata/TestingMetadataUpdater.java | 23 ++++++---
.../client/table/scanner/log/LogFetcherTest.java | 2 -
.../fluss/client/write/RecordAccumulatorTest.java | 56 ++++++++++++++--------
.../com/alibaba/fluss/client/write/SenderTest.java | 2 +-
.../write/StickyStaticBucketAssignerTest.java | 23 +++++----
.../com/alibaba/fluss/cluster/BucketLocation.java | 32 +++++++------
.../java/com/alibaba/fluss/cluster/Cluster.java | 5 +-
.../alibaba/fluss/cluster/BucketLocationTest.java | 5 +-
.../com/alibaba/fluss/cluster/ClusterTest.java | 31 +++++++-----
19 files changed, 190 insertions(+), 168 deletions(-)
