This is an automated email from the ASF dual-hosted git repository.
vpyatkov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from c2d5eb3938d IGNITE-25730 Fix
testExecuteColocatedThrowsTableNotFoundExceptionWhenTableDoesNotExist (#6092)
add 0125c449aa3 IGNITE-25421 Add the requests throttling to raft client
(#5915)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../management/raft/ItCmgRaftServiceTest.java | 2 +-
.../ignite/internal/util/ExceptionUtils.java | 25 ++
.../internal/util/SlidingAverageValueTracker.java | 86 +++++++
.../ignite/internal/util/SlidingHistogram.java | 130 +++++++++++
.../util/SlidingAverageValueTrackerTest.java | 64 ++++++
.../ignite/internal/util/SlidingHistogramTest.java | 70 ++++++
.../ignite/internal/index/IndexBuildTask.java | 7 +-
.../impl/ItIdempotentCommandCacheTest.java | 2 +-
.../server/raft/ItMetaStorageRaftGroupTest.java | 10 +-
.../service/ItAbstractListenerSnapshotTest.java | 13 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 2 +-
.../internal/network/AbstractTopologyService.java | 5 +
.../ignite/internal/network/TopologyService.java | 7 +
.../ReplicationRaftCommandApplicator.java | 28 ++-
.../handlers/WriteIntentSwitchRequestHandler.java | 3 +-
.../placementdriver/PlacementDriverManager.java | 3 +-
.../internal/placementdriver/ActiveActorTest.java | 7 +-
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
.../internal/raft/GroupOverloadedException.java} | 25 +-
.../apache/ignite/internal/raft/RaftManager.java | 12 +-
.../ignite/internal/raft/RaftServiceFactory.java | 4 +-
.../internal/raft/ThrottlingContextHolder.java | 66 ++++++
.../configuration/RaftConfigurationSchema.java | 7 +
.../raft/server/ItSimpleCounterServerTest.java | 28 ++-
.../ignite/raft/server/JraftAbstractTest.java | 13 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 51 ++++-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 161 ++++++++++---
.../apache/ignite/internal/raft/RetryContext.java | 53 ++++-
.../internal/raft/ThrottlingContextHolderImpl.java | 255 +++++++++++++++++++++
.../org/apache/ignite/internal/raft/LozaTest.java | 2 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 9 +-
.../internal/raft/TestThrottlingContextHolder.java | 88 +++++++
.../raft/client/TopologyAwareRaftGroupService.java | 8 +-
.../TopologyAwareRaftGroupServiceFactory.java | 7 +-
.../PlacementDriverMessageProcessor.java | 30 +--
.../ignite/internal/replicator/ReplicaManager.java | 22 +-
.../ignite/internal/replicator/ReplicaService.java | 8 +-
.../ReplicatorRecoverableExceptions.java | 63 +++++
.../replicator/PlacementDriverReplicaSideTest.java | 4 +-
.../AbstractTopologyAwareGroupServiceTest.java | 4 +-
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 8 +-
.../ItMetastorageGroupDisasterRecoveryTest.java | 2 +-
.../replicator/PartitionReplicaListener.java | 7 +-
.../distributed/storage/InternalTableImpl.java | 27 ++-
.../distributed/TableManagerRecoveryTest.java | 2 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 11 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 4 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 45 +---
.../tx/impl/WriteIntentSwitchProcessor.java | 7 +-
52 files changed, 1305 insertions(+), 200 deletions(-)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/SlidingAverageValueTracker.java
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/SlidingHistogram.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/SlidingAverageValueTrackerTest.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/SlidingHistogramTest.java
copy
modules/{file-transfer/src/main/java/org/apache/ignite/internal/network/file/exception/FileTransferException.java
=>
raft-api/src/main/java/org/apache/ignite/internal/raft/GroupOverloadedException.java}
(58%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/ThrottlingContextHolder.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/ThrottlingContextHolderImpl.java
create mode 100644
modules/raft/src/testFixtures/java/org/apache/ignite/internal/raft/TestThrottlingContextHolder.java
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/ReplicatorRecoverableExceptions.java
