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 9014dd0b2d9 IGNITE-24416 Use sql.executeAsync in Sql and Transaction
REST controlers (#5183)
add 9e3d7c4c56c IGNITE-22621 Implement transaction finishing for zone
replica listener (#5187)
No new revisions were added by this update.
Summary of changes:
modules/client-handler/build.gradle | 2 +
.../apache/ignite/client/handler/TestServer.java | 2 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 2 +-
modules/client/build.gradle | 1 +
.../ignite/client/TestClientHandlerModule.java | 2 +-
.../java/org/apache/ignite/client/TestServer.java | 2 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 3 +-
.../rebalance/ItRebalanceDistributedTest.java | 4 +-
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItZoneDataReplicationTest.java | 116 +++++++
.../partition/replicator/fixtures/Node.java | 9 +-
.../PartitionReplicaLifecycleManager.java | 104 +++++--
.../replicator/ReliableCatalogVersions.java} | 37 ++-
.../replicator/ReplicaTxFinishMarker.java | 61 ++++
.../ReplicationRaftCommandApplicator.java | 74 +++++
.../replicator/TxFinishReplicaRequestHandler.java | 337 ++++++++++++++++++++
.../replicator/ZonePartitionReplicaListener.java | 53 ++--
.../partition/replicator/ZoneResourcesManager.java | 12 +
.../replicator/raft/FinishTxCommandHandler.java | 143 +++++++++
.../replicator/raft/RaftTxFinishMarker.java | 64 ++++
.../raft/UnexpectedTransactionStateException.java | 2 +-
.../replicator/raft/ZonePartitionRaftListener.java | 80 ++++-
.../schema/CatalogValidationSchemasSource.java | 2 +-
.../replicator}/schema/ColumnDefinitionDiff.java | 2 +-
.../schema/ExecutorInclinedSchemaSyncService.java | 2 +-
.../replicator}/schema/FullTableSchema.java | 2 +-
.../replicator}/schema/TableDefinitionDiff.java | 2 +-
.../schema/ValidationSchemasSource.java | 2 +-
.../schemacompat}/CompatValidationResult.java | 2 +-
.../IncompatibleSchemaVersionException.java | 2 +-
.../InternalSchemaVersionMismatchException.java | 2 +-
.../SchemaCompatibilityValidator.java | 39 ++-
.../schemacompat}/TableDefinitionDiffKey.java | 2 +-
.../schema/CatalogValidationSchemasSourceTest.java | 2 +-
.../ExecutorInclinedSchemaSyncServiceTest.java | 2 +-
.../replicator}/schema/FullTableSchemaTest.java | 2 +-
.../SchemaCompatibilityValidatorTest.java | 8 +-
.../ignite/internal/replicator/ReplicaManager.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 50 +--
.../schema/AlwaysSyncedSchemaSyncService.java | 3 +-
.../internal/sql/engine/framework/TestNode.java | 2 +-
modules/table/build.gradle | 1 +
...xDistributedTestSingleNodeNoCleanupMessage.java | 2 +-
.../ignite/internal/table/AbstractTableView.java | 4 +-
.../table/TableExceptionMapperProvider.java | 2 +-
.../internal/table/distributed/TableManager.java | 4 +-
.../table/distributed/raft/PartitionListener.java | 116 +------
.../replicator/PartitionReplicaListener.java | 339 +++------------------
.../table/TableExceptionMapperProviderTest.java | 2 +-
.../table/TableKvOperationsMockedTest.java | 2 +-
.../distributed/TableManagerRecoveryTest.java | 14 +-
.../table/distributed/TableManagerTest.java | 2 +-
.../PartitionReplicaListenerIndexLockingTest.java | 2 +-
...itionReplicaListenerSortedIndexLockingTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 10 +-
.../storage/InternalTableEstimatedSizeTest.java | 2 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../table/impl/DummyInternalTableImpl.java | 2 +-
.../table/impl/DummyValidationSchemasSource.java | 4 +-
.../org/apache/ignite/internal/tx/TxManager.java | 3 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 42 +--
.../ignite/internal/tx/impl/TxManagerImpl.java | 3 +-
63 files changed, 1206 insertions(+), 601 deletions(-)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/schema/ExecutorInclinedSchemaSyncService.java
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ReliableCatalogVersions.java}
(51%)
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ReplicaTxFinishMarker.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/ReplicationRaftCommandApplicator.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/TxFinishReplicaRequestHandler.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/FinishTxCommandHandler.java
create mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/RaftTxFinishMarker.java
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/raft/UnexpectedTransactionStateException.java
(96%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/CatalogValidationSchemasSource.java
(99%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/ColumnDefinitionDiff.java
(97%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/ExecutorInclinedSchemaSyncService.java
(97%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/FullTableSchema.java
(98%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/TableDefinitionDiff.java
(98%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator}/schema/ValidationSchemasSource.java
(98%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/schemacompat}/CompatValidationResult.java
(98%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/schemacompat}/IncompatibleSchemaVersionException.java
(98%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/schemacompat}/InternalSchemaVersionMismatchException.java
(96%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/schemacompat}/SchemaCompatibilityValidator.java
(91%)
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/schemacompat}/TableDefinitionDiffKey.java
(96%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator}/schema/CatalogValidationSchemasSourceTest.java
(99%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator}/schema/ExecutorInclinedSchemaSyncServiceTest.java
(98%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed =>
partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator}/schema/FullTableSchemaTest.java
(98%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/replicator
=>
partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/schemacompat}/SchemaCompatibilityValidatorTest.java
(98%)
rename
modules/{table/src/testFixtures/java/org/apache/ignite/internal/table/distributed
=>
schema/src/testFixtures/java/org/apache/ignite/internal}/schema/AlwaysSyncedSchemaSyncService.java
(91%)
