This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-18739
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from f3dd06b6d9 Review fixes 2
add 6394d32d8c Review fixes 3
add c47686b1b5 Review fixes 3
add 08e5d52b72 IGNITE-18802 Fix (#1707)
add 61f4904edd IGNITE-18810 Java client: Balance requests across
connections (#1701)
add c276a334c4 IGNITE-17056 Added design documents for rebalance
cancellation. Fixes #1676
add de1ee322a7 IGNITE-18814 Fix
ItTxDistributedTestSingleNode#assertPartitionsSame (#1689)
add eeb8b898ec IGNITE-18866 JdbcUrlRegistryImpl should stop fetching URLs
after disconnect (#1702)
add d071242834 IGNITE-18827: Sql. UUID. Implement min/max functions.
(#1686)
add 7459327ca0 IGNITE-18861 NPE in DumpThreadsOnTimeout extension (#1705)
add 24de97894c IGNITE-18843 Fix the behavior of
MvPartitionStorage#pollForVacuum when trying to delete the same row in parallel
(#1697)
add 18c9c0b1ec Merge branch 'main' into ignite-18739
add da2161d9f4 Review fixes 3
No new revisions were added by this update.
Summary of changes:
...liCommandTestNotInitializedIntegrationBase.java | 10 +
.../internal/cli/commands/ItNodeNameTest.java | 6 -
.../repl/registry/impl/JdbcUrlRegistryImpl.java | 9 +-
.../ignite/internal/client/ReliableChannel.java | 85 +++++-
.../internal/client/compute/ClientCompute.java | 4 +-
.../ignite/internal/client/sql/ClientSession.java | 22 +-
.../client/table/ClientKeyValueBinaryView.java | 30 +-
.../internal/client/table/ClientKeyValueView.java | 28 +-
.../client/table/ClientRecordBinaryView.java | 30 +-
.../internal/client/table/ClientRecordView.java | 30 +-
.../ignite/internal/client/table/ClientTable.java | 48 +--
.../client/table/ClientTupleSerializer.java | 37 ++-
.../client/table/PartitionAwarenessProvider.java | 66 +++++
.../internal/client/tx/ClientTransaction.java | 22 +-
.../apache/ignite/client/AbstractClientTest.java | 33 +++
.../apache/ignite/client/ClientComputeTest.java | 23 +-
.../ignite/client/PartitionAwarenessTest.java | 4 +-
.../apache/ignite/client/RequestBalancingTest.java | 79 +++++
.../testframework/junit/DumpThreadsOnTimeout.java | 3 +-
.../matchers/CompletableFutureMatcher.java | 20 ++
.../tech-notes/images/cancelRebalance.svg | 1 +
.../distribution-zones/tech-notes/images/flow.svg | 2 +-
modules/distribution-zones/tech-notes/rebalance.md | 56 +++-
.../tech-notes/src/cancelRebalance.puml | 18 ++
.../distribution-zones/tech-notes/src/flow.puml | 5 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 2 -
modules/platforms/cpp/ignite/schema/CMakeLists.txt | 2 -
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 9 +-
.../runner/app/client/ItThinClientSqlTest.java | 39 ++-
.../ignite/internal/sql/engine/ItMetadataTest.java | 10 +-
.../ignite/internal/sql/engine/ItUuidTest.java | 16 +-
.../sql/engine/exec/exp/agg/Accumulators.java | 329 +++++----------------
.../engine/exec/exp/agg/AccumulatorsFactory.java | 10 +-
.../internal/storage/MvPartitionStorage.java | 3 +-
.../ignite/internal/storage/util}/LockHolder.java | 2 +-
.../storage/util/ReentrantLockByRowId.java | 177 +++++++++++
.../internal/storage/util}/LockHolderTest.java | 3 +-
.../storage/util/ReentrantLockByRowIdTest.java | 159 ++++++++++
.../AbstractMvPartitionStorageConcurrencyTest.java | 31 +-
.../storage/AbstractMvPartitionStorageGcTest.java | 6 +-
.../storage/impl/TestMvPartitionStorage.java | 13 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 68 ++---
.../mv/PersistentPageMemoryMvPartitionStorage.java | 2 +
.../mv/VolatilePageMemoryMvPartitionStorage.java | 6 +-
.../internal/storage/rocksdb/GarbageCollector.java | 94 ++++--
.../internal/storage/rocksdb/GcRowVersion.java} | 50 ++--
.../storage/rocksdb/PartitionDataHelper.java | 3 +
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 18 +-
.../distributed/ItTxDistributedTestSingleNode.java | 18 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 14 +-
.../table/distributed/StorageUpdateHandler.java | 8 +-
.../SnapshotAwarePartitionDataStorage.java | 4 +-
.../internal/table/distributed/IndexBaseTest.java | 108 ++-----
.../table/distributed/IndexCleanupTest.java | 24 ++
.../internal/table/distributed/IndexGcTest.java | 61 +---
55 files changed, 1277 insertions(+), 683 deletions(-)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/table/PartitionAwarenessProvider.java
create mode 100644
modules/client/src/test/java/org/apache/ignite/client/RequestBalancingTest.java
create mode 100644
modules/distribution-zones/tech-notes/images/cancelRebalance.svg
create mode 100644
modules/distribution-zones/tech-notes/src/cancelRebalance.puml
rename
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/util}/LockHolder.java
(97%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/util/ReentrantLockByRowId.java
rename
modules/{storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/mv
=>
storage-api/src/test/java/org/apache/ignite/internal/storage/util}/LockHolderTest.java
(96%)
create mode 100644
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/util/ReentrantLockByRowIdTest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/prepare/bounds/MultiBounds.java
=>
storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/GcRowVersion.java}
(59%)
