This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch catalog-feature
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 69b65cb061 catalog-feature after ai-merge
add e26fc8016d IGNITE-20290 Command reordering wrt safe time in
MetaStorage (#2506)
add d857cf28ba IGNITE-20205 Fix race in dummy table (#2495)
add d579c39443 IGNITE-20260 Fix RaftGroupServiceImpl#readIndex (#2498)
add 07a02ae89e IGNITE-20033 Implement local txnStateMap (#2483)
add ea9d9e82a9 IGNITE-20300 Metastorage command reordering wrt Safe Time
on Raft Group entry (#2513)
add 632b5665a1 Merge branch 'main' into catalog-feature
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/client/fakes/FakeTxManager.java | 6 +-
.../impl/ItMetaStorageManagerImplTest.java | 52 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 2 +-
...MetaStorageSafeTimePropagationAbstractTest.java | 13 +-
.../command/MetaStorageWriteCommand.java | 4 +-
.../metastorage/command/SyncTimeCommand.java | 14 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 35 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 2 +-
.../metastorage/server/KeyValueStorage.java | 7 +
.../server/OnRevisionAppliedCallback.java | 15 +-
.../metastorage/server/WatchProcessor.java | 21 +-
.../server/persistence/RocksDbKeyValueStorage.java | 13 +
.../server/raft/MetaStorageListener.java | 3 +-
.../server/raft/MetaStorageWriteHandler.java | 25 +-
.../server/BasicOperationsKeyValueStorageTest.java | 28 +-
.../metastorage/server/WatchProcessorTest.java | 10 +-
.../impl/StandaloneMetaStorageManager.java | 5 +-
.../server/SimpleInMemoryKeyValueStorage.java | 11 +
...CommandClosure.java => BeforeApplyHandler.java} | 45 +-
.../internal/raft/service/RaftGroupListener.java | 12 -
.../raft/server/ItJraftCounterServerTest.java | 8 +
.../ignite/internal/raft/RaftGroupServiceImpl.java | 1 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 38 +-
.../ItPlacementDriverReplicaSideTest.java | 2 +-
.../apache/ignite/internal/replicator/Replica.java | 5 +-
.../ignite/internal/replicator/ReplicaManager.java | 11 +-
.../replicator/listener/ReplicaListener.java | 3 +-
.../storage/ItRebalanceDistributedTest.java | 3 +-
.../runner/app/ItIgniteNodeRestartTest.java | 23 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 8 +-
.../exec/rel/TableScanNodeExecutionTest.java | 3 +-
modules/table/build.gradle | 3 +
.../ignite/distributed/ItTablePersistenceTest.java | 38 +-
.../distributed/ItTxDistributedTestSingleNode.java | 602 ++-------------------
.../ItTxDistributedTestSingleNodeCollocated.java | 10 +-
...butedTestThreeNodesThreeReplicasCollocated.java | 7 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 225 ++++++++
.../ignite/distributed/ReplicaUnavailableTest.java | 6 +-
.../ignite/internal/table/ItColocationTest.java | 6 +-
.../internal/table/distributed/TableManager.java | 2 +
.../table/distributed/command/FinishTxCommand.java | 5 +
.../distributed/command/TxCleanupCommand.java | 5 +
.../distributed/command/UpdateAllCommand.java | 2 +
.../table/distributed/command/UpdateCommand.java | 2 +
.../table/distributed/raft/PartitionListener.java | 37 +-
...plicaRequest.java => CommittableTxRequest.java} | 15 +-
.../request/ReadWriteMultiRowReplicaRequest.java | 7 +-
.../ReadWriteScanRetrieveBatchReplicaRequest.java | 7 +-
.../request/ReadWriteSingleRowReplicaRequest.java | 7 +-
.../request/ReadWriteSwapRowReplicaRequest.java | 7 +-
.../replicator/PartitionReplicaListener.java | 153 ++++--
.../distributed/storage/InternalTableImpl.java | 8 +-
.../RepeatedFinishReadWriteTransactionTest.java | 7 +-
.../apache/ignite/internal/table/TxLocalTest.java | 16 +-
.../PartitionRaftCommandsSerializationTest.java | 10 +
.../raft/PartitionCommandListenerTest.java | 15 +
.../PartitionReplicaListenerIndexLockingTest.java | 4 +-
.../replication/PartitionReplicaListenerTest.java | 254 +++++----
.../PartitionCommandsMarshallerImplTest.java | 1 +
.../ignite/distributed/ItTxTestCluster.java} | 331 ++++-------
.../table/impl/DummyInternalTableImpl.java | 83 +--
.../org/apache/ignite/internal/tx/TxManager.java | 18 +-
.../org/apache/ignite/internal/tx/TxState.java | 27 +
.../internal/tx/{TxMeta.java => TxStateMeta.java} | 63 +--
.../tx/impl/IgniteAbstractTransactionImpl.java | 5 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 9 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 21 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 71 ++-
.../apache/ignite/internal/tx/TxManagerTest.java | 2 +-
69 files changed, 1261 insertions(+), 1258 deletions(-)
copy
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/service/{CommandClosure.java
=> BeforeApplyHandler.java} (51%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxStateLocalMapTest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replication/request/{ReadOnlyReplicaRequest.java
=> CommittableTxRequest.java} (75%)
copy
modules/table/src/{integrationTest/java/org/apache/ignite/distributed/ItTxDistributedTestSingleNode.java
=> testFixtures/java/org/apache/ignite/distributed/ItTxTestCluster.java} (72%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/{TxMeta.java
=> TxStateMeta.java} (56%)
