This is an automated email from the ASF dual-hosted git repository.
ibessonov pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 43859a1f7e IGNITE-17998 Sql. Close the cursor synchronously when the
session is closed (#1330)
add 396413eca8 IGNITE-18122 Track last applied term and group config in
storages (#1331)
No new revisions were added by this update.
Summary of changes:
.../pagememory/persistence/PartitionMeta.java | 64 ++++++++++-
.../pagememory/persistence/io/PartitionMetaIo.java | 51 +++++++-
.../persistence/PartitionMetaManagerTest.java | 15 ++-
.../pagememory/persistence/PartitionMetaTest.java | 67 ++++++++---
.../persistence/checkpoint/CheckpointerTest.java | 2 +-
.../ignite/raft/client/service/CommandClosure.java | 8 ++
.../client/service/CommittedConfiguration.java | 117 +++++++++++++++++++
.../raft/client/service/RaftGroupListener.java | 9 ++
.../snasphot/SnapshotInMemoryStorageFactory.java | 3 +-
.../internal/raft/server/impl/JraftServerImpl.java | 38 +++++-
.../raft/storage/SnapshotStorageFactory.java | 4 +-
.../storage/impl/IgniteJraftServiceFactory.java | 8 +-
.../ignite/raft/jraft/JRaftServiceFactory.java | 5 +-
.../org/apache/ignite/raft/jraft/StateMachine.java | 11 ++
.../jraft/core/DefaultJRaftServiceFactory.java | 4 +-
.../ignite/raft/jraft/core/FSMCallerImpl.java | 33 ++++++
.../storage/snapshot/SnapshotExecutorImpl.java | 2 +-
.../internal/AbstractClusterIntegrationTest.java | 2 +-
.../internal/storage/MvPartitionStorage.java | 25 +++-
.../internal/storage/RaftGroupConfiguration.java | 128 +++++++++++++++++++++
.../storage/AbstractMvPartitionStorageTest.java | 30 ++++-
.../storage/AbstractMvTableStorageTest.java | 7 +-
.../storage/impl/TestMvPartitionStorage.java | 25 +++-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 41 ++++++-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 27 ++++-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 96 +++++++++++++++-
.../ignite/distributed/ItTablePersistenceTest.java | 63 ++++++++--
.../distributed/raft/PartitionDataStorage.java | 33 +++++-
.../table/distributed/raft/PartitionListener.java | 91 ++++++++++++---
.../raft/snapshot/PartitionSnapshotStorage.java | 30 +++--
.../snapshot/PartitionSnapshotStorageFactory.java | 23 +++-
.../snapshot/incoming/IncomingSnapshotCopier.java | 42 +++++--
.../snapshot/incoming/IncomingSnapshotReader.java | 4 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 56 ++++++---
.../snapshot/outgoing/OutgoingSnapshotReader.java | 6 +-
.../outgoing/OutgoingSnapshotsManager.java | 3 +-
.../SnapshotAwarePartitionDataStorage.java | 20 +++-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 32 ++----
.../raft/PartitionCommandListenerTest.java | 128 +++++++++++++++++----
.../PartitionSnapshotStorageFactoryTest.java | 65 +++++++----
.../snapshot/PartitionSnapshotStorageTest.java | 67 +++++++++++
.../incoming/IncomingSnapshotCopierTest.java | 39 +++++--
.../incoming/IncomingSnapshotReaderTest.java} | 12 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 64 ++++-------
.../OutgoingSnapshotMvDataStreamingTest.java | 46 +++++++-
.../outgoing/OutgoingSnapshotReaderTest.java | 41 +++----
.../OutgoingSnapshotTxDataStreamingTest.java | 28 ++---
.../outgoing/OutgoingSnapshotsManagerTest.java | 26 ++++-
.../SnapshotAwarePartitionDataStorageTest.java | 36 +++++-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 37 +-----
.../distributed/TestPartitionDataStorage.java | 21 +++-
.../internal/tx/storage/state/TxStateStorage.java | 19 +--
.../state/rocksdb/TxStateRocksDbStorage.java | 67 +++++++----
.../storage/state/TxStateStorageAbstractTest.java | 42 ++++---
.../tx/storage/state/test/TestTxStateStorage.java | 13 ++-
55 files changed, 1581 insertions(+), 395 deletions(-)
create mode 100644
modules/raft-client/src/main/java/org/apache/ignite/raft/client/service/CommittedConfiguration.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/RaftGroupConfiguration.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionSnapshotStorageTest.java
copy
modules/{network/src/test/java/org/apache/ignite/internal/network/serialization/BuiltInTypeTest.java
=>
table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/incoming/IncomingSnapshotReaderTest.java}
(70%)
