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 b5702483bf IGNITE-23191 Pass unique flag into Sorted index (#4375)
add da5703bc0b IGNITE-23075 Call failure processor on timeout worker crash
(#4365)
No new revisions were added by this update.
Summary of changes:
.../ignite/internal/client/TcpClientChannel.java | 3 +-
.../management/ClusterManagementGroupManager.java | 14 +--
.../ClusterManagementGroupManagerTest.java | 6 +-
.../internal/cluster/management/MockNode.java | 10 +-
.../metastore/DeploymentUnitStoreImplTest.java | 4 +-
.../ignite/internal/failure/FailureContext.java | 0
.../ignite/internal/failure/FailureProcessor.java} | 12 +-
.../ignite/internal/failure/FailureType.java | 0
.../internal/failure/handlers/FailureHandler.java | 0
.../internal/future/timeout/TimeoutWorker.java | 21 +++-
.../internal/future/timeout/TimeoutWorkerTest.java | 134 +++++++++++++++++++++
...niteDistributionZoneManagerNodeRestartTest.java | 4 +-
.../{FailureProcessor.java => FailureManager.java} | 11 +-
.../ignite/internal/failure/package-info.java | 2 +-
.../internal/failure/FailureProcessorTest.java | 30 ++---
...ilureProcessor.java => NoOpFailureManager.java} | 6 +-
.../internal/lowwatermark/LowWatermarkImpl.java | 12 +-
.../lowwatermark/LowWatermarkImplTest.java | 4 +-
.../impl/ItIdempotentCommandCacheTest.java | 4 +-
.../impl/ItMetaStorageManagerImplTest.java | 4 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 14 +--
.../ItMetaStorageMultipleNodesRocksDbTest.java | 4 +-
...tMetaStorageSafeTimePropagationRocksDbTest.java | 4 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 4 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 12 +-
.../metastorage/server/WatchProcessor.java | 20 +--
.../server/persistence/RocksDbKeyValueStorage.java | 6 +-
.../impl/MetaStorageRocksDbRangeTest.java | 4 +-
.../RocksDbCompactionKeyValueStorageTest.java | 4 +-
.../server/RocksDbKeyValueStorageTest.java | 4 +-
.../metastorage/server/WatchProcessorTest.java | 4 +-
.../server/SimpleInMemoryKeyValueStorage.java | 4 +-
.../server/TestRocksDbKeyValueStorage.java | 4 +-
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../internal/network/DefaultMessagingService.java | 14 ++-
.../internal/network/NettyWorkersRegistrar.java | 12 +-
.../internal/network/netty/ConnectionManager.java | 20 +--
.../recovery/RecoveryClientHandshakeManager.java | 12 +-
.../recovery/RecoveryServerHandshakeManager.java | 10 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 11 +-
.../network/DefaultMessagingServiceTest.java | 11 +-
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../RecoveryClientHandshakeManagerTest.java | 6 +-
.../RecoveryServerHandshakeManagerTest.java | 6 +-
.../network/utils/ClusterServiceTestUtils.java | 4 +-
.../persistence/checkpoint/CheckpointManager.java | 12 +-
.../checkpoint/CheckpointTimeoutLock.java | 10 +-
.../persistence/checkpoint/Checkpointer.java | 18 +--
.../persistence/compaction/Compactor.java | 12 +-
.../persistence/store/FilePageStoreManager.java | 16 +--
.../checkpoint/CheckpointManagerTest.java | 6 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 34 +++---
.../persistence/checkpoint/CheckpointerTest.java | 18 +--
.../persistence/compaction/CompactorTest.java | 14 +--
.../store/FilePageStoreManagerTest.java | 4 +-
.../checkpoint/CheckpointTestUtils.java | 4 +-
.../replicator/ItReplicaLifecycleTest.java | 22 ++--
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 8 +-
.../internal/raft/server/impl/JraftServerImpl.java | 26 ++--
.../raft/StateMachineFailureHandlerTest.java | 14 +--
.../ignite/internal/raft/TestLozaFactory.java | 4 +-
.../raft/server/TestJraftServerFactory.java | 4 +-
.../ItPlacementDriverReplicaSideTest.java | 4 +-
.../ignite/internal/replicator/ReplicaManager.java | 18 +--
.../internal/replicator/ReplicaManagerTest.java | 4 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 3 +-
.../ItDistributedConfigurationPropertiesTest.java | 14 +--
.../ItDistributedConfigurationStorageTest.java | 14 +--
.../runner/app/ItIgniteNodeRestartTest.java | 6 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 32 ++---
.../internal/sql/engine/SqlQueryProcessor.java | 10 +-
.../sql/engine/exec/QueryTaskExecutorImpl.java | 12 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 4 +-
.../internal/sql/engine/framework/TestNode.java | 6 +-
.../ignite/internal/storage/DataStorageModule.java | 6 +-
.../internal/storage/DataStorageModules.java | 8 +-
.../internal/storage/DataStorageModulesTest.java | 4 +-
.../storage/impl/TestDataStorageModule.java | 4 +-
.../PersistentPageMemoryDataStorageModule.java | 6 +-
.../PersistentPageMemoryStorageEngine.java | 20 +--
.../VolatilePageMemoryDataStorageModule.java | 4 +-
.../PersistentPageMemoryMvTableStorageTest.java | 4 +-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 6 +-
.../PersistentPageMemoryStorageEngineTest.java | 4 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 4 +-
...PersistentPageMemorySortedIndexStorageTest.java | 4 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 4 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 4 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 4 +-
.../storage/rocksdb/RocksDbDataStorageModule.java | 4 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 4 +-
.../rebalance/ItRebalanceDistributedTest.java | 22 ++--
.../CatalogStorageIndexDescriptorSupplierTest.java | 4 +-
.../distributed/TableManagerRecoveryTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../PersistentPageMemoryGcUpdateHandlerTest.java | 4 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../worker/ItCriticalWorkerMonitoringTest.java | 4 +-
.../internal/worker/CriticalWorkerWatchdog.java | 14 +--
102 files changed, 586 insertions(+), 422 deletions(-)
rename modules/{failure-handler =>
core}/src/main/java/org/apache/ignite/internal/failure/FailureContext.java
(100%)
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/NodeStopper.java
=>
core/src/main/java/org/apache/ignite/internal/failure/FailureProcessor.java}
(73%)
rename modules/{failure-handler =>
core}/src/main/java/org/apache/ignite/internal/failure/FailureType.java (100%)
rename modules/{failure-handler =>
core}/src/main/java/org/apache/ignite/internal/failure/handlers/FailureHandler.java
(100%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/future/timeout/TimeoutWorkerTest.java
rename
modules/failure-handler/src/main/java/org/apache/ignite/internal/failure/{FailureProcessor.java
=> FailureManager.java} (96%)
rename
modules/failure-handler/src/testFixtures/java/org/apache/ignite/internal/failure/{NoOpFailureProcessor.java
=> NoOpFailureManager.java} (87%)
mode change 100755 => 100644
