This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20680
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from e5b50d3121 fix test
add 8492971f35 IGNITE-21524 Sql. Incorrect conversion to KeyValue plan
(#3230)
add c708811d87 IGNITE-21439 Enable thread assertions in tests (#3231)
add 8f40ce50e5 IGNITE-21565 Disable
ReplicasSafeTimePropagationTest#testSafeTimeReorderingOnLeaderReElection (#3238)
add 2f1e599b08 IGNITE-21561 NullPointerException in ActionRequestProcessor
(#3232)
add bba18a5f99 IGNITE-21390 Inconsistent behavior of Compute APIs when
target node does not exist (#3191)
add dd8a43f046 IGNITE-21548 Encapsulate sets of assignments before storing
them to meta-storage (#3226)
add cde51e6cb6 IGNITE-20242 C++ Retry outdated schema error (#3236)
add 1d3c701e7a IGNITE-21271 ODBC: Fix transaction_test flakiness (#3237)
add 92352f62b6 IGNITE-21554 Encapsulate raft-related code of InternalTable
(#3227)
add ca0988674a IGNITE-21573 Fix IDEA warnings in BplusTree (#3241)
add d9f6909e08 Bump picocli from 4.7.0 to 4.7.5 (#3234)
add 847e30389c IGNITE-21571 Get rid of exeption in EventListener#notify
(#3240)
add bc0d6e9198 IGNITE-20117 Implement index backfill process (#3233)
add e07a4fea64 IGNITE-21433 Ignore STOPPING indexes during Catalog
validation (#3223)
add 93990c5773 IGNITE-20593 Sql. Fix all possible default expressions
(#3222)
add a5b65fe313 Merge branch 'main' into ignite-20680
add 1ed9ee0b27 Minor after review.
No new revisions were added by this update.
Summary of changes:
gradle/libs.versions.toml | 2 +-
.../ignite/internal/affinity/Assignments.java | 109 ++++++
.../{JobState.java => NodeNotFoundException.java} | 44 +--
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../internal/catalog/CatalogManagerImpl.java | 4 +-
.../catalog/CatalogParamsValidationUtils.java | 2 +-
.../ignite/internal/catalog/CatalogService.java | 9 +-
.../commands/AlterTableDropColumnCommand.java | 42 ++-
.../internal/catalog/commands/CatalogUtils.java | 2 +-
.../catalog/commands/DropIndexCommand.java | 2 -
.../catalog/descriptors/CatalogIndexStatus.java | 7 +
.../descriptors/CatalogSchemaDescriptor.java | 19 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 16 +-
.../catalog/CatalogManagerRecoveryTest.java | 4 +-
.../internal/catalog/CatalogManagerSelfTest.java | 293 +++++++---------
.../internal/catalog/CatalogSystemViewTest.java | 6 +-
.../commands/AbstractCommandValidationTest.java | 58 +++-
.../AlterTableDropColumnCommandValidationTest.java | 26 +-
.../catalog/commands/CatalogUtilsTest.java | 70 ++--
.../CreateAbstractIndexCommandValidationTest.java | 17 +
.../commands/DropZoneCommandValidationTest.java | 5 +-
.../commands/RenameTableCommandValidationTest.java | 5 +-
.../handler/ClientInboundMessageHandler.java | 2 +-
.../handler/ClientPrimaryReplicaTracker.java | 6 +-
.../compute/ClientComputeExecuteRequest.java | 18 +-
.../ignite/client/handler/FakeCatalogService.java | 2 +-
.../ignite/client/fakes/FakeInternalTable.java | 8 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 141 ++++++++
...nTest.java => ItEmbeddedComputeErrorsTest.java} | 7 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 100 ++++++
...est.java => ItThinClientComputeErrorsTest.java} | 7 +-
.../internal/compute/utils/InteractiveJobs.java | 32 +-
.../internal/compute/ComputeJobFailover.java | 21 +-
...atingJobExecution.java => FailedExecution.java} | 24 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 23 +-
.../internal/compute/IgniteComputeImplTest.java | 2 +
.../internal/event/AbstractEventProducer.java | 17 +-
.../ignite/internal/event/EventListener.java | 16 +-
.../ignite/internal/event/EventProducerTest.java | 23 +-
.../testframework/BaseIgniteAbstractTest.java | 2 +-
.../ItDistributionZonesFilterTest.java | 15 +-
.../distributionzones/DistributionZoneManager.java | 14 +-
.../distributionzones/rebalance/RebalanceUtil.java | 49 +--
.../utils/CatalogAlterZoneEventListener.java | 7 +-
.../DistributionZoneCausalityDataNodesTest.java | 8 +-
.../DistributionZoneRebalanceEngineTest.java | 14 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 10 +-
.../internal/index/ItBuildIndexOneNodeTest.java | 8 +-
.../ignite/internal/index/ItBuildIndexTest.java | 207 +----------
.../index/ItDropIndexMultipleNodesTest.java | 336 ++++++++++++++++++
.../internal/index/ItDropIndexOneNodeTest.java | 112 ++++++
.../index/IndexAvailabilityController.java | 25 +-
.../internal/index/IndexBuildController.java | 23 +-
.../apache/ignite/internal/index/IndexManager.java | 8 +-
.../ignite/internal/index/IndexChooserTest.java | 56 +--
.../ignite/internal/index/IndexManagerTest.java | 38 +-
.../internal/index/TestIndexManagementUtils.java | 4 -
.../ignite/internal/pagememory/tree/BplusTree.java | 234 +++++--------
.../internal/pagememory/tree/io/BplusInnerIo.java | 4 +-
.../internal/pagememory/tree/io/BplusIo.java | 12 +-
.../placementdriver/BasePlacementDriverTest.java | 4 +-
.../ItPrimaryReplicaChoiceTest.java | 8 +-
.../PlacementDriverManagerTest.java | 14 +-
.../placementdriver/AssignmentsTracker.java | 7 +-
.../internal/placementdriver/LeaseTrackerTest.java | 2 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 8 +-
.../ignite/client/detail/cluster_connection.cpp | 31 ++
.../cpp/ignite/client/detail/cluster_connection.h | 61 +---
.../ignite/client/detail/compute/compute_impl.cpp | 2 +-
.../cpp/ignite/client/detail/response_handler.h | 53 ++-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 2 +-
.../cpp/ignite/client/detail/table/table_impl.cpp | 224 +++++++-----
.../cpp/ignite/client/detail/table/table_impl.h | 107 ++++--
modules/platforms/cpp/ignite/common/error_codes.h | 1 +
modules/platforms/cpp/ignite/common/ignite_error.h | 24 ++
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
modules/platforms/cpp/ignite/protocol/utils.cpp | 24 +-
.../cpp/tests/client-test/compute_test.cpp | 20 +-
.../client-test/schema_synchronization_test.cpp | 56 ++-
.../cpp/tests/odbc-test/odbc_connection.h | 2 +-
.../cpp/tests/odbc-test/transaction_test.cpp | 16 +
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 21 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 3 +
.../jraft/rpc/impl/ActionRequestProcessor.java | 15 +-
.../internal/replicator/ReplicaManagerTest.java | 13 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 16 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 6 +-
.../internal/ClusterPerClassIntegrationTest.java | 2 +-
.../apache/ignite/internal/table/NodeUtils.java | 2 +-
.../ignite/internal/schema/SchemaManager.java | 18 +-
.../ignite/internal/schema/SchemaManagerTest.java | 47 +--
.../AuthenticationManagerImplTest.java | 2 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 16 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 6 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 40 +--
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../engine/exec/ExecutableTableRegistryImpl.java | 2 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 178 ++++++++--
.../engine/rule/TableScanToKeyValueGetRule.java | 11 +-
.../ignite/internal/sql/engine/util/Commons.java | 2 +-
...ules.java => IgniteCustomAssignmentsRules.java} | 16 +-
.../exec/rel/TableScanNodeExecutionTest.java | 10 +-
.../sql/engine/planner/CastResolutionTest.java | 6 +-
.../planner/PrimaryKeyLookupPlannerTest.java | 17 +
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 385 +++++++++++++++++++++
.../ignite/internal/storage/BinaryRowAndRowId.java | 4 +-
.../org/apache/ignite/internal/storage/RowId.java | 25 +-
.../storage/BinaryRowAndRowIdMatcherTest.java | 82 +++++
.../storage/AbstractMvTableStorageTest.java | 8 +-
.../internal/storage/BinaryRowAndRowIdMatcher.java | 55 +++
.../index/AbstractHashIndexStorageTest.java | 2 +-
.../index/AbstractSortedIndexStorageTest.java | 2 +-
.../ItInternalTableReadWriteScanTest.java | 4 +-
.../ReplicasSafeTimePropagationTest.java | 2 +
.../rebalance/ItRebalanceDistributedTest.java | 25 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 4 +-
.../ignite/internal/table/ItColocationTest.java | 5 +-
.../ignite/internal/table/InternalTable.java | 25 +-
.../apache/ignite/internal/table/TableImpl.java | 2 +-
.../ignite/internal/table/TableRaftService.java | 52 +++
.../internal/table/distributed/TableManager.java | 149 ++++----
.../distributed/command/BuildIndexCommand.java | 3 +
.../raft/BuildIndexRowVersionChooser.java | 110 ++++++
.../table/distributed/raft/PartitionListener.java | 48 ++-
.../raft/RebalanceRaftGroupEventsListener.java | 30 +-
.../snapshot/FullStateTransferIndexChooser.java | 7 +-
.../replicator/PartitionReplicaListener.java | 7 +-
.../distributed/storage/InternalTableImpl.java | 130 ++-----
.../distributed/storage/TableRaftServiceImpl.java | 167 +++++++++
.../table/distributed/TableManagerTest.java | 4 +-
.../internal/table/distributed/TableUtilsTest.java | 16 +-
.../raft/BuildIndexRowVersionChooserTest.java | 235 +++++++++++++
.../raft/PartitionCommandListenerTest.java | 19 +-
.../FullStateTransferIndexChooserTest.java | 79 ++---
.../distributed/storage/InternalTableImplTest.java | 8 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 5 +-
.../ignite/internal/table/TableTestUtils.java | 10 +-
.../ignite/internal/table/TxAbstractTest.java | 2 +-
.../table/impl/DummyInternalTableImpl.java | 14 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 2 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 2 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 2 +-
.../internal/tx/AbstractLockManagerEventsTest.java | 2 +-
145 files changed, 3600 insertions(+), 1639 deletions(-)
create mode 100644
modules/affinity/src/main/java/org/apache/ignite/internal/affinity/Assignments.java
copy modules/api/src/main/java/org/apache/ignite/compute/{JobState.java =>
NodeNotFoundException.java} (56%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItComputeErrorsBaseTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedWorkerShutdownTest.java
=> ItEmbeddedComputeErrorsTest.java} (81%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItFailoverCandidateNotFoundTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItThinClientWorkerShutdownTest.java
=> ItThinClientComputeErrorsTest.java} (85%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{DelegatingJobExecution.java
=> FailedExecution.java} (65%)
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItDropIndexMultipleNodesTest.java
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItDropIndexOneNodeTest.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/{IgniteCustomAssigmentsRules.java
=> IgniteCustomAssignmentsRules.java} (95%)
create mode 100644
modules/storage-api/src/test/java/org/apache/ignite/internal/storage/BinaryRowAndRowIdMatcherTest.java
create mode 100644
modules/storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/BinaryRowAndRowIdMatcher.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/TableRaftService.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/BuildIndexRowVersionChooser.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/storage/TableRaftServiceImpl.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/BuildIndexRowVersionChooserTest.java
