You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2025/03/21 13:43:07 UTC
(ignite-3) branch ignite-24805 updated (ffec8f887cb -> 57b3e5f9f23)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-24805
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard ffec8f887cb Avoid boxing/unboxing in catalog module
discard 5f720dbf356 Avoid boxing/unboxing in sql module
add 8043078390f IGNITE-24429 Sql. Get rid of support of BINARY datatype. (#5357)
add 354439cc0d2 IGNITE-24768 Support per-zone partitions in client handler (#5401)
add ac7a6fd3c5d IGNITE-24484 RAFT heartbeat coalescing (#5221)
add e3b0006eeb6 Bump org.threeten:threetenbp from 1.7.0 to 1.7.1 (#5394)
add ceaa6e49f53 IGNITE-24762 Support zone partitions in unit tests of ignite-table (#5391)
add 599413a55fb IGNITE-24785 Implement test of enter a node with an index greater than the current majority (#5406)
add c9e5a1fbf20 IGNITE-24665 Extract BuildIndexEventListener from PartitionReplicaListener (#5408)
add 0636aadcaea IGNITE-24803 Do not skip non-private fields in IgniteToStringBuilder (#5409)
add c42912508a5 IGNITE-24633 Fix ItTxResourcesVacuumTest.testVacuum (#5413)
add e8301efd4e4 IGNITE-24765 Sql. Reduce number of state checks in executions nodes (#5395)
add 6889bb42efa IGNITE-24747 Support per-zone partitions in TxInfrastructureTest/TxAbstractTest (#5407)
add 7790d8c5c45 IGNITE-24264 Replace Google Analytics with Matomo (#5374)
add 31e86cfa176 IGNITE-24196 Sql. Merge projection into join node (#5398)
add 1b9592b8642 IGNITE-24806 Fix MappingServiceImpl.buildTargetForTable (#5420)
add cde85023fe2 IGNITE-24808 Improve metrics rendering (#5418)
add cac2ebd86fd IGNITE-24804 Ignore 'index not found' exception when switching index state (#5410)
add 1cbd3b404d1 IGNITE-24711 Fix ignite group id in docs (#5362)
add b75a33fada9 IGNITE-24807 Fix outdated flags in .asf.yaml (#5423)
add 3c8b9b7131b IGNITE-24509 Fix HA tests where we check that partition storages are empty (#5411)
add 68a47fc0d87 Bump junit5 from 5.12.0 to 5.12.1 (#5417)
add 20248d4d29c IGNITE-24523 Logs configuration change using debug level (#5422)
add c36b7d9ad23 IGNITE-24815 Support per-zone partitions in ItColocationTest and disable HA and partitions disaster recovery for colocation (#5428)
add 26a13119705 IGNITE-24810 fix NPE when querying system.locks table while txs conflict (#5421)
add c771eacbf71 IGNITE-24816 Reuse LeaseInfo class in partition storages (#5425)
add 7ea218bcd1b IGNITE-24035 Implemented default values for MS and CMG node lists on init (#5315)
add 75ead9a7a66 Bump org.junit.platform:junit-platform-testkit from 1.12.0 to 1.12.1 (#5414)
add 9c292dd20c9 IGNITE-24809 Use proper variable in bootstrap script (#5419)
add 85ec2909def Bump org.springframework.data:spring-data-jdbc from 3.4.3 to 3.4.4 (#5416)
add e44c705d92d Bump com.google.protobuf:protobuf-java from 4.30.0 to 4.30.1 (#5415)
add 44433f81d0c IGNITE-24830 Fix TOC link for cluster security docs (#5435)
add 51e659e3bed IGNITE-24819 Mute ItNodeTest#testNodeWillNeverGetOutOfSnapshot (#5430)
add e829f3852b3 IGNITE-24831 Move MessageCollectionItemType to network-api (#5436)
add 7e70193cd8a IGNITE-24826 Remove unused UpdateClusterStateCommand (#5434)
add 28720a840e9 IGNITE-24841 Optimize HybridTimestamp#toString (#5444)
add e6655c8ed15 IGNITE-24779 Support index lifecycle for per-zone partitions (#5431)
add f3aabee06cc IGNITE-24821 Simplify partition startup snapshot meta (#5432)
add 305e08bd024 IGNITE-24842 Disable several HA tests. (#5445)
add 9f717807d2e IGNITE-24801 Fix typo in FailureProcessorConfigurationSchema (#5429)
add 45001623a03 IGNITE-24845 Fix and adopt compute test for colocation track (#5446)
add c716f81b026 IGNITE-23934 Prevent duplicate node names (#5255)
add 688662c9d8f IGNITE-24698 Add new catalog serializers that conform with the new serialization protocol (#5373)
add 94879bc00b7 IGNITE-24849 Flush storages after rebalance (#5449)
add 0cd5fe02adf IGNITE-24855 Adopt CatalogCompactionRunnerSelfTest for colocation track (#5448)
add ca2cd36fbcd IGNITE-24873 Destroy zone partition storages on partition eviction (#5452)
add fea02c1de3e Bump mockito from 5.16.0 to 5.16.1 (#5439)
add cfefe7bf9df Bump io.github.bonede:tree-sitter from 0.24.4 to 0.24.5 (#5441)
add fc7a4e58d9a IGNITE-24872 Fix minor issues related to RaftTableProcessor (#5453)
add 0cac806efaf IGNITE-24469 Add tuple support to data streamer with receiver (#5457)
add d8c54bcf2f3 IGNITE-23891 Improve operationTimeout javadoc (#5460)
add c39b356cad6 IGNITE-24637 .NET: Fix "IGN-CMN--1" error code representation (#5447)
add 7ff5f3dbcf3 IGNITE-24838 Add ability to save snapshot information in TX storage (#5443)
add b9511359ab4 IGNITE-24888 Add more logging when saving a snapshot (#5464)
add f7f72d091ff IGNITE-24880 Support per-zone partitions in tests of table module (#5459)
add 3318c3455c5 IGNITE-24822 Persist last created Raft snapshot information (#5433)
add 8af024228a6 IGNITE-24874 Add DataStreamer examples (#5455)
add 1609f2f4691 IGNITE-24839 Avoid unwarranted long parking periods in speed based throttling (#5472)
add 5d07c3b6f54 IGNITE-24897 Add links to original schema in generated configuration classes (#5476)
add 78be7aa3324 IGNITE-24301 Sql schema. Fix Thin client protocol to use schema names (#5426)
add 5e8b57d73f9 IGNITE-24703 Wait for system views registration on node start (#5467)
add 90ccd490ea8 Avoid boxing/unboxing in catalog module
add 574b2797a2a Avoid boxing/unboxing in sql module
add 57b3e5f9f23 Minor refactoring
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 (ffec8f887cb)
\
N -- N -- N refs/heads/ignite-24805 (57b3e5f9f23)
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:
.asf.yaml | 4 +-
DEVNOTES.md | 6 +-
README.md | 4 +-
assembly/README.md | 2 +-
docs/_data/toc.yaml | 2 +-
.../{security.adoc => cluster-security.adoc} | 0
docs/_docs/administrators-guide/lifecycle.adoc | 11 +-
.../security/authentication.adoc | 2 +-
docs/_docs/developers-guide/cache.adoc | 2 +-
docs/_docs/developers-guide/sql/jdbc-driver.adoc | 2 +-
docs/_docs/ignite-cli-tool.adoc | 2 +-
docs/_docs/installation/installing-to-k8s.adoc | 22 +-
docs/_docs/quick-start/embedded-mode.adoc | 4 +-
docs/_docs/quick-start/getting-started-guide.adoc | 6 +-
docs/_layouts/default.html | 27 +-
examples/README.md | 22 +-
.../ignite/example/AbstractExamplesTest.java | 1 -
.../streaming/KeyValueViewDataStreamerExample.java | 219 +
.../KeyValueViewPojoDataStreamerExample.java | 219 +
.../streaming/RecordViewDataStreamerExample.java | 217 +
.../RecordViewPojoDataStreamerExample.java | 213 +
.../ignite/example/streaming/pojo/Account.java | 98 +
.../ignite/example/streaming/pojo/AccountKey.java | 28 +-
.../example/streaming/pojo/AccountValue.java | 42 +-
.../ignite/example/streaming/pojo/Trade.java | 118 +
.../receiver/ReceiverStreamProcessingExample.java | 276 +
...treamProcessingWithResultSubscriberExample.java | 342 +
...iverStreamProcessingWithTableUpdateExample.java | 379 +
examples/src/main/resources/tradesData.csv | 10000 +++++++++++++++++++
gradle/libs.versions.toml | 14 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 3 +
.../inlineschema/TupleWithSchemaMarshalling.java | 6 +-
.../compaction/ItCatalogCompactionTest.java | 3 -
.../CatalogCompactionRunnerSelfTest.java | 37 +-
.../CatalogHashIndexDescriptorSerializers.java | 39 +-
.../CatalogSchemaDescriptorSerializers.java | 43 +-
.../CatalogSortedIndexDescriptorSerializers.java | 54 +-
...CatalogStorageProfileDescriptorSerializers.java | 26 +-
...atalogStorageProfilesDescriptorSerializers.java | 26 +-
.../CatalogSystemViewDescriptorSerializers.java | 40 +-
.../CatalogTableColumnDescriptorSerializers.java | 41 +-
.../CatalogTableDescriptorSerializers.java | 141 +-
.../CatalogTableSchemaVersionsSerializers.java | 31 +-
.../CatalogTableVersionSerializers.java | 27 +-
.../CatalogZoneDescriptorSerializers.java | 62 +-
.../storage/AbstractChangeIndexStatusEntry.java | 6 +
.../storage/AlterColumnEntrySerializers.java | 28 +-
.../catalog/storage/AlterZoneEntrySerializers.java | 26 +-
.../storage/DropColumnsEntrySerializers.java | 30 +-
.../internal/catalog/storage/DropIndexEntry.java | 2 +-
.../catalog/storage/DropIndexEntrySerializers.java | 26 +-
.../catalog/storage/DropSchemaSerializers.java | 26 +-
.../catalog/storage/DropTableEntrySerializers.java | 26 +-
.../catalog/storage/DropZoneEntrySerializers.java | 26 +-
.../MakeIndexAvailableEntrySerializers.java | 26 +-
.../storage/NewColumnsEntrySerializers.java | 28 +-
.../catalog/storage/NewIndexEntrySerializers.java | 26 +-
.../catalog/storage/NewSchemaEntrySerializers.java | 25 +-
.../storage/NewSystemViewEntrySerializers.java | 26 +-
.../catalog/storage/NewTableEntrySerializers.java | 26 +-
.../catalog/storage/NewZoneEntrySerializers.java | 26 +-
.../storage/ObjectIdGenUpdateEntrySerializers.java | 26 +-
.../storage/RemoveIndexEntrySerializers.java | 26 +-
.../storage/RenameIndexEntrySerializers.java | 29 +-
.../storage/RenameTableEntrySerializers.java | 28 +-
.../storage/SetDefaultZoneEntrySerializers.java | 26 +-
.../catalog/storage/SnapshotEntrySerializers.java | 56 +-
.../StartBuildingIndexEntrySerializers.java | 26 +-
.../internal/catalog/storage/UpdateLogImpl.java | 2 +-
.../storage/VersionedUpdateSerializers.java | 31 +-
.../CatalogEntrySerializerProviderImpl.java | 3 +
.../serialization/CatalogMarshallerException.java | 4 +
.../serialization/CatalogObjectDataInput.java | 146 +
.../serialization/CatalogObjectDataOutput.java | 134 +
.../serialization/CatalogObjectSerializer.java | 6 +-
.../serialization/CatalogSerializationUtils.java | 18 +-
.../CatalogVersionAwareSerializer.java | 6 +-
.../serialization/UpdateLogMarshallerImpl.java | 47 +-
.../storage/CatalogEntrySerializationTest.java | 23 +-
.../CatalogSerializationCompatibilityTest.java | 297 +-
...ogSerializationCompatibilityV1ReadsV1Test.java} | 21 +-
...ogSerializationCompatibilityV2ReadsV1Test.java} | 26 +-
...ogSerializationCompatibilityV2ReadsV2Test.java} | 26 +-
.../catalog/storage/DropIndexEntryTest.java} | 12 +-
.../catalog/storage/UpdateLogImplTest.java | 14 +-
.../serialization/CatalogDataInputOutputTest.java | 213 +
.../CatalogEntrySerializerProviderImplTest.java | 6 +-
.../serialization_v2/AlterColumnsEntry_2.bin | Bin 0 -> 104 bytes
.../serialization_v2/AlterZoneEntry_2.bin | Bin 0 -> 114 bytes
.../serialization_v2/DropColumnsEntry_2.bin | Bin 0 -> 35 bytes
.../serialization_v2/DropIndexEntry_2.bin | Bin 0 -> 24 bytes
.../serialization_v2/DropSchemaEntry_2.bin | Bin 0 -> 24 bytes
.../serialization_v2/DropTableEntry_2.bin | Bin 0 -> 24 bytes
.../resources/serialization_v2/DropZoneEntry_2.bin | Bin 0 -> 24 bytes
.../serialization_v2/MakeIndexAvailableEntry_2.bin | Bin 0 -> 24 bytes
.../serialization_v2/NewColumnsEntry_2.bin | Bin 0 -> 7608 bytes
.../resources/serialization_v2/NewIndexEntry_2.bin | Bin 0 -> 1302 bytes
.../serialization_v2/NewSchemaEntry_2.bin | Bin 0 -> 165269 bytes
.../serialization_v2/NewSystemViewEntry_2.bin | Bin 0 -> 7652 bytes
.../resources/serialization_v2/NewTableEntry_2.bin | Bin 0 -> 51763 bytes
.../resources/serialization_v2/NewZoneEntry_2.bin | Bin 0 -> 153 bytes
.../serialization_v2/ObjectIdGenUpdateEntry_2.bin | Bin 0 -> 19 bytes
.../serialization_v2/RemoveIndexEntry_2.bin | Bin 0 -> 24 bytes
.../serialization_v2/RenameIndexEntry_2.bin | Bin 0 -> 25 bytes
.../serialization_v2/RenameTableEntry_2.bin | Bin 0 -> 44 bytes
.../serialization_v2/SetDefaultZoneEntry_2.bin | Bin 0 -> 24 bytes
.../SnapshotEntryNoDefaultZone_2.bin | Bin 0 -> 165391 bytes
.../resources/serialization_v2/SnapshotEntry_2.bin | Bin 0 -> 165394 bytes
.../serialization_v2/StartBuildingIndexEntry_2.bin | Bin 0 -> 24 bytes
.../ignite/internal/cli/CliIntegrationTest.java | 4 +
.../init/ItClusterInitDefaultMsCmgTest.java | 103 +
.../commands/cluster/init/ItClusterInitTest.java | 5 +
.../rest/ItGeneratedRestClientInitTest.java | 115 +
.../internal/rest/ItGeneratedRestClientTest.java | 39 +-
.../commands/cluster/init/ClusterInitOptions.java | 12 +-
.../cli/commands/cluster/ClusterInitTest.java | 51 +-
.../client/proto/ClientBinaryTupleUtils.java | 176 +-
.../internal/client/proto/ClientMessagePacker.java | 11 +
.../client/proto/ClientMessageUnpacker.java | 14 +
.../ignite/internal/client/proto/ClientOp.java | 6 +
.../internal/client/proto/HandshakeUtils.java | 7 +
.../client/proto}/ProtocolBitmaskFeature.java | 30 +-
.../client/proto/StreamerReceiverSerializer.java | 257 +-
.../proto/ClientMessagePackerUnpackerTest.java | 21 +
.../internal/client/proto/HandshakeUtilsTest.java | 44 +
.../client/handler/ItClientHandlerMetricsTest.java | 4 +-
.../ignite/client/handler/ItClientHandlerTest.java | 86 +-
.../ignite/client/handler/ClientHandlerModule.java | 11 +-
.../handler/ClientInboundMessageHandler.java | 15 +-
.../handler/ClientPrimaryReplicaTracker.java | 58 +-
...st.java => ClientTableGetQualifiedRequest.java} | 27 +-
.../requests/table/ClientTableGetRequest.java | 1 -
...t.java => ClientTablesGetQualifiedRequest.java} | 22 +-
.../requests/table/ClientTablesGetRequest.java | 1 -
.../handler/ClientPrimaryReplicaTrackerTest.java | 22 +-
.../ignite/client/handler/FakeCatalogService.java | 47 +-
.../ignite/client/handler/FakePlacementDriver.java | 18 +-
.../org/apache/ignite/client/IgniteClient.java | 3 +
.../ignite/client/IgniteClientConfiguration.java | 3 +
.../apache/ignite/internal/client/ClientUtils.java | 2 +
.../ignite/internal/client/ProtocolContext.java | 1 +
.../ignite/internal/client/ReliableChannel.java | 27 +
.../ignite/internal/client/TcpClientChannel.java | 19 +-
.../ignite/internal/client/table/ClientTables.java | 54 +-
.../apache/ignite/client/AbstractClientTest.java | 2 +-
.../apache/ignite/client/ClientLoggingTest.java | 2 +-
.../apache/ignite/client/ClientMetricsTest.java | 4 +-
.../ignite/client/ClientPartitionManagerTest.java | 8 +-
.../ignite/client/PartitionAwarenessTest.java | 18 +-
.../java/org/apache/ignite/client/TestServer.java | 15 +-
.../ignite/client/fakes/FakeIgniteTables.java | 4 +-
.../cluster/management/ClusterInitializer.java | 101 +-
.../management/ClusterManagementGroupManager.java | 50 +-
.../management/network/CmgMessageCallback.java | 6 +
.../management/network/CmgMessageHandler.java | 3 +
.../network/messages/CmgMessageGroup.java | 8 +-
...CompleteMessage.java => RefuseJoinMessage.java} | 10 +-
.../management/raft/CmgRaftGroupListener.java | 5 -
.../cluster/management/raft/CmgRaftService.java | 10 -
.../raft/commands/UpdateClusterStateCommand.java | 35 -
.../cluster/management/ClusterInitializerTest.java | 103 +-
.../management/raft/CmgRaftGroupListenerTest.java | 39 -
.../internal/compute/ItWorkerShutdownTest.java | 13 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 19 +-
.../compute/NextColocatedWorkerSelector.java | 18 +-
.../compute/PartitionNextWorkerSelector.java | 15 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 6 +-
.../processor/ConfigurationProcessor.java | 35 +-
.../ignite/internal/hlc/HybridTimestamp.java | 4 +-
.../internal/tostring/IgniteToStringBuilder.java | 4 +-
.../internal/versioned/VersionedSerializer.java | 6 +-
.../extensions/communication/package-info.java | 22 -
.../tostring/IgniteToStringBuilderSelfTest.java | 18 +-
.../tostring/IgniteToStringBuilderTest.java} | 33 +-
.../rebalance/ItRebalanceDistributedTest.java | 19 +-
.../ignite/internal/failure/FailureManager.java | 2 +-
.../FailureProcessorConfigurationSchema.java | 4 +-
.../failure/FailureProcessorLoggingTest.java | 2 +-
.../internal/failure/FailureProcessorTest.java | 2 +-
.../FailureProcessorThreadDumpThrottlingTest.java | 6 +-
.../internal/network/file/TestTopologyService.java | 8 +
modules/index/build.gradle | 1 +
.../ignite/internal/index/ItBuildIndexTest.java | 40 +-
.../internal/index/ChangeIndexStatusTask.java | 23 +-
.../index/ChangeIndexStatusTaskController.java | 100 +-
.../index/ChangeIndexStatusTaskScheduler.java | 9 +-
.../internal/index/IndexBuildController.java | 44 +-
.../internal/index/IndexBuildingManager.java | 11 +-
.../internal/index/IndexTaskStoppingException.java | 2 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 94 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 2 +
.../internal/index/IndexBuildControllerTest.java | 4 +-
.../internal/index/TestIndexManagementUtils.java | 4 +-
.../ignite/jdbc/ItJdbcResultSetSelfTest.java | 4 +-
.../raft/MetaStorageSnapshotStorageFactory.java | 2 +-
.../internal/metrics/DistributionMetric.java | 4 +-
.../metrics/exporters/log/LogPushExporter.java | 13 +-
.../internal/metrics/DistributionMetricTest.java | 2 +-
.../MessageCollectionItemTypeConverter.java | 2 +-
.../serialization/MessageReaderMethodResolver.java | 2 +-
.../serialization/MessageWriterMethodResolver.java | 2 +-
...on.java => DuplicateConsistentIdException.java} | 11 +-
.../ignite/internal/network/JoinedNodes.java} | 21 +-
.../ignite/internal/network/TopologyService.java | 2 +-
.../serialization}/MessageCollectionItemType.java | 2 +-
.../network/serialization/MessageReader.java | 1 -
.../network/serialization/MessageWriter.java | 1 -
.../network/netty/ItConnectionManagerTest.java | 43 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 19 +-
.../internal/network/DefaultMessagingService.java | 20 +-
.../network/direct/DirectMessageReader.java | 2 +-
.../network/direct/DirectMessageWriter.java | 2 +-
.../direct/stream/DirectByteBufferStream.java | 2 +-
.../stream/DirectByteBufferStreamImplV1.java | 2 +-
.../handshake/ChannelAlreadyExistsException.java | 19 +-
.../internal/network/netty/ConnectionManager.java | 85 +-
.../recovery/RecoveryClientHandshakeManager.java | 2 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 1 +
.../scalecube/ScaleCubeTopologyService.java | 88 +-
.../network/DefaultMessagingServiceTest.java | 1 +
.../checkpoint/CheckpointProgressImpl.java | 1 +
.../throttling/PagesWriteSpeedBasedThrottle.java | 66 +-
...edBasedMemoryConsumptionThrottlingStrategy.java | 6 +-
.../throttling/PageMemoryThrottlingTest.java | 11 +-
.../partition/replicator/fixtures/Node.java | 4 +-
.../PartitionReplicaLifecycleManager.java | 49 +-
.../replicator/ZonePartitionReplicaListener.java | 12 +-
.../partition/replicator/ZoneResourcesManager.java | 3 +-
.../replicator/raft/OnSnapshotSaveHandler.java | 40 +-
.../replicator/raft/PartitionSnapshotInfo.java | 119 +
.../raft/PartitionSnapshotInfoSerializer.java | 91 +
.../replicator/raft/ZonePartitionRaftListener.java | 34 +-
.../raft/snapshot/PartitionDataStorage.java | 38 +-
.../raft/snapshot/PartitionMvStorageAccess.java | 30 +-
.../snapshot/PartitionSnapshotStorageFactory.java | 98 +-
.../raft/snapshot/PartitionTxStateAccess.java | 9 +-
.../raft/snapshot/PartitionTxStateAccessImpl.java | 15 +-
.../raft/snapshot/RaftSnapshotPartitionMeta.java | 81 -
.../snapshot/incoming/IncomingSnapshotCopier.java | 196 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 11 +-
.../raft/snapshot/outgoing/SnapshotMetaUtils.java | 22 +-
.../PartitionReplicaLifecycleManagerTest.java | 8 +-
.../raft/PartitionSnapshotInfoSerializerTest.java | 82 +
.../raft/ZonePartitionRaftListenerTest.java | 57 +-
.../PartitionSnapshotStorageFactoryTest.java | 112 +-
.../incoming/IncomingSnapshotCopierTest.java | 51 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 13 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 9 +-
.../ItPrimaryReplicaChoiceTest.java | 11 +-
modules/platforms/cpp/ignite/common/error_codes.h | 6 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 1 +
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 2 +
.../dotnet/Apache.Ignite.Tests/ErrorGroupTests.cs | 2 +-
.../ExceptionCodeAsStringTests.cs | 78 +
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 15 +-
.../Apache.Ignite/IgniteClientConfiguration.cs | 4 +-
.../dotnet/Apache.Ignite/IgniteException.cs | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 46 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 22 +-
.../apache/ignite/raft/jraft/core/TestCluster.java | 13 +-
.../snasphot/SnapshotInMemoryStorageFactory.java | 3 +-
.../internal/raft/server/impl/JraftServerImpl.java | 17 +-
.../raft/storage/SnapshotStorageFactory.java | 5 +-
.../org/apache/ignite/raft/jraft/JRaftUtils.java | 13 +
.../org/apache/ignite/raft/jraft/NodeManager.java | 162 +-
.../apache/ignite/raft/jraft/RaftGroupService.java | 14 +-
.../apache/ignite/raft/jraft/RaftMessageGroup.java | 6 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 17 +-
.../ignite/raft/jraft/option/NodeOptions.java | 31 +-
.../rpc/{RpcClient.java => NetworkInvoker.java} | 34 +-
.../apache/ignite/raft/jraft/rpc/RpcClient.java | 26 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 10 +
.../raft/jraft/rpc/impl/AbstractClientService.java | 15 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 11 +-
.../impl/core/AppendEntriesRequestProcessor.java | 9 +-
.../rpc/impl/core/DefaultRaftClientService.java | 66 +-
.../rpc/impl/core/HeartbeatRequestProcessor.java | 91 +
.../storage/snapshot/SnapshotExecutorImpl.java | 4 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 3 +-
.../impl/cli/AbstractCliRequestProcessorTest.java | 2 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 2 +-
.../ignite/raft/jraft/rpc/TestIgniteRpcServer.java | 5 +-
.../internal/replicator/ReplicaTestUtils.java | 79 +-
.../internal/rest/api/cluster/InitCommand.java | 17 +-
.../cluster/ItClusterManagementControllerTest.java | 12 +
.../rest/sql/ItSqlQueryControllerTest.java | 9 -
.../transaction/ItTransactionControllerTest.java | 9 -
.../ItTruncateRaftLogAndRestartNodesTest.java | 495 +
.../internal/benchmark/SqlJoinBenchmark.java | 3 -
.../management/ItDuplicateNodeNamesTest.java | 202 +
.../runner/app/AbstractSchemaChangeTest.java | 2 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 19 +-
.../runner/app/PlatformTestNodeRunner.java | 12 +-
.../runner/app/client/ItThinClientSqlTest.java | 2 +-
.../app/client/ItThinClientTablesGetListTest.java | 170 +
.../streamer/ItAbstractDataStreamerTest.java | 139 +-
.../java/org/apache/ignite/InitParameters.java | 11 +-
.../org/apache/ignite/InitParametersBuilder.java | 49 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 21 +-
.../apache/ignite/InitParametersBuilderTest.java | 224 +
.../java/org/apache/ignite/internal/Cluster.java | 4 +-
.../internal/ClusterPerTestIntegrationTest.java | 14 +
modules/sql-engine/build.gradle | 2 +-
.../internal/sql/engine/ItAlterTableDdlTest.java | 11 -
.../internal/sql/engine/ItCreateTableDdlTest.java | 17 -
.../internal/sql/engine/ItDataTypesTest.java | 7 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 8 +-
.../internal/sql/engine/ItJoinOrderTest.java | 204 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 4 +-
.../sql/engine/datatypes/DataTypeTestSpecs.java | 2 +-
.../datatypes/tests/BaseDmlDataTypeTest.java | 16 -
.../datatypes/tests/BaseJoinDataTypeTest.java | 18 +-
.../sql/engine/datatypes/uuid/ItUuidDmlTest.java | 7 -
.../sql/engine/datatypes/uuid/ItUuidJoinTest.java | 11 +-
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 16 +-
.../datatypes/varbinary/ItVarBinaryJoinTest.java | 15 +-
.../engine/systemviews/AbstractSystemViewTest.java | 8 -
.../engine/systemviews/ItLocksSystemViewTest.java | 87 +
.../contstraint/test_not_null_constraint.test | 65 +-
.../sql/group1/types/blob/test_blob.test | 20 +-
.../src/main/codegen/includes/parserImpls.ftl | 24 +-
.../internal/sql/engine/InternalSqlRowImpl.java | 6 +-
...oseable.java => SchemaAwareFieldConverter.java} | 19 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 4 +-
.../sql/engine/exec/LogicalRelImplementor.java | 76 +-
.../internal/sql/engine/exec/RowHandler.java | 3 -
.../internal/sql/engine/exec/SqlRowHandler.java | 33 -
.../sql/engine/exec/exp/BiFieldGetter.java | 21 +-
.../sql/engine/exec/exp/CommonFieldGetter.java | 22 +-
.../sql/engine/exec/exp/ExpressionFactory.java | 15 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 24 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 11 +-
...ementor.java => JoinProjectionImplementor.java} | 50 +-
.../{SqlProjection.java => SqlJoinProjection.java} | 20 +-
.../engine/exec/mapping/MappingServiceImpl.java | 6 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 37 +-
.../rel/AbstractRightMaterializedJoinNode.java | 19 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 16 +-
.../sql/engine/exec/rel/AsyncRootNode.java | 9 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 74 +-
.../internal/sql/engine/exec/rel/FilterNode.java | 22 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 26 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 205 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 22 +-
.../sql/engine/exec/rel/IndexSpoolNode.java | 20 +-
.../internal/sql/engine/exec/rel/LimitNode.java | 10 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 174 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 12 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 148 +-
.../internal/sql/engine/exec/rel/Outbox.java | 12 +-
.../internal/sql/engine/exec/rel/ProjectNode.java | 6 -
.../internal/sql/engine/exec/rel/RootNode.java | 14 +-
.../internal/sql/engine/exec/rel/ScanNode.java | 12 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 23 +-
.../internal/sql/engine/exec/rel/SortNode.java | 28 +-
.../sql/engine/exec/rel/StorageScanNode.java | 16 +-
.../sql/engine/exec/rel/TableSpoolNode.java | 29 +-
.../internal/sql/engine/exec/rel/UnionAllNode.java | 8 +-
.../sql/engine/prepare/KeyValueGetPlan.java | 12 +-
.../sql/engine/prepare/SelectCountPlan.java | 4 +-
.../engine/rel/agg/IgniteSortAggregateBase.java | 1 -
.../internal/sql/engine/trait/TraitUtils.java | 6 +
.../ignite/internal/sql/engine/util/Commons.java | 15 -
.../internal/sql/engine/util/IgniteMethod.java | 4 -
.../internal/sql/engine/util/IgniteResource.java | 3 +
.../ignite/internal/sql/engine/util/TypeUtils.java | 10 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 46 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 32 +
.../engine/exec/rel/AbstractJoinExecutionTest.java | 33 +-
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 304 +
.../sql/engine/exec/rel/ExecutionTest.java | 111 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 4 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 43 -
.../sql/engine/framework/ArrayRowHandler.java | 9 -
.../engine/framework/ClusterServiceFactory.java | 8 +
.../prepare/ddl/DdlSqlToCommandConverterTest.java | 7 -
.../internal/sql/engine/sql/SqlDdlParserTest.java | 37 +
.../sql/metrics/PlanningCacheMetricsTest.java | 11 +-
.../internal/storage/MvPartitionStorage.java | 35 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 23 +-
.../internal/storage/engine/MvPartitionMeta.java | 39 +-
.../storage/engine/PrimitivePartitionMeta.java | 40 +-
.../ignite/internal/storage/lease/LeaseInfo.java | 6 +
.../storage/AbstractMvPartitionStorageTest.java | 20 +-
.../storage/AbstractMvTableStorageTest.java | 5 +-
.../storage/impl/TestMvPartitionStorage.java | 47 +-
.../internal/storage/impl/TestMvTableStorage.java | 11 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 11 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 13 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 130 +-
.../mv/VolatilePageMemoryMvPartitionStorage.java | 58 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 78 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 12 +-
.../ItInternalTableReadWriteScanTest.java | 3 +
...ItTxDistributedTestThreeNodesThreeReplicas.java | 12 +-
.../ItTxObservableTimePropagationTest.java | 18 +-
.../ReplicasSafeTimePropagationTest.java | 4 +-
.../ignite/internal/ItRaftFsyncOptionTest.java | 4 +-
.../partition/ItPartitionDestructionTest.java | 128 +-
.../ignite/internal/table/ItColocationTest.java | 16 +-
...bstractHighAvailablePartitionsRecoveryTest.java | 32 +-
...ilablePartitionsRecoveryByFilterUpdateTest.java | 7 +-
.../ItHighAvailablePartitionsRecoveryTest.java | 4 +-
.../apache/ignite/internal/table/TableImpl.java | 5 +
.../ignite/internal/table/TableViewInternal.java | 7 +
.../internal/table/distributed/TableManager.java | 166 +-
.../table/distributed/index/IndexUtils.java | 2 +-
.../table/distributed/raft/PartitionListener.java | 124 +-
.../snapshot/PartitionMvStorageAccessImpl.java | 24 +-
.../SnapshotAwarePartitionDataStorage.java | 28 +-
.../PartitionReplicaBuildIndexProcessor.java | 165 +
.../replicator/PartitionReplicaListener.java | 112 +-
.../table/partition/HashPartitionManagerImpl.java | 17 +-
.../distributed/TableManagerRecoveryTest.java | 40 +-
.../table/distributed/TableManagerTest.java | 16 +
.../raft/PartitionCommandListenerTest.java | 45 +-
.../replication/PartitionReplicaListenerTest.java | 57 +-
.../storage/InternalTableEstimatedSizeTest.java | 26 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 302 +-
.../distributed/TestPartitionDataStorage.java | 28 +-
.../ignite/internal/table/TxAbstractTest.java | 7 +-
.../internal/table/TxInfrastructureTest.java | 21 +-
.../table/impl/DummyInternalTableImpl.java | 7 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 4 +
.../disaster/ItDisasterRecoveryMetricTest.java | 4 +
.../ItDisasterRecoveryReconfigurationTest.java | 4 +
.../ItDisasterRecoveryResetPartitionsTest.java | 4 +
.../disaster/ItDisasterRecoverySystemViewTest.java | 11 +-
.../tx/distributed/ItTxResourcesVacuumTest.java | 6 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 43 +-
.../ThreadAssertingTxStatePartitionStorage.java | 12 +
.../tx/storage/state/TxStatePartitionStorage.java | 10 +
.../TxStateMetaRocksDbPartitionStorage.java | 19 +-
.../rocksdb/TxStateRocksDbPartitionStorage.java | 34 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 3 +
.../tx/impl/ReadWriteTransactionImplTest.java | 3 +
.../RocksDbTxStatePartitionStorageTest.java | 2 +-
.../state/AbstractTxStatePartitionStorageTest.java | 82 +-
.../state/test/TestTxStatePartitionStorage.java | 28 +-
packaging/common/linux/bootstrap-functions.sh | 10 +-
packaging/common/windows/bootstrap-functions.bat | 8 +-
packaging/db/build.gradle | 12 +-
packaging/db/linux/service/vars.env | 7 +-
packaging/db/zip/linux/ignite3db | 2 +-
packaging/db/zip/linux/vars.env | 13 +-
packaging/db/zip/windows/ignite3db.bat | 2 +-
packaging/db/zip/windows/vars.bat | 13 +-
448 files changed, 21496 insertions(+), 3958 deletions(-)
rename docs/_docs/administrators-guide/{security.adoc => cluster-security.adoc} (100%)
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewDataStreamerExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/KeyValueViewPojoDataStreamerExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/RecordViewDataStreamerExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/RecordViewPojoDataStreamerExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/pojo/Account.java
copy modules/client-common/src/main/java/org/apache/ignite/internal/jdbc/proto/event/JdbcQueryCancelResult.java => examples/src/main/java/org/apache/ignite/example/streaming/pojo/AccountKey.java (64%)
copy modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/CmgGroupId.java => examples/src/main/java/org/apache/ignite/example/streaming/pojo/AccountValue.java (54%)
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/pojo/Trade.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithResultSubscriberExample.java
create mode 100644 examples/src/main/java/org/apache/ignite/example/streaming/receiver/ReceiverStreamProcessingWithTableUpdateExample.java
create mode 100644 examples/src/main/resources/tradesData.csv
create mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogObjectDataInput.java
create mode 100644 modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogObjectDataOutput.java
copy modules/catalog/src/{main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java => test/java/org/apache/ignite/internal/catalog/storage/CatalogSerializationCompatibilityV1ReadsV1Test.java} (66%)
copy modules/catalog/src/{main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java => test/java/org/apache/ignite/internal/catalog/storage/CatalogSerializationCompatibilityV2ReadsV1Test.java} (62%)
copy modules/catalog/src/{main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java => test/java/org/apache/ignite/internal/catalog/storage/CatalogSerializationCompatibilityV2ReadsV2Test.java} (62%)
copy modules/{network/src/test/java/org/apache/ignite/internal/network/serialization/BuiltInTypeTest.java => catalog/src/test/java/org/apache/ignite/internal/catalog/storage/DropIndexEntryTest.java} (76%)
create mode 100644 modules/catalog/src/test/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogDataInputOutputTest.java
create mode 100644 modules/catalog/src/test/resources/serialization_v2/AlterColumnsEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/AlterZoneEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/DropColumnsEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/DropIndexEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/DropSchemaEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/DropTableEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/DropZoneEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/MakeIndexAvailableEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewColumnsEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewIndexEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewSchemaEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewSystemViewEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewTableEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/NewZoneEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/ObjectIdGenUpdateEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/RemoveIndexEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/RenameIndexEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/RenameTableEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/SetDefaultZoneEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/SnapshotEntryNoDefaultZone_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/SnapshotEntry_2.bin
create mode 100644 modules/catalog/src/test/resources/serialization_v2/StartBuildingIndexEntry_2.bin
create mode 100644 modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/cluster/init/ItClusterInitDefaultMsCmgTest.java
create mode 100644 modules/cli/src/integrationTest/java/org/apache/ignite/internal/rest/ItGeneratedRestClientInitTest.java
rename modules/{client/src/main/java/org/apache/ignite/internal/client => client-common/src/main/java/org/apache/ignite/internal/client/proto}/ProtocolBitmaskFeature.java (79%)
copy modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/{ClientTableGetRequest.java => ClientTableGetQualifiedRequest.java} (67%)
copy modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/{ClientTablesGetRequest.java => ClientTablesGetQualifiedRequest.java} (70%)
copy modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/network/messages/{InitCompleteMessage.java => RefuseJoinMessage.java} (78%)
delete mode 100644 modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/commands/UpdateClusterStateCommand.java
delete mode 100644 modules/core/src/main/java/org/apache/ignite/plugin/extensions/communication/package-info.java
copy modules/{catalog/src/test/java/org/apache/ignite/internal/catalog/descriptors/CatalogSchemaDescriptorTest.java => core/src/test/java/org/apache/ignite/internal/tostring/IgniteToStringBuilderTest.java} (53%)
copy modules/network-api/src/main/java/org/apache/ignite/internal/network/{RecipientLeftException.java => DuplicateConsistentIdException.java} (71%)
copy modules/{raft-api/src/main/java/org/apache/ignite/internal/raft/LeaderElectionListener.java => network-api/src/main/java/org/apache/ignite/internal/network/JoinedNodes.java} (70%)
rename modules/{core/src/main/java/org/apache/ignite/plugin/extensions/communication => network-api/src/main/java/org/apache/ignite/internal/network/serialization}/MessageCollectionItemType.java (97%)
create mode 100644 modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/PartitionSnapshotInfo.java
create mode 100644 modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/PartitionSnapshotInfoSerializer.java
delete mode 100644 modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/RaftSnapshotPartitionMeta.java
create mode 100644 modules/partition-replicator/src/test/java/org/apache/ignite/internal/partition/replicator/raft/PartitionSnapshotInfoSerializerTest.java
create mode 100644 modules/platforms/dotnet/Apache.Ignite.Tests/ExceptionCodeAsStringTests.cs
copy modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/{RpcClient.java => NetworkInvoker.java} (63%)
create mode 100644 modules/raft/src/main/java/org/apache/ignite/raft/jraft/rpc/impl/core/HeartbeatRequestProcessor.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/ItTruncateRaftLogAndRestartNodesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/cluster/management/ItDuplicateNodeNamesTest.java
create mode 100644 modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientTablesGetListTest.java
create mode 100644 modules/runner/src/test/java/org/apache/ignite/InitParametersBuilderTest.java
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/{AsyncCloseable.java => SchemaAwareFieldConverter.java} (67%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{ProjectionImplementor.java => JoinProjectionImplementor.java} (75%)
copy modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{SqlProjection.java => SqlJoinProjection.java} (60%)
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/CorrelatedNestedLoopJoinExecutionTest.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/replicator/PartitionReplicaBuildIndexProcessor.java