This is an automated email from the ASF dual-hosted git repository.
apolovtsev pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 7eaf7e063b9 IGNITE-24491 Fix zone replica stop order (#5226)
add 6b91a505612 IGNITE-22416 Implement snapshots for zone based partitions
(#5212)
No new revisions were added by this update.
Summary of changes:
.../rebalance/ItRebalanceDistributedTest.java | 43 ++--
.../replicator/ItZoneDataReplicationTest.java | 19 +-
.../partition/replicator/fixtures/Node.java | 10 +-
.../PartitionReplicaLifecycleManager.java | 42 +++-
.../network/raft/SnapshotMvDataResponse.java | 3 +
.../raft/FailFastSnapshotStorageFactory.java | 85 -------
.../replicator/raft/OnSnapshotSaveHandler.java | 102 +++++++++
.../replicator/raft/RaftTableProcessor.java | 23 ++
.../replicator/raft/ZonePartitionRaftListener.java | 90 +++++---
.../replicator/raft/snapshot/PartitionKey.java | 55 +----
...onAccess.java => PartitionMvStorageAccess.java} | 67 ++----
.../raft/snapshot/PartitionSnapshotStorage.java | 50 ++++-
.../snapshot/PartitionSnapshotStorageFactory.java | 105 +++++----
.../raft/snapshot/PartitionTxStateAccess.java | 69 ++++++
.../raft/snapshot/PartitionTxStateAccessImpl.java | 69 ++++++
.../raft/snapshot/RaftSnapshotPartitionMeta.java | 2 +-
.../{PartitionKey.java => ZonePartitionKey.java} | 25 ++-
.../snapshot/incoming/IncomingSnapshotCopier.java | 246 +++++++++++++--------
.../outgoing/MvPartitionDeliveryState.java | 101 +++++++++
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 118 ++++++----
.../snapshot/outgoing/OutgoingSnapshotReader.java | 8 +-
.../outgoing/OutgoingSnapshotsManager.java | 27 +--
.../snapshot/outgoing/PartitionsSnapshots.java | 6 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 30 ++-
.../PartitionReplicaLifecycleManagerTest.java | 9 +-
.../raft/ZonePartitionRaftListenerTest.java | 113 ++++++++++
.../PartitionSnapshotStorageFactoryTest.java | 34 ++-
.../snapshot/PartitionSnapshotStorageTest.java | 6 +-
.../incoming/IncomingSnapshotCopierTest.java | 60 +++--
.../outgoing/MvPartitionDeliveryStateTest.java | 145 ++++++++++++
.../outgoing/OutgoingSnapshotCommonTest.java | 46 +++-
.../OutgoingSnapshotMvDataStreamingTest.java | 202 +++++++++++++----
.../outgoing/OutgoingSnapshotReaderTest.java | 49 ++--
.../OutgoingSnapshotTxDataStreamingTest.java | 28 ++-
.../outgoing/OutgoingSnapshotsManagerTest.java | 25 ++-
.../SnapshotAwarePartitionDataStorageTest.java | 53 +++--
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 41 +++-
.../runner/app/ItIgniteNodeRestartTest.java | 43 ++--
.../org/apache/ignite/internal/app/IgniteImpl.java | 3 +-
.../internal/table/distributed/TableManager.java | 77 ++++---
.../table/distributed/raft/PartitionListener.java | 54 ++---
.../snapshot/FullStateTransferIndexChooser.java | 9 +-
...Impl.java => PartitionMvStorageAccessImpl.java} | 116 ++--------
.../SnapshotAwarePartitionDataStorage.java | 31 ++-
.../raft/snapshot/TablePartitionKey.java} | 12 +-
.../distributed/TableManagerRecoveryTest.java | 43 ++--
.../table/distributed/TableManagerTest.java | 2 +-
....java => PartitionMvStorageAccessImplTest.java} | 87 +++-----
48 files changed, 1772 insertions(+), 911 deletions(-)
delete mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/FailFastSnapshotStorageFactory.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/OnSnapshotSaveHandler.java
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/{PartitionAccess.java
=> PartitionMvStorageAccess.java} (81%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionTxStateAccess.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionTxStateAccessImpl.java
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/{PartitionKey.java
=> ZonePartitionKey.java} (71%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/outgoing/MvPartitionDeliveryState.java
create mode 100644
modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/raft/ZonePartitionRaftListenerTest.java
create mode 100644
modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/outgoing/MvPartitionDeliveryStateTest.java
rename
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{PartitionAccessImpl.java
=> PartitionMvStorageAccessImpl.java} (71%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/PartitionKey.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/TablePartitionKey.java}
(82%)
rename
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/{PartitionAccessImplTest.java
=> PartitionMvStorageAccessImplTest.java} (75%)
