This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a change to branch colocation
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from de8043c270c Merge remote-tracking branch 'origin/main' into colocation
add e5eb0d2dca0 IGNITE-24844 Perform all catalog compaction computations
using the dedicated executor (#5482)
add dfe466fb04e IGNITE-24944 Improve TrackerClosedException handling
(#5510)
add 2ca96252861 IGNITE-24586 Tuple API. Add methods to reading byte array
values (#5486)
add b0dbf60d933 IGNITE-24930 Catalog. Write protocol version into
metastore on startup (#5502)
add 669d50add65 Bump com.netflix.nebula.ospackage from 11.11.1 to 11.11.2
(#5504)
add 8c6f3bf714b IGNITE-24584: Sql. IgniteNameUtils.parseIdentifier must be
compatible with Calcite's sql identifier (#5496)
add 30b3e242670 IGNITE-24955 Fix current node address resolving in
DefaultMessagingService#resolveRecipientAddress (#5519)
add 28825a33cd5 IGNITE-24950 Do not allow different Ignite versions to
establish network connections (#5514)
add d228d9be133 IGNITE-24951 Remove validation for Ignite version match on
join (#5516)
add fc80eadf7a4 IGNITE-24827 .NET: Fix error in log on graceful disconnect
(#5522)
add a1a205e8edb IGNITE-24552 Improve error message for invalid column
default (#5450)
add 60d2a519570 IGNITE-22484 Move criticalWorkers config to system root
(#5520)
add 855cd36857a IGNITE-24959 Change squash_commit_message to PR_TITLE in
.asf.yaml (#5521)
add 404006a3de6 IGNITE-22490 Move storageUpdate.batchByteLength config
value to replication.batchSizeBytes (#5518)
add 871108c9d91 IGNITE-24811 Fix restoration of empty tables storages for
zone-based colocation (#5424)
add b2b7cf3f10c IGNITE-24548 Enable speed-based throttling (#5474)
add 6b33cedd86e IGNITE-22494 Move metaStorage.idleSyncTimeInterval to
system root (#5524)
add 7108db505fb IGNITE-24969 Add assertions to "waitForCondition" calls in
tests (#5527)
add 47de84be9c0 IGNITE-24971 Fix flaky test (#5529)
add 132949f2710 IGNITE-24970 Fix wheels building by GitHub Actions (#5528)
add 8076b986934 IGNITE-24967 Add ability to explicitly specify read
timestamp for RO transactions (#5526)
add 61ca2438a51 IGNITE-24973 Only log long handling warnings in tests
(#5534)
add 4938df8d012 IGNITE-24588 Fixed client-side tuple serialization when
the schema has field names containing non-standard characters (#5493)
add cf0678d8831 IGNITE-24949 Refactor createTableLocally (#5512)
add 63cf4bd7bcd IGNITE-23439 C++: Implement query cancellation (#5532)
add 1e7c76b3636 IGNITE-24982 C++: Add missing headers to public (#5540)
add bf7a16e7da4 IGNITE-24843 Sql. Add tests to verify indexes of temporal
types (#5517)
add 68bb7056ebd IGNITE-24977 Ignore tree-sitter update (#5537)
add fde7e392f0d Merge remote-tracking branch 'origin/main' into colocation
No new revisions were added by this update.
Summary of changes:
.asf.yaml | 2 +-
.github/dependabot.yml | 4 +
.github/workflows/python_dbapi_wheels.yml | 10 +-
.../config/cluster-config.adoc | 37 +-
.../administrators-guide/config/node-config.adoc | 44 +-
gradle/libs.versions.toml | 4 +-
modules/api/build.gradle | 1 +
.../apache/ignite/lang/util/IgniteNameUtils.java | 25 +-
.../main/java/org/apache/ignite/table/Tuple.java | 20 +
.../java/org/apache/ignite/table/TupleImpl.java | 12 +
.../org/apache/ignite/table/QualifiedNameTest.java | 12 +-
.../org/apache/ignite/table/TupleImplTest.java | 6 +
.../ignite/table/AbstractImmutableTupleTest.java | 88 ++++
.../compaction/CatalogCompactionRunner.java | 123 +++--
.../CatalogCompactionRunnerSelfTest.java | 61 ++-
.../commands/AlterTableAlterColumnCommand.java | 24 +-
.../internal/catalog/storage/UpdateLogImpl.java | 24 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 2 +-
.../catalog/CatalogManagerRecoveryTest.java | 10 +-
...AlterTableAlterColumnCommandValidationTest.java | 8 +-
.../catalog/storage/UpdateLogImplTest.java | 69 ++-
.../init/ItClusterInitDefaultMsCmgTest.java | 3 +-
.../commands/cluster/init/ItClusterInitTest.java | 3 +-
.../configuration/ItConfigCommandTest.java | 8 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 4 -
.../cli/commands/cluster/ClusterInitTest.java | 2 +-
.../cluster-configuration-with-default.conf | 2 +-
.../table/MutableTupleBinaryTupleAdapter.java | 16 +
.../handler/requests/table/ClientTableCommon.java | 3 +-
.../client/table/ClientTupleSerializer.java | 9 +-
.../ignite/client/ClientKeyValueViewTest.java | 4 +-
.../apache/ignite/client/ClientRecordViewTest.java | 6 +-
.../org/apache/ignite/client/ClientTupleTest.java | 24 +
.../java/org/apache/ignite/client/CustomTuple.java | 12 +
.../management/ItClusterVersionUpgradeTest.java | 105 ++++
.../management/raft/ItCmgRaftServiceTest.java | 28 -
.../cluster/management/raft/ValidationManager.java | 5 -
modules/configuration-system/build.gradle | 1 +
.../SystemDistributedConfigurationSchema.java | 13 +
.../SystemLocalConfigurationSchema.java | 6 +
.../internal/lang/IgniteSystemProperties.java | 3 +
.../internal/properties/IgniteProductVersion.java | 3 +-
.../internal/table/criteria/SqlRowProjection.java | 12 +
.../DefaultIgniteProductVersionSource.java} | 17 +-
.../version/IgniteProductVersionSource.java} | 32 +-
.../java/org/apache/ignite/table/TupleHelper.java | 0
.../ignite/internal/util/IgniteNameUtilsTest.java | 23 +-
.../DefaultIgniteProductVersionSourceTest.java} | 25 +-
.../testframework/BaseIgniteAbstractTest.java | 1 +
...niteDistributionZoneManagerNodeRestartTest.java | 4 +-
.../rebalance/ItRebalanceDistributedTest.java | 20 +-
.../DistributionZonesSchedulersTest.java | 1 +
.../DistributionZoneCausalityDataNodesTest.java | 8 +-
.../ignite/internal/index/IndexBuildTask.java | 14 +-
.../MetaStorageApiConfigurationModule.java | 40 --
.../MetaStorageConfigurationSchema.java | 39 --
.../MetaStorageExtensionConfigurationSchema.java | 31 --
modules/metastorage/build.gradle | 1 +
.../impl/ItIdempotentCommandCacheTest.java | 12 +-
.../impl/ItMetaStorageManagerImplTest.java | 6 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 12 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 8 +-
.../impl/MetaStorageLeaderElectionListener.java | 10 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 26 +-
.../metastorage/server/WatchProcessor.java | 5 +
.../metastorage/server/time/ClusterTimeImpl.java | 10 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 6 +-
.../MetaStorageLeaderElectionListenerTest.java | 14 +-
.../impl/MetaStorageManagerRecoveryTest.java | 6 +-
.../metastorage/server/time/ClusterTimeTest.java | 8 +-
.../impl/StandaloneMetaStorageManager.java | 14 +-
.../network/TrackableNetworkMessageHandler.java | 7 +-
.../network/netty/ItConnectionManagerTest.java | 10 +-
.../ArbitraryIgniteProductVersionSource.java} | 28 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 84 ++-
.../internal/network/DefaultMessagingService.java | 50 +-
.../internal/network/RecipientInetAddress.java | 75 +++
.../internal/network/netty/ConnectionManager.java | 29 +-
.../network/recovery/HandshakeManagerUtils.java | 6 +
.../recovery/RecoveryClientHandshakeManager.java | 75 ++-
.../recovery/RecoveryServerHandshakeManager.java | 31 +-
.../recovery/message/HandshakeRejectionReason.java | 22 +-
.../recovery/message/HandshakeStartMessage.java | 6 +
.../scalecube/ScaleCubeClusterServiceFactory.java | 9 +-
.../network/DefaultMessagingServiceTest.java | 67 ++-
.../network/netty/RecoveryHandshakeTest.java | 7 +-
.../RecoveryClientHandshakeManagerTest.java | 10 +-
.../RecoveryServerHandshakeManagerTest.java | 7 +-
.../message/HandshakeRejectionReasonTest.java | 72 +++
.../network/utils/ClusterServiceTestUtils.java | 52 +-
.../persistence/PersistentPageMemory.java | 3 +-
.../persistence/checkpoint/CheckpointManager.java | 4 +
.../persistence/checkpoint/Checkpointer.java | 17 +
.../throttling/PagesWriteSpeedBasedThrottle.java | 7 +-
.../throttling/PagesWriteThrottlePolicy.java | 3 +-
...edBasedMemoryConsumptionThrottlingStrategy.java | 30 +-
.../throttling/TargetRatioPagesWriteThrottle.java | 9 +-
...ntLockStateChecker.java => ThrottlingType.java} | 17 +-
.../throttling/PageMemoryThrottlingTest.java | 3 +
.../persistence/throttling/ThrottlingTest.java | 31 +-
.../replicator/AbstractZoneReplicationTest.java | 8 +-
.../replicator/ItAbstractColocationTest.java | 8 +-
.../partition/replicator/fixtures/Node.java | 19 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 586 +++++++++++++++++++++
.../PartitionReplicaLifecycleManager.java | 9 +-
.../replicator/raft/ZonePartitionRaftListener.java | 47 +-
.../raft/ZonePartitionRaftListenerTest.java | 72 ++-
.../MultiActorPlacementDriverTest.java | 6 +-
.../PlacementDriverManagerTest.java | 6 +-
modules/platforms/cpp/cmake/dependencies.cmake | 2 +
modules/platforms/cpp/ignite/client/CMakeLists.txt | 6 +
.../platforms/cpp/ignite/client/cancel_handle.cpp | 81 +++
.../platforms/cpp/ignite/client/cancel_handle.h | 90 ++++
.../client/{ssl_mode.h => cancellation_token.h} | 17 +-
.../client/detail/cancellation_token_impl.cpp | 122 +++++
.../ignite/client/detail/cancellation_token_impl.h | 91 ++++
.../ignite/client/detail/cluster_connection.cpp | 9 +-
.../cpp/ignite/client/detail/cluster_connection.h | 79 ++-
.../cpp/ignite/client/detail/node_connection.h | 17 +-
.../cpp/ignite/client/detail/sql/result_set_impl.h | 4 +-
.../cpp/ignite/client/detail/sql/sql_impl.cpp | 44 +-
.../cpp/ignite/client/detail/sql/sql_impl.h | 17 +-
.../cpp/ignite/client/detail/type_mapping_utils.h | 2 +-
modules/platforms/cpp/ignite/client/sql/sql.cpp | 13 +-
modules/platforms/cpp/ignite/client/sql/sql.h | 35 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 2 +
.../platforms/cpp/ignite/protocol/CMakeLists.txt | 2 +-
.../cpp/ignite/protocol/client_operation.h | 5 +-
.../cpp/tests/client-test/column_order_test.cpp | 8 +-
.../cpp/tests/client-test/ignite_runner_suite.h | 2 +-
.../client-test/schema_synchronization_test.cpp | 18 +-
.../platforms/cpp/tests/client-test/sql_test.cpp | 234 ++++++--
.../cpp/tests/client-test/transactions_test.cpp | 4 +-
.../cpp/tests/test-common/ignite_runner.cpp | 7 +
.../cpp/tests/test-common/ignite_runner.h | 12 +-
.../dotnet/Apache.Ignite.Tests/LoggingTests.cs | 3 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 6 +
modules/platforms/python/CMakeLists.txt | 1 +
modules/platforms/python/MANIFEST.in | 1 -
modules/platforms/python/cpp_module/CMakeLists.txt | 11 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 8 +-
.../raft/server/ItJraftCounterServerTest.java | 10 +-
.../ignite/raft/jraft/util/ThreadIdTest.java | 5 +-
.../ignite/internal/replicator/ReplicaManager.java | 13 +-
.../internal/replicator/ReplicaStateManager.java | 6 +-
.../ReplicationConfigurationSchema.java | 7 +
.../internal/benchmark/FutureTimeoutBenchmark.java | 3 +-
.../client/ItClientGetTableSchemaTest.java | 3 +-
.../configuration/ItClusterConfigurationTest.java | 4 +-
.../ItDistributedConfigurationPropertiesTest.java | 5 +-
.../ItDistributedConfigurationStorageTest.java | 6 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 4 +-
.../runner/app/ItIgniteNodeRestartTest.java | 19 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 37 +-
.../testframework/TestIgnitionManager.java | 11 +-
.../SchemaDistributedConfigurationModule.java | 2 +-
.../StorageUpdateConfigurationSchema.java | 36 --
.../StorageUpdateExtensionConfigurationSchema.java | 31 --
.../sql/engine/ItAlterTableAlterColumnTest.java | 103 +++-
.../internal/sql/engine/ItAlterTableDdlTest.java | 62 ++-
.../internal/sql/engine/ItCreateTableDdlTest.java | 56 +-
.../sql/engine/ItSqlMultiStatementTxTest.java | 2 +-
.../internal/sql/engine/ItTemporalIndexTest.java | 323 ++++++++++++
.../internal/sql/sqllogic/ItSqlLogicTest.java | 2 +-
.../src/main/codegen/includes/parserImpls.ftl | 17 +-
.../internal/sql/api/AsyncResultSetImpl.java | 12 +
.../prepare/ddl/DdlSqlToCommandConverter.java | 51 +-
.../internal/sql/engine/sql/IgniteSqlParser.java | 28 +-
.../apache/ignite/internal/sql/engine/TestRow.java | 12 +
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 96 +++-
.../sql/engine/sql/IgniteSqlParserSelfTest.java | 11 +
.../engine/sql/SqlAlterColumnDdlParserTest.java | 80 ++-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 108 +++-
.../sql/engine/util/CompositeSubscriptionTest.java | 1 +
.../pagememory/PersistentPageMemoryDataRegion.java | 109 +++-
.../PersistentPageMemoryDataStorageModule.java | 5 +
.../PersistentPageMemoryStorageEngine.java | 11 +
.../PersistentPageMemoryMvTableStorageTest.java | 1 +
.../PersistentPageMemoryStorageEngineTest.java | 1 +
.../PersistentPageMemoryHashIndexStorageTest.java | 1 +
...PersistentPageMemorySortedIndexStorageTest.java | 1 +
...ageMemoryMvPartitionStorageConcurrencyTest.java | 1 +
...rsistentPageMemoryMvPartitionStorageGcTest.java | 1 +
...PersistentPageMemoryMvPartitionStorageTest.java | 1 +
...entPageMemoryMvTableStorageConcurrencyTest.java | 1 +
.../ItAbstractInternalTableScanTest.java | 6 +-
.../ItInternalTableReadOnlyOperationsTest.java | 6 +-
.../apache/ignite/distributed/ItLockTableTest.java | 5 -
.../ItTxDistributedCleanupRecoveryTest.java | 1 -
...xDistributedTestSingleNodeNoCleanupMessage.java | 1 -
.../ignite/distributed/ItTxStateLocalMapTest.java | 5 -
.../table/ItKeyValueBinaryViewApiTest.java | 290 ++++++----
.../internal/table/ItKeyValueViewApiBaseTest.java | 6 +-
.../internal/table/ItKeyValueViewApiTest.java | 5 +-
.../table/ItKeyValueViewSimpleSchemaApiTest.java | 25 +-
.../internal/table/ItRecordBinaryViewApiTest.java | 456 ++++++++++------
.../internal/table/ItRecordViewApiBaseTest.java | 6 +-
.../ignite/internal/table/ItRecordViewApiTest.java | 25 +-
.../table/ItTableViewApiUnifiedBaseTest.java | 123 +++--
...blePartitionsRecoveryNoStaleRecoveriesTest.java | 4 +-
.../ItHighAvailablePartitionsRecoveryTest.java | 4 +-
.../internal/table/AbstractRowTupleAdapter.java | 16 +
...lueTupleStreamerPartitionAwarenessProvider.java | 3 +-
.../internal/table/MutableRowTupleAdapter.java | 12 +
.../TupleStreamerPartitionAwarenessProvider.java | 3 +-
.../table/distributed/StorageUpdateHandler.java | 14 +-
.../table/distributed/TableAssignmentsService.java | 254 +++++++++
.../internal/table/distributed/TableManager.java | 226 +-------
.../MinimumRequiredTimeCollectorServiceImpl.java | 3 +-
.../table/distributed/raft/PartitionListener.java | 17 +-
.../internal/table/InteropOperationsTest.java | 6 +-
.../internal/table/MutableRowTupleAdapterTest.java | 15 +
.../table/TableKvOperationsMockedTest.java | 6 +-
.../internal/table/distributed/IndexBaseTest.java | 6 +-
.../table/distributed/StorageCleanupTest.java | 6 +-
.../distributed/StorageUpdateHandlerTest.java | 6 +-
.../distributed/TableManagerRecoveryTest.java | 17 +-
.../table/distributed/TableManagerTest.java | 28 +-
.../PersistentPageMemoryGcUpdateHandlerTest.java | 1 +
.../raft/PartitionCommandListenerTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 6 +-
...itionReplicaListenerSortedIndexLockingTest.java | 6 +-
.../replication/PartitionReplicaListenerTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 7 +-
.../internal/table/TxInfrastructureTest.java | 5 -
.../table/impl/DummyInternalTableImpl.java | 20 +-
.../internal/table/impl/TestTupleBuilder.java | 12 +
.../ignite/internal/tx/InternalTxOptions.java | 28 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 20 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 25 +
.../CriticalWorkersConfigurationModule.java | 40 --
...riticalWorkersExtensionConfigurationSchema.java | 31 --
234 files changed, 5078 insertions(+), 1786 deletions(-)
create mode 100644
modules/cluster-management/src/integrationTest/java/org/apache/ignite/internal/cluster/management/ItClusterVersionUpgradeTest.java
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/NoOpFailureHandler.java
=>
core/src/main/java/org/apache/ignite/internal/version/DefaultIgniteProductVersionSource.java}
(63%)
mode change 100755 => 100644
copy modules/{api/src/main/java/org/apache/ignite/table/criteria/Operator.java
=>
core/src/main/java/org/apache/ignite/internal/version/IgniteProductVersionSource.java}
(70%)
rename modules/{table =>
core}/src/main/java/org/apache/ignite/table/TupleHelper.java (100%)
copy
modules/{cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/ClusterIdHolderTest.java
=>
core/src/test/java/org/apache/ignite/internal/version/DefaultIgniteProductVersionSourceTest.java}
(60%)
delete mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageApiConfigurationModule.java
delete mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageConfigurationSchema.java
delete mode 100644
modules/metastorage-api/src/main/java/org/apache/ignite/internal/metastorage/configuration/MetaStorageExtensionConfigurationSchema.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/index/VersionedConverter.java
=>
network/src/integrationTest/java/org/apache/ignite/internal/network/scalecube/ArbitraryIgniteProductVersionSource.java}
(55%)
create mode 100644
modules/network/src/main/java/org/apache/ignite/internal/network/RecipientInetAddress.java
create mode 100644
modules/network/src/test/java/org/apache/ignite/internal/network/recovery/message/HandshakeRejectionReasonTest.java
copy
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/{CheckpointLockStateChecker.java
=> ThrottlingType.java} (75%)
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/raft/ItZonePartitionRaftListenerRecoveryTest.java
create mode 100644 modules/platforms/cpp/ignite/client/cancel_handle.cpp
create mode 100644 modules/platforms/cpp/ignite/client/cancel_handle.h
copy modules/platforms/cpp/ignite/client/{ssl_mode.h => cancellation_token.h}
(74%)
create mode 100644
modules/platforms/cpp/ignite/client/detail/cancellation_token_impl.cpp
create mode 100644
modules/platforms/cpp/ignite/client/detail/cancellation_token_impl.h
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/StorageUpdateConfigurationSchema.java
delete mode 100644
modules/schema/src/main/java/org/apache/ignite/internal/schema/configuration/StorageUpdateExtensionConfigurationSchema.java
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItTemporalIndexTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableAssignmentsService.java
delete mode 100644
modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersConfigurationModule.java
delete mode 100644
modules/workers/src/main/java/org/apache/ignite/internal/worker/configuration/CriticalWorkersExtensionConfigurationSchema.java
