This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a change to branch ignite-22115
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from cbba29d6352 Merge remote-tracking branch 'origin/main' into
ignite-22115
add 0125c449aa3 IGNITE-25421 Add the requests throttling to raft client
(#5915)
add e4db8b2aca1 IGNITE-25684 Fix ClientTransactionCommitRequest error
handling (#6094)
add eeed4d36dc3 IGNITE-25561 Sql. Transfer partition awareness meta to the
client (#6076)
add bbacf586fe1 IGNITE-25472 .NET: Fix locale sensitivity in
BigDecimalTests.TestToString (#6095)
add eebbc79d76e IGNITE-25735 Add node name to metric exporter's thread
pool (#6096)
add 5fd48f88679 IGNITE-25740 Fix hash index comparator in aipersist/aimem
(#6098)
add 79c2d75cbec IGNITE-24783 Port tests related to partition lifecycle to
PartitionReplicaLifecycleManager tests (#6072)
add 9b604e74657 IGNITE-25737 Fixed deferred partition stop may throw
OutdatedTokenException (#6097)
add 594f6286f5f Bump it.unimi.dsi:fastutil-core from 8.5.15 to 8.5.16
(#6101)
add 30cbd5ebc47 Bump io.swagger.core.v3:swagger-annotations from 2.2.33 to
2.2.34 (#6088)
add 1eeb3e9cb9d IGNITE-25612 Improve diagnostic message related to watch
event processing (#6100)
add aca2d19123a Merge remote-tracking branch 'origin/main' into
ignite-22115
No new revisions were added by this update.
Summary of changes:
gradle/libs.versions.toml | 4 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../client/handler/ItClientHandlerMetricsTest.java | 4 +-
.../ignite/client/handler/ItClientHandlerTest.java | 5 +-
.../ignite/client/handler/ClientHandlerModule.java | 3 +-
.../handler/ClientInboundMessageHandler.java | 5 +-
.../handler/requests/jdbc/JdbcQueryCursor.java | 8 +
.../requests/sql/ClientSqlExecuteRequest.java | 55 ++-
.../tx/ClientTransactionCommitRequest.java | 4 +
modules/client/build.gradle | 1 +
.../org/apache/ignite/client/IgniteClient.java | 50 ++-
.../ignite/client/IgniteClientConfiguration.java | 34 ++
.../client/IgniteClientConfigurationImpl.java | 14 +-
.../ignite/internal/client/TcpClientChannel.java | 3 +-
.../ignite/internal/client/TcpIgniteClient.java | 4 +-
.../internal/client/sql/ClientAsyncResultSet.java | 17 +-
.../sql/ClientPartitionAwarenessMetadata.java | 71 ++++
.../client/sql/ClientResultSetMetadata.java | 8 +-
.../ignite/internal/client/sql/ClientSql.java | 68 +++-
.../ignite/internal/client/table/ClientTable.java | 6 +-
.../ignite/internal/client/table/ClientTables.java | 9 +-
.../org/apache/ignite/client/ClientSqlTest.java | 64 +++
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../org/apache/ignite/client/fakes/FakeCursor.java | 18 +
.../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 +-
.../ignite/internal/jdbc/JdbcConnection.java | 3 +-
.../ignite/internal/metastorage/WatchEvent.java | 19 +-
.../metastorage/timebag/IgniteStopwatch.java | 205 ++++++++++
.../internal/metastorage/timebag/IgniteTicker.java | 48 +++
.../internal/metastorage/timebag/NoOpTimeBag.java} | 31 +-
.../internal/metastorage/timebag/TimeBag.java | 82 ++++
.../internal/metastorage/timebag/TimeBagImpl.java | 367 +++++++++++++++++
.../impl/ItIdempotentCommandCacheTest.java | 2 +-
.../server/raft/ItMetaStorageRaftGroupTest.java | 10 +-
.../service/ItAbstractListenerSnapshotTest.java | 13 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 2 +-
.../metastorage/server/WatchAndEvents.java | 6 +-
.../metastorage/server/WatchProcessor.java | 31 +-
.../ignite/internal/metrics/MetricManager.java | 5 +-
.../ignite/internal/metrics/MetricManagerImpl.java | 10 +-
.../ignite/internal/metrics/MetricRegistry.java | 3 +-
.../metrics/exporters/BasicMetricExporter.java | 13 +-
.../metrics/exporters/PushMetricExporter.java | 13 +-
.../internal/network/AbstractTopologyService.java | 5 +
.../ignite/internal/network/TopologyService.java | 7 +
modules/partition-replicator/build.gradle | 1 +
.../ReplicationRaftCommandApplicator.java | 28 +-
.../partition/replicator/ZoneResourcesManager.java | 2 +-
.../handlers/WriteIntentSwitchRequestHandler.java | 3 +-
.../PartitionReplicaLifecycleManagerTest.java | 127 +++++-
.../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 +
.../dotnet/Apache.Ignite.Tests/BigDecimalTests.cs | 8 +-
.../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 +-
.../app/client/ItThinClientTransactionsTest.java | 24 ++
.../internal/sql/api/AsyncResultSetImpl.java | 6 +
.../ignite/internal/sql/engine/AsyncSqlCursor.java | 5 +
.../internal/sql/engine/AsyncSqlCursorImpl.java | 29 ++
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 8 +-
.../sql/engine/exec/fsm/QueryExecutor.java | 1 +
.../PartitionAwarenessMetadata.java | 19 +-
.../index/hash/CompareIndexColumnsValue.java | 2 +-
.../index/hash/PageMemoryHashIndexStorage.java | 11 +
.../pagememory/index/hash/io/HashIndexTreeIo.java | 8 +-
.../AbstractPageMemoryHashIndexStorageTest.java | 54 ++-
.../PersistentPageMemoryHashIndexStorageTest.java | 2 +-
.../VolatilePageMemoryHashIndexStorageTest.java | 2 +-
.../ItMetastorageGroupDisasterRecoveryTest.java | 2 +-
.../internal/table/distributed/TableManager.java | 14 +-
.../replicator/PartitionReplicaListener.java | 7 +-
.../distributed/storage/BrokenTxStateStorage.java | 5 +
.../distributed/storage/InternalTableImpl.java | 27 +-
.../distributed/TableManagerRecoveryTest.java | 2 +-
.../table/distributed/TableManagerTest.java | 12 +-
.../raft/PartitionCommandListenerTest.java | 81 ++++
.../replication/PartitionReplicaListenerTest.java | 443 +++++++++++++++++++++
.../tx/impl/PersistentTxStateVacuumizer.java | 11 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 4 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 45 +--
.../tx/impl/WriteIntentSwitchProcessor.java | 7 +-
.../state/ThreadAssertingTxStateStorage.java | 17 +-
.../internal/tx/storage/state/TxStateStorage.java | 8 +
.../state/rocksdb/TxStateRocksDbStorage.java | 7 +-
.../tx/storage/state/test/TestTxStateStorage.java | 7 +-
115 files changed, 3382 insertions(+), 318 deletions(-)
create mode 100644
modules/client/src/main/java/org/apache/ignite/internal/client/sql/ClientPartitionAwarenessMetadata.java
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
create mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/timebag/IgniteStopwatch.java
create mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/timebag/IgniteTicker.java
copy
modules/{catalog/src/test/java/org/apache/ignite/internal/catalog/storage/CatalogSerializationCompatibilityV2ReadsV2Test.java
=>
metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/timebag/NoOpTimeBag.java}
(61%)
create mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/timebag/TimeBag.java
create mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/timebag/TimeBagImpl.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
rename
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/{
=> hash}/AbstractPageMemoryHashIndexStorageTest.java (64%)
rename
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/{
=> hash}/PersistentPageMemoryHashIndexStorageTest.java (98%)
rename
modules/storage-page-memory/src/test/java/org/apache/ignite/internal/storage/pagememory/index/{
=> hash}/VolatilePageMemoryHashIndexStorageTest.java (97%)
