This is an automated email from the ASF dual-hosted git repository.
rpuch pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 0eb8ea4ba1 IGNITE-22783 Handle CMG-related network messages in CMG
thread pool (#4467)
add 789d0fb715 IGNITE-15119 Use UUID as the ClusterNode ID (#4466)
No new revisions were added by this update.
Summary of changes:
.../org/apache/ignite/network/ClusterNode.java | 3 +-
.../compaction/CatalogCompactionRunner.java | 5 +-
.../CatalogCompactionRunnerSelfTest.java | 17 ++--
.../internal/cli/decorators/TopologyDecorator.java | 2 +-
modules/client-handler/build.gradle | 2 +
.../client/handler/ItClientHandlerMetricsTest.java | 4 +-
.../ignite/client/handler/ItClientHandlerTest.java | 7 +-
.../apache/ignite/client/handler/TestServer.java | 3 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../cluster/ClientClusterGetNodesRequest.java | 2 +-
.../ignite/client/handler/FakePlacementDriver.java | 20 +++--
.../ignite/internal/client/ClientClusterNode.java | 9 ++-
.../ignite/internal/client/TcpClientChannel.java | 2 +-
.../ignite/internal/client/TcpIgniteClient.java | 3 +-
.../apache/ignite/client/AbstractClientTest.java | 2 +-
.../java/org/apache/ignite/client/TestServer.java | 11 +--
.../ignite/client/fakes/FakeInternalTable.java | 10 +--
.../apache/ignite/client/fakes/FakeTxManager.java | 2 +-
.../management/ClusterManagementGroupManager.java | 2 +-
.../raft/ClusterStateStorageManager.java | 6 +-
.../cluster/management/raft/ValidationManager.java | 3 +-
.../raft/commands/ClusterNodeMessage.java | 3 +-
.../management/topology/LogicalTopologyImpl.java | 2 +-
.../management/topology/api/LogicalNode.java | 7 +-
.../cluster/management/ClusterInitializerTest.java | 19 ++---
.../AbstractClusterStateStorageManagerTest.java | 7 +-
.../management/raft/CmgRaftGroupListenerTest.java | 7 +-
.../topology/LogicalTopologyImplTest.java | 90 ++++++++++++----------
.../internal/compute/ItComputeErrorsBaseTest.java | 3 +-
.../internal/compute/ComputeComponentImplTest.java | 25 +++---
.../internal/compute/IgniteComputeImplTest.java | 7 +-
.../internal/testframework/IgniteTestUtils.java | 11 +++
...niteDistributionZoneManagerNodeRestartTest.java | 12 +--
.../distributionzones/DistributionZoneManager.java | 5 +-
.../distributionzones/DistributionZonesUtil.java | 3 +-
.../ignite/internal/distributionzones/Node.java | 9 ++-
.../distributionzones/NodeWithAttributes.java | 7 +-
.../DistributionZoneManagerAlterFilterTest.java | 11 +--
...ibutionZoneManagerConfigurationChangesTest.java | 3 +-
.../DistributionZoneManagerFilterTest.java | 11 +--
...butionZoneManagerLogicalTopologyEventsTest.java | 7 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 17 ++--
...butionZoneManagerStorageProfilesFilterTest.java | 11 +--
.../DistributionZoneStorageProfilesFilterTest.java | 9 ++-
.../DistributionZoneCausalityDataNodesTest.java | 7 +-
.../DistributionZoneRebalanceEngineTest.java | 32 +++++---
.../RebalanceUtilUpdateAssignmentsTest.java | 2 +-
.../network/file/FileTransferServiceImplTest.java | 9 ++-
.../internal/network/file/TestTopologyService.java | 3 +-
.../internal/index/IndexManagementUtils.java | 3 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 4 +-
.../internal/index/IndexBuildControllerTest.java | 8 +-
.../internal/index/IndexManagementUtilsTest.java | 8 +-
.../internal/index/TestIndexManagementUtils.java | 3 +-
.../impl/ItIdempotentCommandCacheTest.java | 4 +-
.../metastorage/impl/CommandIdGenerator.java | 7 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 3 +-
.../impl/IdempotentCommandCacheTest.java | 2 +-
.../server/BasicOperationsKeyValueStorageTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 2 +-
.../ignite/internal/network/ClusterNodeImpl.java | 9 ++-
.../internal/network/ClusterNodeResolver.java | 5 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 5 +-
.../network/SingleClusterNodeResolver.java | 3 +-
.../network/netty/ItConnectionManagerTest.java | 2 +-
.../internal/network/DefaultMessagingService.java | 3 +-
.../network/message/ClusterNodeMessage.java | 3 +-
.../internal/network/netty/ConnectionManager.java | 10 +--
.../internal/network/netty/InNetworkObject.java | 3 +-
.../ignite/internal/network/netty/NettySender.java | 7 +-
.../network/recovery/InMemoryStaleIds.java | 7 +-
.../recovery/RecoveryClientHandshakeManager.java | 14 +---
.../recovery/RecoveryServerHandshakeManager.java | 9 +--
.../internal/network/recovery/StaleIdDetector.java | 4 +-
.../ignite/internal/network/recovery/StaleIds.java | 4 +-
.../internal/network/recovery/VaultStaleIds.java | 21 ++---
.../scalecube/ScaleCubeClusterServiceFactory.java | 2 +-
.../scalecube/ScaleCubeTopologyService.java | 7 +-
.../network/DefaultMessagingServiceTest.java | 4 +-
.../internal/network/netty/NettyClientTest.java | 3 +-
.../network/netty/RecoveryHandshakeTest.java | 4 +-
.../RecoveryClientHandshakeManagerTest.java | 8 +-
.../RecoveryServerHandshakeManagerTest.java | 5 +-
.../network/recovery/VaultStaleIdsTest.java | 55 ++++++++-----
.../scalecube/ScaleCubeTopologyServiceTest.java | 5 +-
.../internal/network/recovery/AllIdsAreFresh.java | 4 +-
.../internal/network/recovery/AllIdsAreStale.java | 4 +-
.../replicator/utils/TestPlacementDriver.java | 3 +-
.../replicator/ZonePartitionReplicaListener.java | 3 +-
.../network/command/UpdateAllCommand.java | 2 +-
.../replicator/network/command/UpdateCommand.java | 2 +-
.../ReadOnlyScanRetrieveBatchReplicaRequest.java | 2 +-
.../replication/ReadWriteReplicaRequest.java | 2 +-
.../internal/placementdriver/ReplicaMeta.java | 3 +-
.../event/PrimaryReplicaEventParameters.java | 7 +-
.../placementdriver/TestPlacementDriver.java | 3 +-
.../placementdriver/TestReplicaMetaImpl.java | 13 ++--
.../ItPrimaryReplicaChoiceTest.java | 5 +-
.../PlacementDriverManagerTest.java | 5 +-
.../internal/placementdriver/leases/Lease.java | 14 ++--
.../placementdriver/leases/LeaseTracker.java | 3 +-
.../negotiation/LeaseAgreement.java | 3 +-
.../placementdriver/LeaseNegotiationTest.java | 9 ++-
.../internal/placementdriver/LeaseTrackerTest.java | 5 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 3 +-
.../placementdriver/PlacementDriverTest.java | 13 ++--
.../leases/LeaseSerializationTest.java | 3 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 3 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 2 +-
.../ItPlacementDriverReplicaSideTest.java | 5 +-
.../apache/ignite/internal/replicator/Replica.java | 3 +-
.../ignite/internal/replicator/ReplicaImpl.java | 5 +-
.../ignite/internal/replicator/ReplicaManager.java | 11 ++-
.../replicator/ZonePartitionReplicaImpl.java | 3 +-
.../exception/PrimaryReplicaMissException.java | 4 +-
.../replicator/listener/ReplicaListener.java | 3 +-
.../message/PrimaryReplicaChangeCommand.java | 3 +-
.../replicator/PlacementDriverReplicaSideTest.java | 5 +-
.../internal/replicator/ReplicaManagerTest.java | 3 +-
.../internal/rest/api/cluster/ClusterNode.java | 7 +-
.../runner/app/ItIgniteNodeRestartTest.java | 3 +-
.../runner/app/ItReplicaStateManagerTest.java | 3 +-
.../client/ItThinClientComputeMarshallingTest.java | 6 +-
.../runner/app/client/ItThinClientComputeTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../DistributedConfigurationStorageTest.java | 2 +-
.../internal/sql/engine/exec/TxAttributes.java | 10 +--
.../sql/engine/exec/ExecutionServiceImplTest.java | 7 +-
.../sql/engine/exec/PartitionProvidersTest.java | 6 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 6 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 8 +-
.../engine/exec/mapping/FragmentMappingTest.java | 3 +-
.../exec/mapping/MappingServiceImplTest.java | 6 +-
.../exec/mapping/MappingTestRunnerSelfTest.java | 3 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 21 ++---
.../engine/exec/rel/ScannableTableSelfTest.java | 23 +++---
.../exec/rel/TableScanNodeExecutionTest.java | 7 +-
.../engine/framework/ClusterServiceFactory.java | 7 +-
.../sql/engine/framework/ExplicitTxContext.java | 2 +-
.../sql/engine/framework/ImplicitTxContext.java | 2 +-
.../sql/engine/framework/NoOpTransaction.java | 8 +-
.../sql/engine/framework/TestBuilders.java | 3 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 6 +-
.../internal/storage/MvPartitionStorage.java | 4 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 4 +-
.../storage/AbstractMvPartitionStorageTest.java | 6 +-
.../storage/impl/TestMvPartitionStorage.java | 6 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 17 ++--
.../mv/VolatilePageMemoryMvPartitionStorage.java | 7 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 12 +--
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 2 +-
.../disaster/system/MetastorageRepairImplTest.java | 8 +-
.../SystemDisasterRecoveryManagerImplTest.java | 10 +--
.../internal/systemview/SystemViewManagerTest.java | 3 +-
.../ItAbstractInternalTableScanTest.java | 3 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 2 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 2 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 5 +-
.../internal/table/ItTransactionRecoveryTest.java | 8 +-
.../internal/table/ItTxResourcesVacuumTest.java | 2 +-
.../ignite/internal/table/InternalTable.java | 10 +--
.../distributed/raft/PartitionDataStorage.java | 4 +-
.../table/distributed/raft/PartitionListener.java | 6 +-
.../SnapshotAwarePartitionDataStorage.java | 4 +-
.../replicator/PartitionReplicaListener.java | 34 ++++----
.../replicator/TransactionStateResolver.java | 2 +-
.../distributed/storage/InternalTableImpl.java | 14 ++--
.../UpdateCommandsMarshallingMicroBenchmark.java | 4 +-
.../distributed/TableManagerRecoveryTest.java | 3 +-
.../table/distributed/TableManagerTest.java | 9 +--
.../PartitionRaftCommandsSerializationTest.java | 8 +-
.../raft/PartitionCommandListenerTest.java | 21 ++---
.../PartitionReplicaListenerIndexLockingTest.java | 6 +-
...itionReplicaListenerSortedIndexLockingTest.java | 5 +-
.../replication/PartitionReplicaListenerTest.java | 18 +++--
.../CheckCatalogVersionOnActionRequestTest.java | 2 +-
.../storage/InternalTableEstimatedSizeTest.java | 7 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +-
.../distributed/TestPartitionDataStorage.java | 4 +-
.../ignite/internal/table/TxAbstractTest.java | 2 +-
.../table/impl/DummyInternalTableImpl.java | 6 +-
.../ignite/internal/tx/InternalTransaction.java | 2 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 11 +--
.../ignite/internal/tx/TxStateMetaAbandoned.java | 3 +-
.../ignite/internal/tx/TxStateMetaFinishing.java | 3 +-
.../tx/impl/IgniteAbstractTransactionImpl.java | 6 +-
.../tx/impl/PublicApiThreadingTransaction.java | 2 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 2 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 2 +-
.../tx/impl/RemotelyTriggeredResourceRegistry.java | 20 ++---
.../internal/tx/impl/ResourceCloseException.java | 3 +-
.../internal/tx/impl/ResourceVacuumManager.java | 7 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 2 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 2 +-
.../internal/tx/message/TxStateMetaMessage.java | 3 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 5 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 5 +-
.../internal/tx/impl/OrphanDetectorTest.java | 5 +-
.../tx/impl/ReadOnlyTransactionImplTest.java | 2 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 5 +-
201 files changed, 784 insertions(+), 607 deletions(-)
