This is an automated email from the ASF dual-hosted git repository. github-bot pushed a change to branch dependabot/gradle/com.github.johnrengelman.shadow-8.1.1 in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit f92605fb51 Bump com.github.johnrengelman.shadow from 7.1.2 to 8.1.1 add 97ccd370e8 IGNITE-21916 Sql. Cover SQL T828 (JSON_QUERY) feature by tests (#3577) add 0ce74471de IGNITE-22025 .NET: Remove Console.WriteLine leftovers (#3586) add 5c6befafbc IGNITE-21840 PersistentPageMemoryStorageEngine#createMvTable should return MvTableStorage. (#3477) add 87cf63d118 IGNITE-21841 The FilePageStoreManager constructor should not throw an exception. (#3476) add f10ab88c85 IGNITE-20416 Retry when schema change is detected during implicit transaction (#3584) add 94b064ab89 IGNITE-21933 Fix TxStateStorage#leaseStartTime possible inconsistency with partition storage (#3551) add 34354d2a59 IGNITE-21987 Optimize RO scan in sorted indexes (#3566) add 2dd41ef593 IGNITE-22027 Fix ItPrimaryReplicaChoiceTest#testPrimaryChangeLongHandling (#3593) add d1635529ef IGNITE-22030 Remove unused jackson-dataformat-msgpack dependency (#3595) add 058e5c9c4d IGNITE-22021 Set null into IndexStorage#getNextRowIdToBuild for the primary index (#3589) add 95a9a44859 IGNITE-21919 Sql. Cover SQL E031-03 (Identifiers, Trailing underscore feature) by tests (#3570) add f38ecb94b7 IGNITE-22035 Reduce memory consumption of integration tests (#3598) add c22595a83a IGNITE-21914 Cover SQL T631(IN predicate with one list element) feature by tests (#3571) add 770030b063 IGNITE-22038 Make idle safe time sending more robust (#3602) add a7545f3bea IGNITE-22022: Support of JSON object with nested object creation (#3592) add 79d5bc824d IGNITE-21902 Add an option to configure log storage path (#3605) add ea454d40b4 IGNITE-22045 Fix ItComputeApiThreadingTest (#3607) add 1bee9be9f8 IGNITE-21976 Sql. Amend TREE keyword to SORTED for CREATE INDEX syntax (#3601) add 2534207d7b IGNITE-21921 Sql. Cover SQL E071-01 (Basic query expressions, UNION DISTINCT table operator) feature by tests (#3559) add 6b0358f234 IGNITE-22033 Replace PlacementDriver#currentLease with #getPrimaryReplica in ReadWriteTxContext#waitReadyToFinish (#3600) add a3e8fd1266 IGNITE-21904 Mechanism to provide custom Event implementations to register EventSerializer (#3606) add 09cd1d897d IGNITE-22042 Do not enlist operations in a FINISHING transaction (#3604) add 0f9f1df95e IGNITE-22015: Fix checking NOT NULL constraint for UPDATE, MERGE, INSERT INTO ... FROM statements (#3583) add ac10fb020b IGNITE-22052 Disable flaky basic_authenticator_test (#3612) add 7306b533c0 IGNITE-22047 Ignore index destruction attempt if table storage is closed/destroyed (#3609) add 46f09f5c15 IGNITE-22029 Change default configuration according to default RAFT option (#3596) add 93165bd652 Bump uk.co.datumedge:hamcrest-json from 0.2 to 0.3 (#3587) add c1f9e5ea66 Bump asm from 9.6 to 9.7 (#3481) add e18c0a005f IGNITE-22027 Disable destruction_does_not_update_data (#3617) add ad69dfd808 IGNITE-22055 Shut destruction executor down before closing volatile regions (#3616) add c69918e148 IGNITE-20516 Remove openapi.yaml from source code (#3581) add 8737d92818 IGNITE-22060: Enable sql logic tests for NOT NULL constraint violation (#3618) add bf7f2a9777 IGNITE-21963: fix incorrect serialization for some BigDecimal values (#3599) add 84c1712957 IGNITE-22053 Sql. Logic test without ordering compares with ordered results (#3613) add 3cd90d4f59 IGNITE-19687 Add support for reassigning the default distribution zone in Catalog (#3590) add 98a2a22830 IGNITE-22066 Fix memory leak in the DummyInternalTableImpl (#3621) add 66ef243b39 IGNITE-21928 Describe Catalog operation flow in README (#3585) add 958b4a06fc IGNITE-22041 Correct inline size calculation for indexes (#3622) add ce4050397f IGNITE-22001 Throw specific exception if during writeTableAssignmentsToMetastore process was interrupted (#3575) add 5a419c5dd9 IGNITE-21935: Cover SQL E153(Updatable queries with subqueries) feature by tests (#3630) add b43e81f171 IGNITE-21996 Sql. Improve test coverage for ALTER COLUMN command (#3631) add 2ba5a6def1 Bump archunit from 1.2.1 to 1.3.0 (#3623) add 8bde02bffb Bump org.apache.calcite.avatica:avatica-core from 1.24.0 to 1.25.0 (#3624) add ced1035ffa IGNITE-21923: Cover SQL E051-09(Basic query specification, Rename columns in the FROM clause) feature by tests (#3628) add 9036b30bef IGNITE-22054 Fix ItMultipleLocksTest#test (#3632) add c6d135080a Bump com.github.spotbugs from 6.0.8 to 6.0.12 (#3638) add 0978749e4e IGNITE-22062 RO transaction does not close cursor when exception is thrown (#3620) add 7ac3f5ba1b IGNITE-21257 Introduce REST API for viewing partition states (#3614) add 50d14e8fca IGNITE-21988 Don't allow reading from index storage if it is in build state (#3561) add 15a4383367 IGNITE-22083 Sql. Invalidate fragment mapping cache when the mapped node has left the cluster (#3637) add 25926b1a76 IGNITE-19949 Fix dynamic completer for same options (#3644) add aa22af743d IGNITE-21940 Sql. Cover SQL F304 (EXCEPT ALL table operator) feature by tests (#3635) add 21f940de18 IGNITE-21939 Sql. Cover SQL F302-02(INTERSECT [ALL] table operator) feature by tests (#3636) add a3b26ac688 IGNITE-18647 Sql. Implement missed Statement and StatementBuilder methods (#3626) add df39219094 IGNITE-21943: Cover SQL F561(Full value expressions) feature by tests (#3641) add 6dedb616b3 IGNITE-19681 Java thin: Add tx partition awareness (lazy tx start) (#3640) add c57c1a8c38 IGNITE-22024 Fixed ItSqlClientSynchronousApiTest#runtimeErrorInDmlCausesTransactionToFail (#3651) add d3781844a7 IGNITE-21937 Sql. Cover SQL F041-05 feature by tests (#3643) add 0f5618fde0 IGNITE-21435: Sql. Catalog DefaultValue should not depend on Serializable. (#3627) add 478ee5de9f Bump org.rocksdb:rocksdbjni from 8.11.3 to 9.1.1 (#3654) add d593e6487a IGNITE-21824 Revert workaround for jline bug (#3647) add cfea5baaf2 IGNITE-22075 GC doesn't wait for RO transactions (#3650) add 694f43b5be IGNITE-21850 Enable LogSinkTest (#3646) add b39659f90d IGNITE-22093: Sql. Rename PlannerPhase::HEP_DECORRELATE (#3652) add a3bd2e5b6d IGNITE-22095 Remove compute job jars from the repo (#3655) add 4871350087 IGNITE-22105 Add busy lock to RocksDbClusterStateStorage (#3659) add e7ace75f49 Bump com.github.johnrengelman.shadow from 7.1.2 to 8.1.1 This update added new revisions after undoing existing revisions. That is to say, some revisions that were in the old version of the branch are not in the new version. This situation occurs when a user --force pushes a change and generates a repository containing something like this: * -- * -- B -- O -- O -- O (f92605fb51) \ N -- N -- N refs/heads/dependabot/gradle/com.github.johnrengelman.shadow-8.1.1 (e7ace75f49) You should already have received notification emails for all of the O revisions, and so the following emails describe only the N revisions from the common base, B. Any revisions marked "omit" are not gone; other references still refer to them. Any revisions marked "discard" are gone forever. No new revisions were added by this update. Summary of changes: .gitignore | 3 + check-rules/spotbugs-excludes.xml | 6 + docs/_docs/sql-reference/ddl.adoc | 4 +- gradle/libs.versions.toml | 15 +- .../ignite/internal/affinity/Assignments.java | 11 + .../java/org/apache/ignite/catalog/IndexType.java | 2 +- .../java/org/apache/ignite/lang/ErrorGroups.java | 6 + .../main/java/org/apache/ignite/sql/Statement.java | 53 +- .../catalog/sql/CreateFromAnnotationsTest.java | 6 +- .../catalog/sql/CreateFromDefinitionTest.java | 6 +- .../internal/catalog/sql/CreateTableTest.java | 8 +- .../ignite/internal/catalog/sql/QueryPartTest.java | 12 +- modules/catalog/README.md | 87 +- .../apache/ignite/internal/catalog/Catalog.java | 14 +- .../internal/catalog/CatalogManagerImpl.java | 43 +- .../ignite/internal/catalog/CatalogService.java | 2 - .../AlterZoneSetDefaultCatalogCommand.java | 12 +- .../catalog/commands/CreateTableCommand.java | 13 +- .../internal/catalog/commands/DefaultValue.java | 220 +++- .../internal/catalog/commands/DropZoneCommand.java | 14 +- .../catalog/commands/RenameZoneCommand.java | 5 - .../descriptors/CatalogTableColumnDescriptor.java | 30 +- .../internal/catalog/events/CatalogEvent.java | 3 + .../storage/AbstractChangeIndexStatusEntry.java | 3 +- .../internal/catalog/storage/AlterColumnEntry.java | 3 +- .../internal/catalog/storage/AlterZoneEntry.java | 3 +- .../internal/catalog/storage/DropColumnsEntry.java | 3 +- .../internal/catalog/storage/DropTableEntry.java | 3 +- .../internal/catalog/storage/DropZoneEntry.java | 3 +- .../internal/catalog/storage/NewColumnsEntry.java | 3 +- .../internal/catalog/storage/NewIndexEntry.java | 3 +- .../catalog/storage/NewSystemViewEntry.java | 3 +- .../internal/catalog/storage/NewTableEntry.java | 3 +- .../internal/catalog/storage/NewZoneEntry.java | 3 +- .../catalog/storage/ObjectIdGenUpdateEntry.java | 3 +- .../internal/catalog/storage/RemoveIndexEntry.java | 3 +- .../internal/catalog/storage/RenameIndexEntry.java | 3 +- .../internal/catalog/storage/RenameTableEntry.java | 3 +- ...DropZoneEntry.java => SetDefaultZoneEntry.java} | 34 +- .../internal/catalog/storage/SnapshotEntry.java | 16 +- .../CatalogEntrySerializerProvider.java | 2 + .../serialization/MarshallableEntryType.java | 3 +- ...CatalogManagerDescriptorCausalityTokenTest.java | 12 +- .../internal/catalog/CatalogManagerSelfTest.java | 177 ++- .../commands/AbstractCommandValidationTest.java | 4 +- .../catalog/commands/CatalogUtilsTest.java | 2 - .../commands/DropZoneCommandValidationTest.java | 9 +- .../commands/RenameZoneCommandValidationTest.java | 12 - .../storage/CatalogEntrySerializationTest.java | 274 ++--- .../catalog/storage/UpdateLogImplTest.java | 2 + .../internal/catalog/BaseCatalogManagerTest.java | 2 - modules/catalog/tech-notes/acceptUpdateFlow.puml | 53 + modules/catalog/tech-notes/accept_update_flow.png | Bin 0 -> 42531 bytes modules/catalog/tech-notes/applyUpdateFlow.puml | 32 + modules/catalog/tech-notes/apply_update_flow.png | Bin 0 -> 15220 bytes modules/cli/build.gradle | 14 +- .../cli/commands/sql/help/IgniteSqlCommand.java | 2 +- .../repl/completer/DynamicCompleterRegistry.java | 38 +- .../core/repl/executor/IgnitePicocliCommands.java | 34 - .../completer/DynamicCompleterRegistryTest.java | 60 +- modules/client-common/build.gradle | 1 - .../internal/jdbc/proto/JdbcQueryEventHandler.java | 2 +- modules/client-handler/build.gradle | 1 - .../handler/ClientPrimaryReplicaTracker.java | 19 +- .../ignite/client/handler/FakePlacementDriver.java | 11 - modules/client/build.gradle | 1 - .../internal/client/compute/ClientCompute.java | 3 +- .../ignite/internal/client/sql/ClientSql.java | 15 +- .../client/sql/ClientStatementBuilder.java | 36 +- .../client/table/ClientKeyValueBinaryView.java | 50 +- .../internal/client/table/ClientKeyValueView.java | 60 +- .../client/table/ClientRecordBinaryView.java | 53 +- .../internal/client/table/ClientRecordView.java | 51 +- .../ignite/internal/client/table/ClientTable.java | 62 +- .../client/table/ClientTupleSerializer.java | 16 +- .../client/table/PartitionAwarenessProvider.java | 30 +- .../internal/client/tx/ClientLazyTransaction.java | 176 +++ .../internal/client/tx/ClientTransaction.java | 14 +- .../internal/client/tx/ClientTransactions.java | 15 +- .../client/ObservableTimestampPropagationTest.java | 20 +- .../ignite/client/PartitionAwarenessTest.java | 361 +++--- .../org/apache/ignite/client/RetryPolicyTest.java | 4 + .../apache/ignite/client/ServerMetricsTest.java | 6 +- .../management/ClusterManagementGroupManager.java | 93 +- .../management/raft/ClusterStateStorage.java | 13 +- .../management/raft/CmgRaftGroupListener.java | 3 +- .../management/raft/RaftStorageManager.java | 12 +- .../raft/RocksDbClusterStateStorage.java | 201 ++-- .../raft/AbstractClusterStateStorageTest.java | 80 +- .../management/raft/TestClusterStateStorage.java | 167 ++- modules/compute/build.gradle | 1 + modules/compute/jobs.gradle | 89 ++ .../ignite/internal/compute/ItComputeBaseTest.java | 16 +- .../internal/compute/ItComputeTestEmbedded.java | 46 - .../internal/compute/ItComputeTestStandalone.java | 33 +- .../threading/ItComputeApiThreadingTest.java | 2 +- .../units/ignite-it-jobs-1.0-SNAPSHOT.jar | Bin 5528 -> 0 bytes .../units/ignite-jobs-1.0-SNAPSHOT-src.zip | Bin 69608 -> 0 bytes .../units/ignite-ut-job1-1.0-SNAPSHOT.jar | Bin 1749 -> 0 bytes .../units/ignite-ut-job2-1.0-SNAPSHOT.jar | Bin 1724 -> 0 bytes .../apache/ignite/internal/compute/ConcatJob.java} | 22 +- .../ignite/internal/compute/FailingJob.java} | 21 +- .../ignite/internal/compute/GetNodeNameJob.java} | 21 +- .../ignite/internal/compute/JobException.java} | 9 +- .../apache/ignite/internal/compute/SleepJob.java} | 24 +- modules/compute/src/test/README.md | 15 - .../compute/loader/JobClassLoaderFactoryTest.java | 30 +- .../units/ignite-jobs-1.0-SNAPSHOT-src.zip | Bin 69608 -> 0 bytes .../unit1/1.0.0/ignite-ut-job1-1.0-SNAPSHOT.jar | Bin 1749 -> 0 bytes .../unit1/2.0.0/ignite-ut-job2-1.0-SNAPSHOT.jar | Bin 1724 -> 0 bytes .../unit1/3.0.1/ignite-ut-job1-1.0-SNAPSHOT.jar | Bin 1749 -> 0 bytes .../unit1/3.0.1/ignite-ut-job2-1.0-SNAPSHOT.jar | Bin 1724 -> 0 bytes .../unit1/3.0.2/ignite-ut-job1-1.0-SNAPSHOT.jar | Bin 1749 -> 0 bytes .../3.0.2/subdir/ignite-ut-job2-1.0-SNAPSHOT.jar | Bin 1724 -> 0 bytes .../units/unit1/4.0.0/unit1-1.0-corrupted.jar | Bin 1693 -> 0 bytes .../unit2/1.0.0/ignite-ut-job1-1.0-SNAPSHOT.jar | Bin 1749 -> 0 bytes .../unit2/2.0.0/ignite-ut-job2-1.0-SNAPSHOT.jar | Bin 1724 -> 0 bytes .../ignite/internal/compute/Job1Utility.java} | 7 +- .../apache/ignite/internal/compute/UnitJob.java} | 21 +- .../ignite/internal/compute/Job2Utility.java} | 7 +- .../apache/ignite/internal/compute/UnitJob.java} | 21 +- .../ignite/internal/event/EventParameters.java | 2 +- .../ignite/internal/util/io/IgniteDataInput.java | 90 ++ .../ignite/internal/util/io/IgniteDataOutput.java | 90 ++ .../internal/util/io/IgniteUnsafeDataInput.java | 110 ++ .../internal/util/io/IgniteUnsafeDataOutput.java | 121 ++ .../IgniteUnsafeDataInputOutputByteOrderTest.java | 120 +- .../testframework/TestIgnitionManager.java | 3 +- ...niteDistributionZoneManagerNodeRestartTest.java | 72 +- .../BaseDistributionZoneManagerTest.java | 5 + .../DistributionZoneManagerAlterFilterTest.java | 53 +- ...ibutionZoneManagerConfigurationChangesTest.java | 3 +- ...istributionZoneManagerScaleUpScaleDownTest.java | 32 +- .../DistributionZoneCausalityDataNodesTest.java | 46 +- .../DistributionZoneRebalanceEngineTest.java | 4 +- .../DistributionZonesTestUtil.java | 10 + .../apache/ignite/internal/eventlog/api/Event.java | 15 +- .../ignite/internal/eventlog/event/EventImpl.java | 13 +- .../internal/eventlog/impl/EventLogImpl.java | 5 +- .../ignite/internal/eventlog/impl/LogSink.java | 5 +- .../impl/{SinkFactory.java => LogSinkFactory.java} | 18 +- .../ignite/internal/eventlog/impl/SinkFactory.java | 9 +- .../eventlog/ser/EventSerializerFactory.java} | 21 +- ...alizer.java => JacksonBasedJsonSerializer.java} | 50 +- .../internal/eventlog/event/EventBuilderTest.java | 30 +- .../internal/eventlog/event/IgniteEventsTest.java | 4 +- .../ConfigurationBasedChannelRegistryTest.java | 6 +- .../impl/ConfigurationBasedSinkRegistryTest.java | 3 +- .../internal/eventlog/impl/EventLogTest.java | 2 +- .../ignite/internal/eventlog/impl/LogSinkTest.java | 10 +- .../ignite/internal/eventlog/ser/CustomEvent.java | 67 ++ .../internal/eventlog/ser/CustomEventBuilder.java | 51 + ...st.java => JacksonBasedJsonSerializerTest.java} | 39 +- .../ignite/internal/eventlog/ser/Message.java} | 26 +- .../apache/ignite/internal/index/IndexManager.java | 10 +- .../index/IndexAvailabilityControllerTest.java | 14 +- .../ignite/internal/index/IndexManagerTest.java | 6 +- .../internal/index/TestIndexManagementUtils.java | 3 +- .../ignite/internal/index/TestPlacementDriver.java | 5 - .../ignite/jdbc/ItJdbcClientTimeZoneTest.java | 4 +- .../ignite/internal/jdbc/ConnectionProperties.java | 8 +- .../internal/jdbc/ConnectionPropertiesImpl.java | 5 +- .../ignite/internal/lowwatermark/LowWatermark.java | 24 +- .../internal/lowwatermark/LowWatermarkImpl.java | 88 +- .../ChangeLowWatermarkEventParameters.java} | 28 +- .../lowwatermark/event/LowWatermarkEvent.java} | 27 +- .../event/LowWatermarkEventParameters.java} | 9 +- .../lowwatermark/LowWatermarkImplTest.java | 123 ++- .../internal/lowwatermark/TestLowWatermark.java | 42 +- .../server/raft/ItMetaStorageRaftGroupTest.java | 24 +- .../processor/messages/MessageImplGenerator.java | 1 - .../internal/network/NettyWorkersRegistrar.java | 29 +- .../pagememory/persistence/PartitionMeta.java | 47 +- .../pagememory/persistence/io/PartitionMetaIo.java | 27 + .../persistence/store/FilePageStoreFactory.java | 2 +- .../persistence/store/FilePageStoreManager.java | 5 +- .../persistence/PartitionMetaManagerTest.java | 7 +- .../pagememory/persistence/PartitionMetaTest.java | 2 +- .../PersistentPageMemoryNoLoadTest.java | 2 +- .../persistence/checkpoint/CheckpointerTest.java | 2 +- .../store/FilePageStoreManagerTest.java | 2 +- .../internal/placementdriver/PlacementDriver.java | 10 - .../placementdriver/TestPlacementDriver.java | 5 - .../ItPrimaryReplicaChoiceTest.java | 2 +- .../placementdriver/leases/LeaseTracker.java | 9 - modules/platforms/cpp/ignite/common/error_codes.h | 2 + modules/platforms/cpp/ignite/odbc/common_types.cpp | 2 + .../tests/client-test/basic_authenticator_test.cpp | 12 +- .../cpp/tests/client-test/compute_test.cpp | 2 +- .../cpp/tests/client-test/transactions_test.cpp | 3 +- .../Apache.Ignite.Tests/ProjectFilesTests.cs | 23 + .../Table/SchemaSynchronizationTest.cs | 5 - .../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 6 + .../Apache.Ignite/Internal/Table/DataStreamer.cs | 3 - .../configuration/RaftConfigurationSchema.java | 8 +- .../ignite/raft/server/ItJraftHlcServerTest.java | 12 +- .../raft/server/ItJraftServerLogPathTest.java | 113 ++ .../raft/server/ItSimpleCounterServerTest.java | 7 +- .../ignite/raft/server/JraftAbstractTest.java | 17 +- .../ignite/raft/server/RaftServerAbstractTest.java | 34 + .../java/org/apache/ignite/internal/raft/Loza.java | 2 +- .../internal/raft/server/impl/JraftServerImpl.java | 41 +- .../storage/impl/DefaultLogStorageFactory.java | 21 +- .../raft/storage/logit/LogitLogStorageFactory.java | 17 +- .../ignite/raft/jraft/option/NodeOptions.java | 1 - .../jraft/storage/impl/LogStorageBenchmark.java | 2 +- .../jraft/storage/logit/LogitLogStorageTest.java | 3 +- .../service/ItAbstractListenerSnapshotTest.java | 2 +- modules/replicator/build.gradle | 9 +- .../ItPlacementDriverReplicaSideTest.java | 4 +- .../ignite/internal/replicator/ReplicaManager.java | 43 +- .../internal/replicator/ReplicaManagerTest.java | 4 +- .../AbstractTopologyAwareGroupServiceTest.java | 1 + modules/rest-api/build.gradle | 31 +- modules/rest-api/openapi/openapi.properties | 20 - modules/rest-api/openapi/openapi.yaml | 1163 -------------------- .../rest/api/recovery/DisasterRecoveryApi.java | 74 ++ .../api/recovery/GlobalPartitionStateResponse.java | 62 ++ .../recovery/GlobalPartitionStatesResponse.java} | 28 +- .../api/recovery/LocalPartitionStateResponse.java | 70 ++ .../recovery}/LocalPartitionStatesResponse.java | 28 +- .../handler/IgniteInternalExceptionHandler.java | 10 + modules/rest/build.gradle | 2 + .../recovery/ItDisasterRecoveryControllerTest.java | 156 +++ .../rest/recovery/DisasterRecoveryController.java | 114 ++ .../rest/recovery/DisasterRecoveryFactory.java | 47 + .../benchmark/SqlPartitionPruningBenchmark.java | 2 +- .../runner/app/ItIgniteNodeRestartTest.java | 10 +- .../client/ItThinClientPartitionAwarenessTest.java | 24 +- .../app/client/ItThinClientTransactionsTest.java | 17 +- .../ItSchemaSyncAndImplicitTransactionsTest.java | 290 +++++ .../schemasync/ItSchemaSyncSingleNodeTest.java | 8 +- .../ignite/internal/table/ItTableScanTest.java | 2 +- .../org/apache/ignite/internal/app/IgniteImpl.java | 13 +- .../internal/ClusterPerClassIntegrationTest.java | 5 +- .../apache/ignite/internal/table/NodeUtils.java | 5 +- .../internal/schema/marshaller/MarshallerUtil.java | 2 +- .../schema/marshaller/KvMarshallerTest.java | 46 + .../schema/marshaller/MarshallerUtilTest.java | 70 ++ .../ignite/internal/sql/api/ItSqlApiBaseTest.java | 2 +- .../internal/sql/api/ItSqlAsynchronousApiTest.java | 36 +- .../sql/api/ItSqlClientAsynchronousApiTest.java | 25 - .../internal/sql/api/ItSqlClientMetricsTest.java | 7 +- .../internal/sql/api/ItSqlSynchronousApiTest.java | 16 - .../sql/engine/ItAlterTableAlterColumnTest.java | 44 +- .../internal/sql/engine/ItCreateTableDdlTest.java | 23 +- .../internal/sql/engine/ItDataTypesTest.java | 2 +- .../ignite/internal/sql/engine/ItDmlTest.java | 4 +- .../internal/sql/engine/ItFunctionsTest.java | 2 - .../sql/engine/ItIndexesSystemViewTest.java | 2 +- .../ignite/internal/sql/engine/ItMetadataTest.java | 6 + .../sql/engine/ItNotNullConstraintClientTest.java | 79 ++ .../sql/engine/ItNotNullConstraintServerTest.java} | 19 +- .../sql/engine/ItNotNullConstraintTest.java | 279 +++++ .../internal/sql/engine/ItSqlOperatorsTest.java | 56 +- .../ignite/internal/sql/engine/ItZoneDdlTest.java | 151 ++- .../internal/sql/engine/ItZonesSystemViewTest.java | 13 +- .../datatypes/tests/BaseIndexDataTypeTest.java | 2 +- .../sql/threading/ItSqlApiThreadingTest.java | 20 +- .../sql/basic_queries/rename_columns_in_from.test | 79 ++ .../sql/contstraint/test_not_null_contraint.test | 60 - .../generic/test_in_list_of_single_element.test | 209 ++++ .../sql/function/json/test_json.test | 35 + .../sql/function/json/test_json_exists.test | 51 + .../sql/function/json/test_json_predicate.test | 83 ++ .../sql/function/json/test_json_query.test | 96 ++ .../sql/function/json/test_json_value.test | 56 + .../test_identifiers_trailing_underscore.test | 80 ++ .../sql/join/test_nested_outer_join.test | 69 ++ .../sql/join/test_not_distinct_from.test | 4 +- .../integrationTest/sql/set/test_except_all.test | 59 + .../integrationTest/sql/set/test_intersect.test | 86 ++ .../sql/subquery/scalar/test_delete_subquery.test | 1 + .../sql/subquery/scalar/test_update_subquery.test | 17 + .../scalar/test_update_subquery.test_ignore | 73 -- .../sql/subquery/table/test_subquery_union.test | 13 - .../sql/subquery/table/test_union_of_subquery.test | 97 ++ .../integrationTest/sql/types/row/test_row.test | 45 + .../sql/union/test_basic_union.test | 109 ++ modules/sql-engine/src/main/codegen/config.fmpp | 2 - .../src/main/codegen/includes/parserImpls.ftl | 6 +- .../internal/sql/api/AntiHijackAsyncResultSet.java | 8 +- .../ignite/internal/sql/api/IgniteSqlImpl.java | 24 +- .../internal/sql/api/StatementBuilderImpl.java | 59 +- .../ignite/internal/sql/api/StatementImpl.java | 66 +- .../internal/sql/engine/SqlQueryProcessor.java | 4 +- .../sql/engine/exec/DestinationFactory.java | 6 +- .../internal/sql/engine/exec/ExecutionContext.java | 2 +- .../internal/sql/engine/exec/RowHandler.java | 9 + .../internal/sql/engine/exec/SqlRowHandler.java | 18 + .../sql/engine/exec/UpdatableTableImpl.java | 25 + .../engine/exec/mapping/MappingServiceImpl.java | 53 +- .../internal/sql/engine/externalize/RelJson.java | 5 +- .../sql/engine/message/QueryStartRequest.java | 2 +- .../sql/engine/prepare/IgniteSqlValidator.java | 9 +- .../internal/sql/engine/prepare/PlannerHelper.java | 2 +- .../internal/sql/engine/prepare/PlannerPhase.java | 4 +- .../sql/engine/prepare/PrepareServiceImpl.java | 2 +- .../prepare/ddl/DdlSqlToCommandConverter.java | 4 +- .../rel/agg/IgniteColocatedAggregateBase.java | 8 + .../sql/engine/sql/IgniteSqlCreateIndex.java | 2 +- .../sql/engine/sql/IgniteSqlIndexType.java | 6 +- .../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 1 + .../sql/engine/trait/IgniteDistributions.java | 14 +- .../internal/sql/engine/util/IgniteResource.java | 3 + .../engine/util/SqlExceptionMapperProvider.java | 14 +- .../internal/lang/SqlExceptionMapperUtilTest.java | 38 +- .../internal/sql/api/StatementBuilderImplTest.java | 193 ++++ .../exec/mapping/MappingServiceImplTest.java | 28 +- .../exec/rel/TableScanNodeExecutionTest.java | 8 +- .../sql/engine/exec/row/SqlRowHandlerTest.java | 32 +- .../sql/engine/framework/ArrayRowHandler.java | 5 + .../planner/CorrelatedSubqueryPlannerTest.java | 2 +- .../sql/engine/planner/JoinCommutePlannerTest.java | 1 - .../prepare/ddl/DdlSqlToCommandConverterTest.java | 4 +- .../sql/DistributionZoneSqlDdlParserTest.java | 52 + .../internal/sql/engine/sql/SqlDdlParserTest.java | 10 +- .../internal/storage/MvPartitionStorage.java | 14 + .../storage/ThreadAssertingMvPartitionStorage.java | 12 + .../internal/storage/engine/MvTableStorage.java | 2 +- .../index/InconsistentIndexStateException.java} | 30 +- .../storage/index/IndexNotBuiltException.java} | 30 +- .../internal/storage/index/IndexStorage.java | 1 + .../internal/storage/index/SortedIndexStorage.java | 51 +- .../storage/index/StorageHashIndexDescriptor.java | 25 +- .../storage/index/StorageIndexDescriptor.java | 3 + .../index/StorageSortedIndexDescriptor.java | 25 +- .../index/ThreadAssertingSortedIndexStorage.java | 16 + .../ignite/internal/storage/util/StorageUtils.java | 14 + .../storage/index/StorageIndexDescriptorTest.java | 94 ++ .../storage/index/TestSortedIndexStorageTest.java | 5 + .../storage/AbstractMvPartitionStorageTest.java | 23 + .../storage/AbstractMvTableStorageTest.java | 311 ++++-- .../ignite/internal/storage/TestStorageUtils.java} | 23 +- .../storage/engine/AbstractStorageEngineTest.java | 10 +- .../storage/impl/TestMvPartitionStorage.java | 22 + .../index/AbstractHashIndexStorageTest.java | 49 +- .../storage/index/AbstractIndexStorageTest.java | 123 ++- .../index/AbstractSortedIndexStorageTest.java | 334 ++++-- .../index/impl/AbstractTestIndexStorage.java | 28 +- .../storage/index/impl/TestHashIndexStorage.java | 6 +- .../storage/index/impl/TestSortedIndexStorage.java | 107 +- .../pagememory/AbstractPageMemoryTableStorage.java | 10 +- .../PersistentPageMemoryStorageEngine.java | 32 +- .../VolatilePageMemoryStorageEngine.java | 2 +- .../index/AbstractPageMemoryIndexStorage.java | 4 + .../storage/pagememory/index/InlineUtils.java | 2 + .../index/hash/PageMemoryHashIndexStorage.java | 2 + .../pagememory/index/hash/io/HashIndexTreeIo.java | 2 +- .../index/sorted/PageMemorySortedIndexStorage.java | 108 +- .../index/sorted/io/SortedIndexTreeIo.java | 2 +- .../storage/pagememory/mv/IndexStorageFactory.java | 5 +- .../mv/PersistentPageMemoryMvPartitionStorage.java | 20 + .../mv/VolatilePageMemoryMvPartitionStorage.java | 28 + .../storage/pagememory/index/InlineUtilsTest.java | 4 +- ...ageMemoryMvPartitionStorageConcurrencyTest.java | 4 +- ...rsistentPageMemoryMvPartitionStorageGcTest.java | 4 +- ...PersistentPageMemoryMvPartitionStorageTest.java | 4 +- .../storage/rocksdb/RocksDbMetaStorage.java | 10 +- .../storage/rocksdb/RocksDbMvPartitionStorage.java | 52 +- .../storage/rocksdb/RocksDbTableStorage.java | 26 +- .../rocksdb/index/AbstractRocksDbIndexStorage.java | 14 +- .../rocksdb/index/RocksDbHashIndexStorage.java | 4 +- .../rocksdb/index/RocksDbSortedIndexStorage.java | 157 ++- .../rocksdb/instance/SharedRocksDbInstance.java | 2 + modules/table/build.gradle | 1 + .../ItInternalTableReadOnlyScanTest.java | 9 - .../ignite/distributed/ReplicaUnavailableTest.java | 4 +- .../ItDisasterRecoveryReconfigurationTest.java | 4 +- .../rebalance/ItRebalanceDistributedTest.java | 21 +- .../ignite/internal/table/ItColocationTest.java | 13 +- .../threading/ItKvRecordApiThreadingTest.java | 28 +- .../ignite/internal/table/AbstractTableView.java | 29 +- .../table/distributed/SortedIndexLocker.java | 2 +- .../internal/table/distributed/TableManager.java | 147 ++- .../table/distributed/TableMessageGroup.java | 4 +- .../disaster/DisasterRecoveryManager.java | 217 +++- .../disaster/GlobalPartitionState.java} | 21 +- .../disaster/GlobalPartitionStateEnum.java} | 21 +- .../distributed/disaster/LocalPartitionState.java} | 21 +- ...nState.java => LocalPartitionStateMessage.java} | 2 +- .../messages/LocalPartitionStatesResponse.java | 2 +- .../ignite/internal/table/distributed/gc/MvGc.java | 77 +- .../distributed/raft/PartitionDataStorage.java | 14 + .../table/distributed/raft/PartitionListener.java | 20 +- .../snapshot/FullStateTransferIndexChooser.java | 15 +- .../SnapshotAwarePartitionDataStorage.java | 10 + .../replicator/IncompatibleSchemaException.java | 3 +- .../replicator/PartitionReplicaListener.java | 18 +- .../replicator/TransactionStateResolver.java | 2 +- .../distributed/storage/InternalTableImpl.java | 75 +- .../wrappers/DelegatingPlacementDriver.java | 6 - .../internal/table/distributed/IndexBaseTest.java | 48 +- .../table/distributed/SortedIndexLockerTest.java | 7 +- .../table/distributed/StorageCleanupTest.java | 45 +- .../distributed/StorageUpdateHandlerTest.java | 45 +- .../distributed/TableManagerRecoveryTest.java | 6 +- .../table/distributed/TableManagerTest.java | 37 + .../internal/table/distributed/gc/MvGcTest.java | 34 +- .../PersistentPageMemoryGcUpdateHandlerTest.java | 4 +- .../raft/PartitionCommandListenerTest.java | 6 +- .../PartitionReplicaListenerIndexLockingTest.java | 8 +- .../replication/PartitionReplicaListenerTest.java | 60 +- .../ExecutorInclinedPlacementDriverTest.java | 11 - .../apache/ignite/distributed/ItTxTestCluster.java | 9 +- .../distributed/TestPartitionDataStorage.java | 10 + .../ignite/internal/table/TableTestUtils.java | 11 +- .../table/impl/DummyInternalTableImpl.java | 9 +- .../ignite/internal/tx/impl/HeapLockManager.java | 75 +- .../internal/tx/impl/ReadOnlyTransactionImpl.java | 2 - .../internal/tx/impl/TransactionInflights.java | 49 +- .../ignite/internal/tx/impl/TxManagerImpl.java | 41 +- .../tx/impl/VolatileTxStateMetaStorage.java | 8 +- .../state/ThreadAssertingTxStateStorage.java | 14 - .../internal/tx/storage/state/TxStateStorage.java | 16 - .../state/rocksdb/TxStateRocksDbStorage.java | 69 -- .../apache/ignite/internal/tx/TxManagerTest.java | 35 +- .../storage/state/AbstractTxStateStorageTest.java | 33 - .../tx/storage/state/test/TestTxStateStorage.java | 22 - .../internal/worker/CriticalWorkerWatchdog.java | 11 + 420 files changed, 9535 insertions(+), 4441 deletions(-) copy modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/{DropZoneEntry.java => SetDefaultZoneEntry.java} (71%) create mode 100644 modules/catalog/tech-notes/acceptUpdateFlow.puml create mode 100644 modules/catalog/tech-notes/accept_update_flow.png create mode 100644 modules/catalog/tech-notes/applyUpdateFlow.puml create mode 100644 modules/catalog/tech-notes/apply_update_flow.png create mode 100644 modules/client/src/main/java/org/apache/ignite/internal/client/tx/ClientLazyTransaction.java create mode 100644 modules/compute/jobs.gradle delete mode 100644 modules/compute/src/integrationTest/resources/units/ignite-it-jobs-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/integrationTest/resources/units/ignite-jobs-1.0-SNAPSHOT-src.zip delete mode 100644 modules/compute/src/integrationTest/resources/units/ignite-ut-job1-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/integrationTest/resources/units/ignite-ut-job2-1.0-SNAPSHOT.jar copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/IncompatibleSchemaException.java => compute/src/jobs/java/org/apache/ignite/internal/compute/ConcatJob.java} (59%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => compute/src/jobs/java/org/apache/ignite/internal/compute/FailingJob.java} (66%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => compute/src/jobs/java/org/apache/ignite/internal/compute/GetNodeNameJob.java} (67%) copy modules/{api/src/main/java/org/apache/ignite/catalog/IndexType.java => compute/src/jobs/java/org/apache/ignite/internal/compute/JobException.java} (81%) copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/IncompatibleSchemaException.java => compute/src/jobs/java/org/apache/ignite/internal/compute/SleepJob.java} (57%) delete mode 100644 modules/compute/src/test/README.md delete mode 100644 modules/compute/src/test/resources/units/ignite-jobs-1.0-SNAPSHOT-src.zip delete mode 100644 modules/compute/src/test/resources/units/unit1/1.0.0/ignite-ut-job1-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/2.0.0/ignite-ut-job2-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/3.0.1/ignite-ut-job1-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/3.0.1/ignite-ut-job2-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/3.0.2/ignite-ut-job1-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/3.0.2/subdir/ignite-ut-job2-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit1/4.0.0/unit1-1.0-corrupted.jar delete mode 100644 modules/compute/src/test/resources/units/unit2/1.0.0/ignite-ut-job1-1.0-SNAPSHOT.jar delete mode 100644 modules/compute/src/test/resources/units/unit2/2.0.0/ignite-ut-job2-1.0-SNAPSHOT.jar copy modules/{api/src/main/java/org/apache/ignite/catalog/IndexType.java => compute/src/unit1/java/org/apache/ignite/internal/compute/Job1Utility.java} (87%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => compute/src/unit1/java/org/apache/ignite/internal/compute/UnitJob.java} (71%) copy modules/{api/src/main/java/org/apache/ignite/catalog/IndexType.java => compute/src/unit2/java/org/apache/ignite/internal/compute/Job2Utility.java} (87%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => compute/src/unit2/java/org/apache/ignite/internal/compute/UnitJob.java} (70%) copy modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/impl/{SinkFactory.java => LogSinkFactory.java} (73%) copy modules/{low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/LowWatermarkChangedListener.java => eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/EventSerializerFactory.java} (62%) rename modules/eventlog/src/main/java/org/apache/ignite/internal/eventlog/ser/{JsonEventSerializer.java => JacksonBasedJsonSerializer.java} (64%) create mode 100644 modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/CustomEvent.java create mode 100644 modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/CustomEventBuilder.java rename modules/eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/{JsonEventSerializerTest.java => JacksonBasedJsonSerializerTest.java} (66%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/Message.java} (69%) rename modules/low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/{LowWatermarkChangedListener.java => event/ChangeLowWatermarkEventParameters.java} (60%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/event/LowWatermarkEvent.java} (62%) copy modules/{api/src/main/java/org/apache/ignite/catalog/IndexType.java => low-watermark/src/main/java/org/apache/ignite/internal/lowwatermark/event/LowWatermarkEventParameters.java} (78%) create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ItJraftServerLogPathTest.java delete mode 100644 modules/rest-api/openapi/openapi.properties delete mode 100644 modules/rest-api/openapi/openapi.yaml create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/DisasterRecoveryApi.java create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStateResponse.java copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionStatesResponse.java => rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStatesResponse.java} (51%) create mode 100644 modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/LocalPartitionStateResponse.java copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages => rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery}/LocalPartitionStatesResponse.java (51%) create mode 100644 modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/recovery/ItDisasterRecoveryControllerTest.java create mode 100644 modules/rest/src/main/java/org/apache/ignite/internal/rest/recovery/DisasterRecoveryController.java create mode 100644 modules/rest/src/main/java/org/apache/ignite/internal/rest/recovery/DisasterRecoveryFactory.java create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/schemasync/ItSchemaSyncAndImplicitTransactionsTest.java create mode 100644 modules/schema/src/test/java/org/apache/ignite/internal/schema/marshaller/MarshallerUtilTest.java create mode 100644 modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItNotNullConstraintClientTest.java copy modules/sql-engine/src/{main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => integrationTest/java/org/apache/ignite/internal/sql/engine/ItNotNullConstraintServerTest.java} (72%) create mode 100644 modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItNotNullConstraintTest.java create mode 100644 modules/sql-engine/src/integrationTest/sql/basic_queries/rename_columns_in_from.test create mode 100644 modules/sql-engine/src/integrationTest/sql/function/generic/test_in_list_of_single_element.test create mode 100644 modules/sql-engine/src/integrationTest/sql/function/json/test_json_exists.test create mode 100644 modules/sql-engine/src/integrationTest/sql/function/json/test_json_predicate.test create mode 100644 modules/sql-engine/src/integrationTest/sql/function/json/test_json_query.test create mode 100644 modules/sql-engine/src/integrationTest/sql/function/json/test_json_value.test create mode 100644 modules/sql-engine/src/integrationTest/sql/identifiers/test_identifiers_trailing_underscore.test create mode 100644 modules/sql-engine/src/integrationTest/sql/join/test_nested_outer_join.test create mode 100644 modules/sql-engine/src/integrationTest/sql/set/test_except_all.test create mode 100644 modules/sql-engine/src/integrationTest/sql/set/test_intersect.test delete mode 100644 modules/sql-engine/src/integrationTest/sql/subquery/scalar/test_update_subquery.test_ignore delete mode 100644 modules/sql-engine/src/integrationTest/sql/subquery/table/test_subquery_union.test create mode 100644 modules/sql-engine/src/integrationTest/sql/subquery/table/test_union_of_subquery.test create mode 100644 modules/sql-engine/src/integrationTest/sql/types/row/test_row.test create mode 100644 modules/sql-engine/src/integrationTest/sql/union/test_basic_union.test create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/api/StatementBuilderImplTest.java copy modules/storage-api/src/{test/java/org/apache/ignite/internal/storage/index/TestSortedIndexStorageTest.java => main/java/org/apache/ignite/internal/storage/index/InconsistentIndexStateException.java} (50%) copy modules/storage-api/src/{test/java/org/apache/ignite/internal/storage/index/TestSortedIndexStorageTest.java => main/java/org/apache/ignite/internal/storage/index/IndexNotBuiltException.java} (53%) create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/index/StorageIndexDescriptorTest.java copy modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/IncompatibleSchemaException.java => storage-api/src/testFixtures/java/org/apache/ignite/internal/storage/TestStorageUtils.java} (57%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalPartitionState.java} (64%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalPartitionStateEnum.java} (66%) copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/sql/IgniteSqlIndexType.java => table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalPartitionState.java} (64%) rename modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/{LocalPartitionState.java => LocalPartitionStateMessage.java} (96%)