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 fde7e392f0d Merge remote-tracking branch 'origin/main' into colocation
add d7bc940c771 IGNITE-24986 Fixed throttling properties parsing and error
message (#5545)
add 43091d5a290 Bump asm from 9.7.1 to 9.8 (#5530)
add e4ba67a926b IGNITE-24561 Use direct mapping in client transactions.
add 1dfd79d2b8a IGNITE-24989 Adjust timeout on
ItClientDataStreamerLoadTest.testHighLoad (#5548)
add ce3eeabc526 IGNITE-24932 Fix hanging of module runner tests (#5501)
add 2907b367323 IGNITE-24980 Rename InternalTransaction#startTimestamp()
to schemaTimestamp() (#5550)
add 2a9f3c4b42c IGNITE-25003 Remove ALTER ZONE SET STORAGE PROFILES doc
(#5555)
add 756e68a6140 IGNITE-24788 Configurable coalescing for RAFT heartbeat
(#5477)
add 4c334bd2a8f IGNITE-24497 Rename docker image in docs (#5275)
add 84ddf9747af IGNITE-24702 Fix of CompactedException on the end of
rebalancing (#5468)
add cfc88f22976 IGNITE-24905 Fix MetricSetMbean doesn't support custom
composite metrics (#5481)
add 858c4c1b18e Bump Microsoft.Extensions.Logging.Console from 9.0.2 to
9.0.3 in /modules/platforms/dotnet (#5546)
add 844eab6f3e5 IGNITE-25004 Notify failure handler in CatalogManagerImpl
(#5554)
add 8a48d82a614 IGNITE-24985 Add a test where a node joins to the cluster
of two (#5542)
add 4d6523fa157 IGNITE-24837 C++: Fix error codes (#5557)
add d90b50e8707 IGNITE-22857 C++ Remove NUMBER and BITMASK types (#5558)
add a2968f7b66e Merge remote-tracking branch 'origin/main' into colocation
No new revisions were added by this update.
Summary of changes:
DEVNOTES.md | 4 +-
README.md | 2 +-
docs/_docs/sql-reference/distribution-zones.adoc | 1 -
examples/README.md | 26 +-
gradle/libs.versions.toml | 2 +-
modules/catalog-compaction/build.gradle | 1 +
.../compaction/ItCatalogCompactionTest.java | 4 +-
.../compaction/AbstractCatalogCompactionTest.java | 8 +-
modules/catalog/build.gradle | 2 +
.../internal/catalog/BulkUpdateProducer.java | 2 +-
.../ignite/internal/catalog/CatalogManager.java | 12 +
.../internal/catalog/CatalogManagerImpl.java | 34 +-
.../internal/catalog/commands/CatalogUtils.java | 4 +-
.../catalog/commands/CreateSchemaCommand.java | 4 +-
.../descriptors/CatalogHashIndexDescriptor.java | 13 +-
.../CatalogHashIndexDescriptorSerializers.java | 21 +-
.../descriptors/CatalogIndexDescriptor.java | 5 +-
.../descriptors/CatalogObjectDescriptor.java | 35 +-
.../descriptors/CatalogSchemaDescriptor.java | 6 +-
.../CatalogSchemaDescriptorSerializers.java | 20 +-
.../descriptors/CatalogSortedIndexDescriptor.java | 11 +-
.../CatalogSortedIndexDescriptorSerializers.java | 21 +-
.../descriptors/CatalogSystemViewDescriptor.java | 11 +-
.../CatalogSystemViewDescriptorSerializers.java | 20 +-
.../descriptors/CatalogTableDescriptor.java | 15 +-
.../CatalogTableDescriptorSerializers.java | 20 +-
.../catalog/descriptors/CatalogZoneDescriptor.java | 13 +-
.../CatalogZoneDescriptorSerializers.java | 21 +-
.../storage/AbstractChangeIndexStatusEntry.java | 9 +-
.../internal/catalog/storage/AlterColumnEntry.java | 5 +-
.../internal/catalog/storage/AlterZoneEntry.java | 5 +-
.../internal/catalog/storage/DropColumnsEntry.java | 5 +-
.../internal/catalog/storage/DropSchemaEntry.java | 3 +-
.../internal/catalog/storage/DropTableEntry.java | 5 +-
.../internal/catalog/storage/DropZoneEntry.java | 3 +-
.../internal/catalog/storage/NewColumnsEntry.java | 5 +-
.../internal/catalog/storage/NewIndexEntry.java | 7 +-
.../internal/catalog/storage/NewSchemaEntry.java | 5 +-
.../catalog/storage/NewSystemViewEntry.java | 7 +-
.../internal/catalog/storage/NewTableEntry.java | 7 +-
.../internal/catalog/storage/NewZoneEntry.java | 5 +-
.../catalog/storage/ObjectIdGenUpdateEntry.java | 3 +-
.../internal/catalog/storage/RemoveIndexEntry.java | 5 +-
.../internal/catalog/storage/RenameIndexEntry.java | 9 +-
.../internal/catalog/storage/RenameTableEntry.java | 5 +-
.../catalog/storage/SetDefaultZoneEntry.java | 6 +-
.../internal/catalog/storage/UpdateEntry.java | 5 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 78 ++--
.../internal/catalog/CatalogManagerSelfTest.java | 5 +-
.../internal/catalog/CatalogSystemViewTest.java | 5 +-
.../commands/AbstractCommandValidationTest.java | 8 +-
.../catalog/commands/CatalogUtilsTest.java | 2 +-
.../descriptors/CatalogSchemaDescriptorTest.java | 3 +-
.../descriptors/CatalogZoneDescriptorTest.java | 2 +-
.../storage/CatalogEntrySerializationTest.java | 98 +++--
.../CatalogSerializationCompatibilityTest.java | 68 ++--
...logSerializationCompatibilityV1ReadsV1Test.java | 4 +-
...logSerializationCompatibilityV2ReadsV1Test.java | 4 +-
...logSerializationCompatibilityV2ReadsV2Test.java | 4 +-
.../storage/TestCatalogObjectDescriptors.java | 27 +-
.../catalog/storage/UpdateLogImplTest.java | 3 +-
.../internal/catalog/BaseCatalogManagerTest.java | 4 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 38 +-
.../internal/client/proto/HandshakeUtils.java | 3 -
.../client/proto/ProtocolBitmaskFeature.java | 7 +-
.../internal/client/proto/tx/ClientTxUtils.java} | 13 +-
.../ignite/client/handler/ItClientHandlerTest.java | 4 +-
.../ignite/client/handler/ClientContext.java | 9 +-
.../ignite/client/handler/ClientHandlerModule.java | 3 +-
.../handler/ClientInboundMessageHandler.java | 44 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 2 +-
.../requests/sql/ClientSqlExecuteRequest.java | 2 +-
.../sql/ClientSqlQueryMetadataRequest.java | 2 +-
.../handler/requests/table/ClientTableCommon.java | 97 +++--
.../table/ClientTupleContainsAllKeysRequest.java | 6 +-
.../table/ClientTupleContainsKeyRequest.java | 6 +-
.../table/ClientTupleDeleteAllExactRequest.java | 6 +-
.../table/ClientTupleDeleteAllRequest.java | 6 +-
.../table/ClientTupleDeleteExactRequest.java | 6 +-
.../requests/table/ClientTupleDeleteRequest.java | 6 +-
.../requests/table/ClientTupleGetAllRequest.java | 11 +-
.../table/ClientTupleGetAndDeleteRequest.java | 6 +-
.../table/ClientTupleGetAndReplaceRequest.java | 6 +-
.../table/ClientTupleGetAndUpsertRequest.java | 6 +-
.../requests/table/ClientTupleGetRequest.java | 7 +-
.../table/ClientTupleInsertAllRequest.java | 6 +-
.../requests/table/ClientTupleInsertRequest.java | 6 +-
.../table/ClientTupleReplaceExactRequest.java | 6 +-
.../requests/table/ClientTupleReplaceRequest.java | 6 +-
.../table/ClientTupleUpsertAllRequest.java | 6 +-
.../requests/table/ClientTupleUpsertRequest.java | 6 +-
.../requests/tx/ClientTransactionBeginRequest.java | 58 ++-
.../tx/ClientTransactionCommitRequest.java | 111 ++++-
.../tx/ClientTransactionRollbackRequest.java | 33 +-
.../ignite/internal/client/PartitionMapping.java} | 40 +-
.../ignite/internal/client/ReliableChannel.java | 78 +++-
.../ignite/internal/client/TcpClientChannel.java | 3 +-
.../ignite/internal/client/WriteContext.java} | 12 +-
.../internal/client/compute/ClientCompute.java | 10 +-
.../client/compute/ClientJobExecution.java | 4 +
.../ignite/internal/client/sql/ClientSql.java | 10 +-
.../internal/client/table/ClientDataStreamer.java | 1 +
.../client/table/ClientKeyValueBinaryView.java | 86 ++--
.../internal/client/table/ClientKeyValueView.java | 102 ++---
.../client/table/ClientPartitionManager.java | 8 +-
.../client/table/ClientRecordBinaryView.java | 74 ++--
.../client/table/ClientRecordSerializer.java | 18 +-
.../internal/client/table/ClientRecordView.java | 70 ++--
.../ignite/internal/client/table/ClientTable.java | 203 +++++++---
.../client/table/ClientTupleSerializer.java | 116 ++++--
.../client/table/PartitionAwarenessProvider.java | 31 +-
.../internal/client/tx/ClientLazyTransaction.java | 26 +-
.../internal/client/tx/ClientTransaction.java | 259 +++++++++++-
.../internal/client/tx/ClientTransactions.java | 38 +-
.../client/ObservableTimestampPropagationTest.java | 7 +-
.../ignite/client/TestClientHandlerModule.java | 6 +-
.../ignite/client/fakes/FakeInternalTable.java | 5 +
.../apache/ignite/client/fakes/FakeTxManager.java | 15 +-
.../RepeatedFinishClientTransactionTest.java | 104 ++++-
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../management/ClusterManagementGroupManager.java | 7 +-
.../ClusterManagementGroupManagerTest.java | 2 +-
...tDistributionZoneMetaStorageCompactionTest.java | 75 +++-
...niteDistributionZoneManagerNodeRestartTest.java | 7 +-
.../rebalance/ItRebalanceDistributedTest.java | 1 +
.../distributionzones/DataNodesHistory.java | 1 +
.../distributionzones/DistributionZoneManager.java | 32 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 13 +-
.../DistributionZoneRebalanceEngineV2.java | 12 +-
.../RebalanceMinimumRequiredTimeProviderImpl.java | 111 +++--
.../distributionzones/rebalance/RebalanceUtil.java | 33 +-
.../ZoneRebalanceRaftGroupEventsListener.java | 12 +-
.../rebalance/ZoneRebalanceUtil.java | 40 +-
.../DistributionZoneCausalityDataNodesTest.java | 450 +++++++++++----------
.../DistributionZoneRebalanceEngineTest.java | 7 +-
...balanceMinimumRequiredTimeProviderImplTest.java | 7 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 9 +-
.../ZoneRebalanceUtilUpdateAssignmentsTest.java | 6 +-
modules/distribution-zones/tech-notes/rebalance.md | 6 +-
.../ignite/internal/jdbc/JdbcConnection.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 3 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 27 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 2 +-
.../impl/MetaStorageManagerRecoveryTest.java | 2 +-
.../impl/StandaloneMetaStorageManager.java | 12 +-
.../metrics/exporters/jmx/MetricSetMbean.java | 6 +
.../metrics/exporters/jmx/JmxExporterTest.java | 149 ++++++-
.../partition/replicator/fixtures/Node.java | 1 +
.../PartitionReplicaLifecycleManager.java | 22 +-
.../ReadWriteSingleRowPkReplicaRequest.java | 6 +
.../ReadWriteSingleRowReplicaRequest.java | 6 +
.../ReadWriteSwapRowReplicaRequest.java | 7 +-
.../PartitionReplicaLifecycleManagerTest.java | 10 +-
.../schema/CatalogValidationSchemasSourceTest.java | 4 +-
.../ignite/client/detail/argument_check_utils.h | 2 +-
.../client/detail/cancellation_token_impl.cpp | 4 +-
.../ignite/client/detail/cluster_connection.cpp | 8 +-
.../cpp/ignite/client/detail/table/table_impl.h | 3 +-
.../platforms/cpp/ignite/client/detail/utils.cpp | 12 -
.../platforms/cpp/ignite/client/ignite_client.cpp | 2 +-
.../cpp/ignite/client/table/ignite_tuple.h | 9 +-
modules/platforms/cpp/ignite/common/CMakeLists.txt | 3 +-
modules/platforms/cpp/ignite/common/bit_array.h | 153 -------
.../platforms/cpp/ignite/common/bit_array_test.cpp | 238 -----------
modules/platforms/cpp/ignite/common/ignite_error.h | 52 ++-
.../platforms/cpp/ignite/common/ignite_result.h | 2 +-
modules/platforms/cpp/ignite/common/ignite_type.h | 6 -
modules/platforms/cpp/ignite/common/primitive.h | 29 +-
.../platforms/cpp/ignite/common/primitive_test.cpp | 2 -
.../transactions.cpp => common/uuid.cpp} | 18 +-
modules/platforms/cpp/ignite/common/uuid.h | 7 +
.../network/detail/win/win_async_client_pool.cpp | 2 +-
.../cpp/ignite/network/length_prefix_codec.cpp | 2 +-
.../ignite/network/ssl/secure_socket_client.cpp | 4 +-
.../cpp/ignite/network/ssl/secure_utils.cpp | 2 +-
.../cpp/ignite/odbc/app/application_data_buffer.h | 9 -
.../ignite/odbc/query/column_metadata_query.cpp | 2 +-
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 4 -
.../cpp/ignite/odbc/query/type_info_query.cpp | 5 +-
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 1 +
modules/platforms/cpp/ignite/odbc/type_traits.cpp | 12 +-
modules/platforms/cpp/ignite/protocol/messages.cpp | 6 +-
.../cpp/ignite/protocol/protocol_version.cpp | 5 +-
modules/platforms/cpp/ignite/protocol/utils.cpp | 42 +-
modules/platforms/cpp/ignite/protocol/utils.h | 7 -
.../cpp/tests/client-test/all_fields_type.h | 1 -
.../cpp/tests/odbc-test/meta_queries_test.cpp | 2 +-
.../Apache.Ignite.Tests/Apache.Ignite.Tests.csproj | 2 +-
.../apache/ignite/internal/raft/RaftManager.java | 49 +--
.../raft/RaftNodeDisruptorConfiguration.java | 52 ---
.../ignite/internal/raft/ItLearnersTest.java | 12 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 18 +-
.../internal/raft/ItRaftGroupServiceTest.java | 124 +++++-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 2 +
.../java/org/apache/ignite/internal/raft/Loza.java | 71 +---
.../internal/raft/server/RaftGroupOptions.java | 48 ++-
.../internal/raft/server/impl/JraftServerImpl.java | 18 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 26 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 70 ++--
.../raft/jraft/disruptor/StripedDisruptor.java | 28 +-
.../ignite/raft/jraft/option/NodeOptions.java | 18 +
.../rpc/impl/core/DefaultRaftClientService.java | 3 +-
.../ignite/disruptor/StripedDisruptorTest.java | 7 +
.../org/apache/ignite/internal/raft/LozaTest.java | 5 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 2 +
.../raft/jraft/core/ReadOnlyServiceTest.java | 2 +
.../raft/jraft/storage/impl/LogManagerTest.java | 2 +
modules/runner/build.gradle | 20 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 17 +-
...sertKvBenchmark.java => ClientKvBenchmark.java} | 72 ++--
...sertKvBenchmark.java => RemoteKvBenchmark.java} | 101 +----
.../internal/client/ItClientDirectMappingTest.java | 150 +++++++
.../ignite/internal/runner/app/ItAddNodeTest.java} | 39 +-
.../runner/app/ItIgniteNodeRestartTest.java | 7 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 2 +
.../app/client/ItAbstractThinClientTest.java | 4 +-
.../app/client/ItThinClientTransactionsTest.java | 253 +++++++++++-
.../streamer/ItClientDataStreamerLoadTest.java | 2 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 1 +
.../ignite/internal/schema/SchemaManagerTest.java | 4 +-
.../internal/sql/engine/SqlQueryProcessor.java | 2 +-
.../sql/engine/exec/fsm/QueryExecutor.java | 2 +-
.../sql/engine/tx/QueryTransactionContextImpl.java | 2 +-
.../sql/engine/framework/ExplicitTxContext.java | 2 +-
.../sql/engine/framework/NoOpTransaction.java | 7 +-
.../pagememory/PersistentPageMemoryDataRegion.java | 6 +-
.../disaster/system/ItCmgDisasterRecoveryTest.java | 4 +-
.../ignite/internal/table/AbstractTableView.java | 2 +-
.../ignite/internal/table/InternalTable.java | 8 +
.../table/distributed/TableAssignmentsService.java | 7 +-
.../internal/table/distributed/TableManager.java | 11 +-
.../distributed/disaster/GroupUpdateRequest.java | 35 +-
.../replicator/PartitionReplicaListener.java | 58 ++-
.../distributed/storage/InternalTableImpl.java | 72 ++--
.../ignite/internal/utils/RebalanceUtilEx.java | 21 +-
.../distributed/TableManagerRecoveryTest.java | 3 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../disaster/DisasterRecoveryMsInvokeTest.java | 11 +-
modules/table/tech-notes/rebalance.md | 16 +-
.../ItDisasterRecoveryReconfigurationTest.java | 4 +-
.../TransactionExpirationRegistryBenchmark.java | 7 +-
.../ignite/internal/tx/InternalTransaction.java | 20 +-
.../org/apache/ignite/internal/tx/TxManager.java | 13 +
.../tx/impl/PublicApiThreadingTransaction.java | 9 +-
.../internal/tx/impl/ReadOnlyTransactionImpl.java | 8 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 9 +-
.../tx/impl/RemoteReadWriteTransaction.java | 167 ++++++++
.../tx/impl/TransactionExpirationRegistry.java | 61 ++-
.../ignite/internal/tx/impl/TxManagerImpl.java | 70 +++-
.../tx/impl/ReadOnlyTransactionImplTest.java | 2 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 2 +-
...ransactionExpirationRegistryConcurrentTest.java | 11 +-
.../tx/impl/TransactionExpirationRegistryTest.java | 15 +
.../internal/tx/test/ItTransactionTestUtils.java | 27 ++
packaging/build.gradle | 2 +-
packaging/docker/docker-compose.yml | 2 +-
256 files changed, 3940 insertions(+), 2361 deletions(-)
copy
modules/{api/src/main/java/org/apache/ignite/table/DataStreamerOperationType.java
=>
client-common/src/main/java/org/apache/ignite/internal/client/proto/tx/ClientTxUtils.java}
(79%)
copy
modules/{client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/event/JdbcQueryCloseResult.java
=>
client/src/main/java/org/apache/ignite/internal/client/PartitionMapping.java}
(54%)
copy
modules/{api/src/main/java/org/apache/ignite/table/partition/Partition.java =>
client/src/main/java/org/apache/ignite/internal/client/WriteContext.java} (78%)
delete mode 100644 modules/platforms/cpp/ignite/common/bit_array.h
delete mode 100644 modules/platforms/cpp/ignite/common/bit_array_test.cpp
copy modules/platforms/cpp/ignite/{client/transaction/transactions.cpp =>
common/uuid.cpp} (72%)
delete mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/RaftNodeDisruptorConfiguration.java
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{UpsertKvBenchmark.java
=> ClientKvBenchmark.java} (68%)
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{UpsertKvBenchmark.java
=> RemoteKvBenchmark.java} (50%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/client/ItClientDirectMappingTest.java
copy
modules/{metrics/src/integrationTest/java/org/apache/ignite/internal/metrics/exporters/ItMetricsTest.java
=>
runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItAddNodeTest.java}
(51%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/RemoteReadWriteTransaction.java
