This is an automated email from the ASF dual-hosted git repository.
jooger pushed a change to branch jdbc_over_thin_sql
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from ffe62e80175 IGNITE-26276 Sql. Jdbc. Add new implementation for
ResultSetMetadata (#6488)
add 73cba3e2d28 IGNITE-26172 Log job failed event when failover fails
(#6461)
add 885de79599f IGNITE-26169 Update code deployment example (#6398)
add 8fcd8d562e3 IGNITE-25979 Support
DisasterRecoveryManager#restartPartitionWithCleanup in Colocation track (#6458)
add e31b4b0b265 IGNITE-26233 Fix issues after increasing partition
generation and checkpoint (#6463)
add a8443870d88 IGNITE-26316 Take registration failure cause from correct
future (#6490)
add 4cd0fd51eec IGNITE-17838 Implement runInTransaction automatic retries
(#6413)
add 97ac8dcfa78 IGNITE-26155 Expire of cache of SQL plans (#6467)
add 9a254901c51 Bump io.dropwizard.metrics:metrics-core from 4.2.33 to
4.2.34 (#6499)
add 1504f117acb Bump io.swagger.parser.v3:swagger-parser from 2.1.31 to
2.1.32 (#6498)
add 176f78d0ced Bump com.google.protobuf:protobuf-java from 4.31.1 to
4.32.0 (#6497)
add 6793ef0230f Bump net.bytebuddy:byte-buddy from 1.17.6 to 1.17.7 (#6496)
add d1c5efd0687 Bump com.gradleup.shadow from 8.3.8 to 8.3.9 (#6495)
add 5960d6a81b1 IGNITE-25640 Fix cancelled compute task status (#6492)
add 5702caee7e4 IGNITE-26289 Reduced message verbosity on cluster init
errors (#6478)
add 1c162291bd9 IGNITE-26319 Use correct field name for writing
marshallable field (#6500)
add 2a887000644 IGNITE-26037 Error saving FreeList metadata causing
checkpointer to crash (#6354)
add 4aff5f03433 IGNITE-26222 .NET: Improve debug logging for failed table
ops (#6452)
add cbd8d359769 IGNITE-26275 Add failure context id (#6471)
add 75c4ecb973a IGNITE-25986 Add public REST API for partition restart
with clean up functionality (#6493)
add 0685356531e IGNITE-26118 Add compute task events for map reduce tasks
(#6491)
add 44256b0c091 IGNITE-25861 Add more tests for partition generation
change (#6511)
add 2a929c868c6 IGNITE-26317 Cleanup compute module (#6494)
add e2594a72ee7 IGNITE-26331 Introduce compute execution context (#6508)
add 33befc66e3f IGNITE-26310 Fix flaky
DataNodesManagerTest#removeNodesWithScheduledScaleDown (#6489)
add b74522ac677 IGNITE-26315 Fix race between increasing partition
generation and performing write operations to it (#6502)
add 9461f2af7db IGNITE-25202 Add clusterId method to IgniteCluster
interface (#6469)
add 5d21abdf414 IGNITE-26244 Fix
AbstractPageReplacementTest.testFsyncDeltaFilesWillNotStartOnCheckpointUntilPageReplacementIsComplete
(#6514)
add 56ee65d1e06 IGNITE-26028 Support partial comparison in JitComparator
(#6515)
add 7cb21adc854 Bump org.threeten:threetenbp from 1.7.1 to 1.7.2 (#6506)
add 9bfc005c45a Bump org.assertj:assertj-core from 3.27.3 to 3.27.4 (#6505)
add ee13a6fef84 Bump org.jetbrains.gradle.plugin.idea-ext from 1.2 to 1.3
(#6504)
add e99428759e0 Bump org.springframework.data:spring-data-jdbc from 3.5.1
to 3.5.3 (#6503)
add a40f4dd12ba IGNITE-26050 Remove auto adjust related code (#6476)
add 8fea6dcd7ba IGNITE-25669 Fix Netty buffer leak in TcpClientChannel
(#6512)
add 8d94b95b32d IGNITE-26277 Fix DotNetComputeExecutor process start on
undeploy (#6519)
add 9565e696257 IGNITE-26274 Fix on demand deploy race condition (#6470)
add 216dfa0228d IGNITE-26352 Add single checkstyle task (#6517)
add 8c956b3f0d8 IGNITE-26178 Sql. List of SQL keywords (#6520)
add 938e09d0306 IGNITE-25987 Add public CLI API for partition restart with
cleanup functionality (#6513)
add a4695b99f9e IGNITE-25631 C++ Client: Move verification to
configuration methods (#6523)
add 06e115514ce IGNITE-26308 Mute the test until heartbeats are
implemented (#6522)
add 62c47e04531 IGNITE-26336 Fix node name and node url options (#6510)
add 2130f880dd9 IGNITE-26309 .NET: Fix MetricsTests flakiness (#6529)
add 8f6a1f99e71 IGNITE-25872 Sql. Support GROUPING aggregate function
(#6479)
add b809e6218fd IGNITE-26373 Return public API for auto adjust related
entities (#6537)
add 3b9e88e6f0d IGNITE-26359 Reduce excessive warninng messages during
client message handling (#6528)
add 31292e3213d IGNITE-26312 .NET: Fix port issues in compat tests (#6545)
add 0666e26f594 IGNITE-26181 Fix default byte array marshalling (#6521)
add 07bb9b89e48 IGNITE-26235 Separate public ClusterNode from internal
ClusterNode (#6538)
add 6d2fc42a132 Merge branch 'main' into jdbc_over_thin_sql
No new revisions were added by this update.
Summary of changes:
... checkstyleTest checkstyleTestFixtures].run.xml | 9 +-
build.gradle | 8 +
docs/_docs/general-tips.adoc | 1 -
.../deployment/CodeDeploymentExample.java} | 39 +-
.../ignite/example/code/deployment/MyJob.java | 71 +++
.../example/code/deployment/resources/script.sh | 3 +
gradle/libs.versions.toml | 18 +-
.../apache/ignite/catalog/annotations/Zone.java | 4 +-
.../ignite/catalog/definitions/ZoneDefinition.java | 8 +-
.../ignite/marshalling/ByteArrayMarshaller.java | 49 +-
.../JavaSerializationByteArrayMarshalling.java | 70 ---
.../org/apache/ignite/network/IgniteCluster.java | 8 +
...ge-info.java => IgniteTransactionDefaults.java} | 12 +-
.../org/apache/ignite/tx/IgniteTransactions.java | 112 ++--
...nfo.java => RetriableTransactionException.java} | 9 +-
.../ignite/tx/RunInTransactionInternalImpl.java | 360 +++++++++++++
.../ignite/tx/RunInTransactionRetryTest.java | 367 +++++++++++++
modules/catalog-compaction/build.gradle | 1 +
.../compaction/ItCatalogCompactionTest.java | 8 +-
.../compaction/CatalogCompactionRunner.java | 20 +-
.../CatalogCompactionRunnerSelfTest.java | 42 +-
.../catalog/ItCatalogApiThreadingTest.java | 1 -
.../ignite/internal/catalog/ItCatalogDslTest.java | 1 -
.../internal/matcher/ZoneDefinitionMatcher.java | 14 -
.../catalog/sql/CreateFromAnnotationsImpl.java | 4 +-
.../catalog/sql/CreateFromDefinitionImpl.java | 4 +-
.../internal/catalog/sql/CreateZoneImpl.java | 10 -
.../apache/ignite/internal/catalog/sql/Option.java | 4 -
.../catalog/sql/CreateFromAnnotationsTest.java | 13 +-
.../catalog/sql/CreateFromDefinitionTest.java | 4 +-
.../catalog/sql/InvalidDefinitionTest.java | 2 -
.../catalog/CatalogParamsValidationUtils.java | 16 -
.../catalog/commands/AlterZoneCommand.java | 33 +-
.../catalog/commands/AlterZoneCommandBuilder.java | 8 -
.../catalog/commands/CreateZoneCommand.java | 26 +-
.../catalog/commands/CreateZoneCommandBuilder.java | 8 -
.../catalog/commands/RenameZoneCommand.java | 1 -
.../catalog/descriptors/CatalogZoneDescriptor.java | 76 ++-
.../CatalogZoneDescriptorSerializers.java | 5 +-
.../internal/catalog/CatalogManagerSelfTest.java | 1 -
.../ignite/internal/catalog/CatalogTableTest.java | 1 -
.../ignite/internal/catalog/CatalogZoneTest.java | 7 +-
.../commands/AbstractCommandValidationTest.java | 1 -
.../commands/AlterZoneCommandValidationTest.java | 85 +--
.../commands/CreateZoneCommandValidationTest.java | 87 +--
.../descriptors/CatalogZoneDescriptorTest.java | 7 -
.../storage/CatalogEntrySerializationTest.java | 1 -
.../catalog/storage/TestZoneDescriptors.java | 3 -
modules/cli/build.gradle | 1 +
.../restart/ItRestartPartitionsTest.java | 71 ++-
.../recovery/restart/RestartPartitionsCall.java | 12 +-
.../restart/RestartPartitionsCallInput.java | 22 +-
.../ignite/internal/cli/commands/Options.java | 5 +
.../internal/cli/commands/node/NodeUrlMixin.java | 13 +-
.../partitions/restart/RestartPartitionsMixin.java | 10 +
.../repl/completer/StringDynamicCompleter.java | 1 -
.../ignite/internal/cli/commands/MixinTest.java | 246 +++++++++
.../partitions/restart/RestartPartitionsTest.java | 64 +++
.../filter/ExclusionsCompleterFilterTest.java | 1 -
.../handler/ClientInboundMessageHandler.java | 34 +-
.../ClientComputeExecuteColocatedRequest.java | 17 +-
.../ClientComputeExecuteMapReduceRequest.java | 18 +-
.../compute/ClientComputeExecuteRequest.java | 12 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 2 +
.../ignite/client/handler/FakeCatalogService.java | 1 -
.../ignite/internal/client/TcpClientChannel.java | 86 +--
.../internal/client/network/ClientCluster.java | 6 +
.../apache/ignite/client/ClientComputeTest.java | 15 +-
.../apache/ignite/client/ConfigurationTest.java | 22 +
.../java/org/apache/ignite/client/TestServer.java | 8 +-
.../apache/ignite/client/fakes/FakeCompute.java | 56 +-
.../ignite/client/fakes/FakeInternalTable.java | 24 +-
.../cluster/management/ItClusterManagerTest.java | 10 +-
.../management/raft/ItCmgRaftServiceTest.java | 12 +-
.../cluster/management/ClusterInitializer.java | 39 +-
.../management/ClusterManagementGroupManager.java | 70 +--
.../management/network/CmgMessageCallback.java | 12 +-
.../management/network/CmgMessageHandler.java | 8 +-
.../management/raft/CmgRaftGroupListener.java | 8 +-
.../cluster/management/raft/CmgRaftService.java | 14 +-
.../cluster/management/raft/ValidationManager.java | 10 +-
.../raft/commands/ClusterNodeMessage.java | 10 +-
.../topology/LogicalTopologyServiceImpl.java | 4 +-
.../management/topology/api/LogicalNode.java | 12 +-
.../topology/api/LogicalNodeSerializer.java | 4 +-
.../topology/api/LogicalTopologyService.java | 4 +-
.../cluster/management/ClusterInitializerTest.java | 70 +--
.../management/raft/CmgRaftServiceTest.java | 6 +-
.../topology/LogicalTopologyImplTest.java | 16 +-
.../topology/LogicalTopologyServiceImplTest.java | 4 +-
.../internal/cluster/management/MockNode.java | 6 +-
.../metrics/messaging/MetricMessaging.java | 34 +-
.../deployunit/DeployMessagingService.java | 10 +-
.../ignite/internal/deployunit/NodesToDeploy.java | 6 +-
.../ignite/internal/deployunit/UnitDownloader.java | 21 +-
.../internal/client/ClientCompatibilityTests.java | 1 -
...urrentClientWithOldServerCompatibilityTest.java | 1 -
.../PlatformCompatibilityTestNodeRunner.java | 33 +-
.../internal/compute/ItComputeErrorsBaseTest.java | 11 +-
.../internal/compute/ItExecutionsCleanerTest.java | 7 +-
...> ItFailoverCandidateNotFoundEmbeddedTest.java} | 28 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 156 +++++-
...ItFailoverCandidateNotFoundThinClientTest.java} | 19 +-
.../ignite/internal/compute/ItMapReduceTest.java | 87 ++-
...Test.java => ItWorkerShutdownEmbeddedTest.java} | 2 +-
.../internal/compute/ItWorkerShutdownTest.java | 36 +-
...st.java => ItWorkerShutdownThinClientTest.java} | 2 +-
.../internal/compute/events/EventMatcher.java | 87 ++-
.../events/ItComputeEventsEmbeddedTest.java | 96 ++++
.../compute/events/ItComputeEventsTest.java | 134 +++--
...est.java => ItComputeEventsThinClientTest.java} | 12 +-
.../events/ItEmbeddedComputeEventsTest.java | 27 -
.../threading/ItComputeApiThreadingTest.java | 3 +-
.../internal/compute/utils/InteractiveJobs.java | 12 +-
.../internal/compute/utils/InteractiveTasks.java | 42 +-
.../internal/compute/FailingJobMapReduceTask.java} | 10 +-
.../compute/FailingReduceMapReduceTask.java} | 13 +-
.../compute/FailingSplitMapReduceTask.java} | 19 +-
.../apache/ignite/internal/compute/MapReduce.java | 3 +-
.../ignite/internal/compute/ComputeComponent.java | 43 +-
.../internal/compute/ComputeComponentImpl.java | 87 ++-
.../internal/compute/ComputeJobFailover.java | 69 ++-
.../ignite/internal/compute/ExecutionContext.java | 118 +++++
.../ignite/internal/compute/IgniteComputeImpl.java | 199 ++++---
.../internal/compute/IgniteComputeInternal.java | 49 +-
.../apache/ignite/internal/compute/JobStarter.java | 18 +-
.../internal/compute/NextWorkerSelector.java | 4 +-
.../compute/PrimaryReplicaNextWorkerSelector.java | 4 +-
.../internal/compute/RemoteExecutionContext.java | 72 ---
.../compute/TaskToJobExecutionWrapper.java | 10 +-
.../compute/events/ComputeEventMetadata.java | 11 +-
.../events/ComputeEventMetadataBuilder.java | 33 +-
.../compute/events/ComputeEventsFactory.java | 32 +-
.../internal/compute/executor/ComputeExecutor.java | 5 +-
.../compute/executor/ComputeExecutorImpl.java | 33 +-
.../compute/executor/JobExecutionInternal.java | 10 +-
.../platform/PlatformComputeConnection.java | 4 +-
.../platform/dotnet/DotNetComputeExecutor.java | 52 +-
.../compute/messaging/ComputeMessaging.java | 89 ++--
.../compute/messaging/RemoteJobExecution.java | 11 +-
.../compute/queue/PriorityQueueExecutor.java | 20 +-
.../internal/compute/queue/QueueExecutionImpl.java | 4 +-
.../ignite/internal/compute/task/JobSubmitter.java | 8 +-
.../compute/task/TaskExecutionInternal.java | 91 +++-
.../internal/compute/ComputeComponentImplTest.java | 44 +-
.../internal/compute/IgniteComputeImplTest.java | 72 ++-
.../platform/dotnet/DotNetComputeExecutorTest.java | 33 ++
.../compute/queue/PriorityQueueExecutorTest.java | 3 +-
.../ignite/internal/failure/FailureContext.java | 13 +
.../internal/lang/ComponentStoppingException.java | 3 +-
.../internal/lang/NodeStoppingException.java | 3 +-
.../internal/network/PublicClusterNodeImpl.java} | 8 +-
.../apache/ignite/internal/thread/ThreadUtils.java | 13 +-
.../ignite/internal/util/FastTimestamps.java | 6 +-
.../testframework/log4j2/EventLogInspector.java} | 40 +-
...niteDistributionZoneManagerNodeRestartTest.java | 8 +-
.../rebalance/ItRebalanceDistributedTest.java | 8 +-
.../distributionzones/DataNodesManager.java | 6 -
.../utils/CatalogAlterZoneEventListener.java | 16 -
.../distributionzones/DataNodesManagerTest.java | 25 +-
.../DistributionZoneManagerAlterFilterTest.java | 12 +-
.../DistributionZoneManagerFilterTest.java | 12 +-
...istributionZoneManagerScaleUpScaleDownTest.java | 4 +-
...butionZoneManagerStorageProfilesFilterTest.java | 12 +-
.../DistributionZoneCausalityDataNodesTest.java | 18 +-
.../rebalance/ZoneMetricSourceTest.java | 1 -
.../ZoneRebalanceUtilUpdateAssignmentsTest.java | 1 -
.../utils/CatalogAlterZoneEventListenerTest.java | 32 --
.../DistributionZonesTestUtil.java | 8 +-
.../tech-notes/images/cancelRebalance.svg | 2 +-
.../tech-notes/images/primaryReplica.svg | 2 +-
.../internal/eventlog/api/IgniteEventType.java | 6 +
.../ignite/internal/failure/FailureManager.java | 25 +-
.../ignite/internal/network/file/TestCluster.java | 4 +-
.../network/file/FileTransferServiceImpl.java | 4 +-
.../network/file/FileTransferServiceImplTest.java | 8 +-
.../network/file/TestMessagingService.java | 19 +-
.../internal/network/file/TestTopologyService.java | 26 +-
.../internal/index/IndexBuildController.java | 4 +-
.../ignite/internal/index/IndexBuildTask.java | 6 +-
.../apache/ignite/internal/index/IndexBuilder.java | 6 +-
.../internal/index/IndexManagementUtils.java | 6 +-
.../IndexNodeFinishedRwTransactionsChecker.java | 6 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 8 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 19 +-
.../IndexAvailabilityControllerRestorerTest.java | 4 +-
.../index/IndexAvailabilityControllerTest.java | 4 +-
.../ignite/internal/index/IndexBuilderTest.java | 12 +-
.../internal/index/IndexManagementUtilsTest.java | 14 +-
.../internal/index/TestIndexManagementUtils.java | 8 +-
.../internal/lowwatermark/LowWatermarkImpl.java | 4 +-
.../lowwatermark/LowWatermarkImplTest.java | 6 +-
.../cache/IdempotentCacheVacuumizer.java | 4 +-
.../ItMetaStorageMultipleNodesVsStorageTest.java | 4 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 10 +-
.../metastorage/impl/ElectionListener.java | 4 +-
.../impl/MetaStorageCompactionTrigger.java | 6 +-
.../impl/MetaStorageLeaderElectionListener.java | 4 +-
.../impl/MetaStorageLearnerManager.java | 10 +-
.../MetaStorageDeployWatchesCorrectnessTest.java | 4 +-
.../MetaStorageLeaderElectionListenerTest.java | 8 +-
.../impl/MetaStorageManagerRecoveryTest.java | 4 +-
.../impl/StandaloneMetaStorageManager.java | 10 +-
.../serialization/MessageWriterMethodResolver.java | 1 +
...erializatersAndDeserializersFieldNamesTest.java | 67 +++
.../internal/network/ClusterNodeResolver.java | 7 +-
.../internal/network/ClusterNodeSerializer.java | 11 +-
.../ignite/internal/network/IgniteClusterImpl.java | 27 +-
.../internal/network/InternalClusterNode.java} | 12 +-
...rNodeImpl.java => InternalClusterNodeImpl.java} | 17 +-
.../ignite/internal/network/JoinedNodes.java | 6 +-
.../ignite/internal/network/MessagingService.java | 55 +-
.../internal/network/NetworkMessageHandler.java | 3 +-
.../network/PublicApiThreadingIgniteCluster.java | 6 +
.../internal/network/TopologyEventHandler.java | 6 +-
.../ignite/internal/network/TopologyService.java | 9 +-
.../network/TrackableNetworkMessageHandler.java | 3 +-
.../network/UnresolvableConsistentIdException.java | 6 +-
.../JumpToExecutorByConsistentIdAfterSend.java | 15 +-
...java => InternalClusterNodeSerializerTest.java} | 9 +-
.../JumpToExecutorByConsistentIdAfterSendTest.java | 24 +-
.../network/SingleClusterNodeResolver.java | 11 +-
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../node/ItNodeStalenessAndRestartTest.java | 4 +-
.../network/scalecube/ItClusterServiceTest.java | 14 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 26 +-
.../internal/network/DefaultMessagingService.java | 35 +-
.../handshake/HandshakeEventLoopSwitcher.java | 6 +-
.../network/message/ClusterNodeMessage.java | 12 +-
.../internal/network/netty/ConnectionManager.java | 8 +-
.../internal/network/netty/HandshakeHandler.java | 4 +-
.../internal/network/netty/InNetworkObject.java | 10 +-
.../internal/network/netty/MessageHandler.java | 6 +-
.../network/recovery/HandshakeManagerUtils.java | 4 +-
.../recovery/RecoveryAcceptorHandshakeManager.java | 10 +-
.../RecoveryInitiatorHandshakeManager.java | 12 +-
.../RecoveryInitiatorHandshakeManagerFactory.java | 4 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 10 +-
.../scalecube/ScaleCubeTopologyService.java | 74 +--
.../network/DefaultMessagingServiceTest.java | 61 ++-
.../handshake/NoOpHandshakeEventLoopSwitcher.java | 4 +-
.../network/netty/RecoveryHandshakeTest.java | 6 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../RecoveryInitiatorHandshakeManagerTest.java | 8 +-
.../scalecube/ScaleCubeTopologyServiceTest.java | 14 +-
.../ItBplusTreePersistentPageMemoryTest.java | 4 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 4 +-
.../ignite/internal/pagememory/FullPageId.java | 8 +-
.../internal/pagememory/freelist/FreeListImpl.java | 11 +-
.../pagememory/persistence/DirtyFullPageId.java | 90 ++++
.../pagememory/persistence/PageHeader.java | 21 +
.../pagememory/persistence/PageStoreWriter.java | 3 +-
.../PartitionDestructionLockManager.java | 44 ++
.../pagememory/persistence/PartitionMeta.java | 11 +-
.../persistence/PartitionMetaFactory.java | 3 +-
.../persistence/PartitionMetaManager.java | 15 +-
.../persistence/PartitionProcessingCounterMap.java | 84 ---
.../persistence/PersistentPageMemory.java | 98 +++-
.../checkpoint/CheckpointDirtyPages.java | 25 +-
.../persistence/checkpoint/CheckpointManager.java | 50 +-
.../checkpoint/CheckpointPageReplacement.java | 16 +-
.../persistence/checkpoint/CheckpointPages.java | 88 +---
.../checkpoint/CheckpointPagesWriter.java | 102 ++--
.../checkpoint/CheckpointPagesWriterFactory.java | 11 +-
.../checkpoint/CheckpointProgressImpl.java | 85 +--
.../persistence/checkpoint/CheckpointWorkflow.java | 26 +-
.../persistence/checkpoint/Checkpointer.java | 61 +--
.../checkpoint/DataRegionsDirtyPages.java | 6 +-
.../checkpoint/DirtyPagesAndPartitions.java | 6 +-
.../persistence/compaction/Compactor.java | 35 +-
.../replacement/DelayedDirtyPageWrite.java | 23 +-
.../replacement/DelayedPageReplacementTracker.java | 10 +-
.../RandomLruPageReplacementPolicy.java | 8 +-
.../PartitionProcessingCounterMapTest.java | 79 ---
.../checkpoint/CheckpointDirtyPagesTest.java | 20 +-
.../checkpoint/CheckpointManagerTest.java | 20 +-
.../checkpoint/CheckpointPageReplacementTest.java | 46 +-
.../checkpoint/CheckpointPagesTest.java | 52 +-
.../checkpoint/CheckpointPagesWriterTest.java | 59 ++-
.../checkpoint/CheckpointProgressImplTest.java | 48 --
.../persistence/checkpoint/CheckpointTest.java | 4 +-
.../checkpoint/CheckpointWorkflowTest.java | 38 +-
.../persistence/checkpoint/CheckpointerTest.java | 114 ++--
.../checkpoint/TestCheckpointUtils.java | 10 +-
.../persistence/compaction/CompactorTest.java | 66 +--
.../replacement/AbstractPageReplacementTest.java | 23 +-
.../RandomLruPageReplacementPolicySelfTest.java | 5 +-
.../throttling/PageMemoryThrottlingTest.java | 10 +-
.../pagememory/persistence/FakePartitionMeta.java | 15 +-
.../checkpoint/CheckpointTestUtils.java | 4 +-
.../replicator/fixtures/TestPlacementDriver.java | 6 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 4 +-
.../PartitionReplicaLifecycleManager.java | 58 +-
.../partition/replicator/ReplicaPrimacyEngine.java | 6 +-
.../partition/replicator/TxRecoveryEngine.java | 6 +-
.../replicator/ZonePartitionReplicaListener.java | 6 +-
...xStateCommitPartitionReplicaRequestHandler.java | 6 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 14 +-
.../outgoing/OutgoingSnapshotsManager.java | 6 +-
.../PartitionReplicaLifecycleManagerTest.java | 5 +-
.../incoming/IncomingSnapshotCopierTest.java | 12 +-
.../PrimaryReplicaAwaitException.java | 3 +-
.../PrimaryReplicaAwaitTimeoutException.java | 3 +-
.../placementdriver/TestPlacementDriver.java | 15 +-
.../placementdriver/TestReplicaMetaImpl.java | 12 +-
.../ItPrimaryReplicaChoiceTest.java | 11 +-
.../PlacementDriverManagerTest.java | 4 +-
.../internal/placementdriver/LeaseUpdater.java | 20 +-
.../placementdriver/PlacementDriverManager.java | 4 +-
.../internal/placementdriver/TopologyTracker.java | 4 +-
.../placementdriver/PlacementDriverTest.java | 18 +-
modules/platforms/cpp/ignite/client/CMakeLists.txt | 1 +
.../platforms/cpp/ignite/client/ignite_client.cpp | 7 -
.../ignite_client_configuration.cpp} | 17 +-
.../ignite/client/ignite_client_configuration.h | 38 +-
modules/platforms/cpp/ignite/client/ssl_mode.h | 2 +-
.../cpp/ignite/network/detail/win/sockets.cpp | 1 -
.../cpp/tests/client-test/ignite_client_test.cpp | 60 +++
.../cpp/tests/client-test/ignite_runner_suite.h | 4 +-
.../CurrentClientWithOldServerCompatibilityTest.cs | 7 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 3 +-
.../dotnet/Apache.Ignite.Tests/JavaServer.cs | 106 ++--
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 3 -
.../Apache.Ignite.Tests/Table/SchemaUpdateTest.cs | 20 +-
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 2 +-
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 6 +
.../dotnet/Apache.Ignite/Internal/LogMessages.cs | 7 +
.../Apache.Ignite/Internal/Table/RecordView.cs | 6 +
modules/platforms/python/tests/test_fetch_table.py | 3 +-
.../internal/raft/LeaderElectionListener.java | 4 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 8 +-
.../ignite/internal/raft/RaftGroupServiceImpl.java | 8 +-
.../server/impl/RaftServiceEventInterceptor.java | 10 +-
.../apache/ignite/raft/jraft/rpc/RpcContext.java | 4 +-
.../raft/jraft/rpc/impl/AbstractClientService.java | 6 +-
.../raft/jraft/rpc/impl/IgniteRpcClient.java | 5 +-
.../raft/jraft/rpc/impl/IgniteRpcServer.java | 14 +-
.../rpc/impl/RaftGroupEventsClientListener.java | 4 +-
.../ignite/internal/raft/RaftGroupServiceTest.java | 48 +-
.../ignite/raft/jraft/rpc/IgniteRpcTest.java | 6 +-
.../ignite/raft/jraft/test/MockAsyncContext.java | 8 +-
.../ItPlacementDriverReplicaSideTest.java | 4 +-
.../raft/client/TopologyAwareRaftGroupService.java | 27 +-
.../PlacementDriverMessageProcessor.java | 14 +-
.../ignite/internal/replicator/ReplicaImpl.java | 6 +-
.../ignite/internal/replicator/ReplicaManager.java | 14 +-
.../ignite/internal/replicator/ReplicaService.java | 8 +-
.../exception/PrimaryReplicaMissException.java | 4 +-
.../exception/ReplicaStoppingException.java | 4 +-
.../exception/ReplicaUnavailableException.java | 4 +-
.../replicator/exception/ReplicationException.java | 3 +-
.../replicator/PlacementDriverReplicaSideTest.java | 18 +-
.../internal/replicator/ReplicaManagerTest.java | 4 +-
.../AbstractTopologyAwareGroupServiceTest.java | 24 +-
.../internal/replicator/ReplicaTestUtils.java | 6 +-
.../topology/TestLogicalTopologyService.java | 4 +-
.../rest/api/recovery/DisasterRecoveryApi.java | 28 +
modules/rest/build.gradle | 1 +
.../ItDisasterRecoveryColocationDisabledTest.java | 14 +
...terRecoveryControllerRestartPartitionsTest.java | 1 -
...ontrollerRestartPartitionsWithCleanupTest.java} | 49 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 1 -
.../internal/rest/cluster/TopologyController.java | 5 +-
.../rest/recovery/DisasterRecoveryController.java | 28 +
.../apache/ignite/internal/ItIgniteStartTest.java | 6 +-
.../ItTruncateRaftLogAndRestartNodesTest.java | 4 +-
.../management/ItDuplicateNodeNamesTest.java | 4 +-
.../network/ItAbstractIgniteClusterTest.java | 8 +
.../ItRaftCommandLeftInLogUntilRestartTest.java | 8 +-
.../runner/app/client/ItThinClientComputeTest.java | 37 +-
.../app/client/ItThinClientTransactionsTest.java | 9 +-
.../app/compute/ItEmbeddedMarshallingTest.java | 24 +-
.../streamer/ItAbstractDataStreamerTest.java | 4 +-
.../internal/table/ItReadOnlyTransactionTest.java | 22 +-
.../ignite/internal/table/ItReplicasTest.java | 10 +-
.../ignite/internal/table/ItTableScanTest.java | 21 +-
.../partition/ItAbstractPartitionManagerTest.java | 6 +-
.../main/java/org/apache/ignite/IgniteServer.java | 3 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 9 +-
.../restart/RestartProofIgniteCluster.java | 6 +
.../configuration/ignite-snapshot.bin | Bin 5503 -> 5511 bytes
.../internal/ClusterPerClassIntegrationTest.java | 3 +-
.../internal/ClusterPerTestIntegrationTest.java | 13 +-
.../internal/schema/BinaryTupleComparatorTest.java | 5 +
.../schema/PartialBinaryTupleMatcherTest.java | 134 +----
.../schema/BinaryTupleComparatorBaseTest.java | 139 +++++
.../internal/sql/engine/ItAggregatesTest.java | 72 ++-
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 8 +-
.../systemviews/ItTransactionsSystemViewTest.java | 4 +-
.../engine/systemviews/ItZonesSystemViewTest.java | 1 -
.../group1/aggregate/group/test_grouping_sets.test | 149 ++++++
.../group/test_multicolumn_grouping_sets.test | 106 ++++
.../SqlPlannerDistributedConfigurationSchema.java | 7 +
.../internal/sql/engine/SqlQueryProcessor.java | 4 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 6 +-
.../internal/sql/engine/exec/ExecutionContext.java | 8 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 24 +-
.../sql/engine/exec/MailboxRegistryImpl.java | 6 +-
.../engine/exec/exp/agg/AccumulatorWrapper.java | 3 +
.../sql/engine/exec/exp/agg/Accumulators.java | 65 +++
.../engine/exec/exp/agg/AccumulatorsFactory.java | 19 +-
.../sql/engine/exec/exp/agg/AggregateRow.java | 21 +-
.../sql/engine/exec/kill/KillCommandHandler.java | 4 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 4 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 4 +-
.../internal/sql/engine/exec/rel/Outbox.java | 4 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 2 +-
.../sql/engine/message/MessageListener.java | 4 +-
.../sql/engine/message/MessageServiceImpl.java | 12 +-
.../sql/engine/prepare/IgniteSqlValidator.java | 8 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 5 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 5 -
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 3 -
.../sql/engine/rel/agg/MapReduceAggregates.java | 27 +-
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 1 +
.../internal/sql/engine/util/IgniteResource.java | 5 +
.../sql/engine/util/cache/CacheFactory.java | 14 +
.../engine/util/cache/CaffeineCacheFactory.java | 10 +
.../ignite/internal/sql/docs/OperatorListTest.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 33 +-
.../sql/engine/exec/PartitionProvidersTest.java | 4 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 4 +-
.../exec/exp/agg/GroupingAccumulatorTest.java | 189 +++++++
.../engine/exec/kill/KillCommandHandlerTest.java | 24 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 28 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 18 +-
.../exec/rel/TableScanNodeExecutionTest.java | 10 +-
.../engine/framework/ClusterServiceFactory.java | 52 +-
.../sql/engine/framework/NoOpTransaction.java | 10 +-
.../sql/engine/framework/TestBuilders.java | 10 +-
.../planner/AbstractAggregatePlannerTest.java | 35 +-
.../sql/engine/planner/AggregatePlannerTest.java | 12 +
.../planner/ColocatedHashAggregatePlannerTest.java | 12 +
.../planner/ColocatedSortAggregatePlannerTest.java | 12 +
.../planner/MapReduceHashAggregatePlannerTest.java | 12 +
.../planner/MapReduceSortAggregatePlannerTest.java | 12 +
.../sql/engine/planner/PlannerTimeoutTest.java | 13 +-
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 4 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 54 +-
.../DistributionZoneSqlToCommandConverterTest.java | 10 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 4 +-
...ributionZoneObsoleteSyntaxSqlDdlParserTest.java | 8 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 581 +++++++++++++++++++++
.../sql/engine/util/EmptyCacheFactory.java | 6 +
.../engine/util/IgniteSqlDateTimeUtilsTest.java | 4 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 2 +-
.../src/test/resources/docs/operator_list.txt | 3 +
.../src/test/resources/tpcds/plan/q27.plan | 68 +++
.../test/resources/tpcds/plan/q27_colocated.plan | 68 +++
.../pagememory/PersistentPageMemoryDataRegion.java | 3 +-
.../PersistentPageMemoryTableStorage.java | 24 +-
.../storage/pagememory/StoragePartitionMeta.java | 4 +-
.../pagememory/StoragePartitionMetaFactory.java | 8 +-
.../sorted/comparator/JitComparatorGenerator.java | 46 +-
.../sorted/comparator/JitComparatorOptions.java | 24 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 10 +-
.../PersistentPageMemoryMvTableStorageTest.java | 151 +++++-
.../pagememory/PersistentPageMemoryNoLoadTest.java | 66 ++-
.../StoragePartitionMetaManagerTest.java | 4 +-
.../pagememory/StoragePartitionMetaTest.java | 2 +-
.../index/sorted/comparator/JitComparatorTest.java | 6 +
.../disaster/system/MetastorageRepairImpl.java | 4 +-
.../system/SystemDisasterRecoveryManagerImpl.java | 34 +-
.../disaster/system/MetastorageRepairImplTest.java | 14 +-
.../SystemDisasterRecoveryManagerImplTest.java | 44 +-
.../internal/systemview/SystemViewManagerTest.java | 6 +-
.../ItAbstractInternalTableScanTest.java | 12 +-
.../ItInternalTableReadOnlyOperationsTest.java | 18 +-
.../ItInternalTableReadOnlyScanTest.java | 4 +-
.../ItInternalTableReadWriteScanTest.java | 4 +-
.../apache/ignite/distributed/ItLockTableTest.java | 4 +-
.../ItTxDistributedCleanupRecoveryTest.java | 4 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 6 +-
.../ItTxObservableTimePropagationTest.java | 4 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 4 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 10 +-
.../ignite/internal/table/ItColocationTest.java | 8 +-
...tKeyValueBinaryViewApiExplicitRunInTxnTest.java | 3 +-
.../ignite/internal/table/InternalTable.java | 20 +-
.../internal/table/StreamerReceiverRunner.java | 6 +-
.../PartitionReplicatorNodeRecovery.java | 12 +-
.../internal/table/distributed/TableManager.java | 4 +-
.../disaster/DisasterRecoveryManager.java | 58 +-
.../disaster/ManualGroupRestartRequest.java | 276 ++++++----
.../replicator/PartitionReplicaListener.java | 6 +-
.../replicator/TransactionStateResolver.java | 4 +-
.../distributed/storage/InternalTableImpl.java | 22 +-
.../table/partition/HashPartitionManagerImpl.java | 9 +-
.../ignite/internal/utils/PrimaryReplica.java | 8 +-
.../distributed/TableManagerRecoveryTest.java | 12 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../PartitionReplicaListenerIndexLockingTest.java | 8 +-
...itionReplicaListenerSortedIndexLockingTest.java | 8 +-
.../replication/PartitionReplicaListenerTest.java | 14 +-
.../ZonePartitionReplicaListenerTest.java | 14 +-
.../storage/InternalTableEstimatedSizeTest.java | 6 +-
.../distributed/storage/InternalTableImplTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 24 +-
.../ignite/internal/table/TxAbstractTest.java | 93 ++--
.../internal/table/TxInfrastructureTest.java | 8 +-
.../table/impl/DummyInternalTableImpl.java | 28 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 346 +++++++++++-
.../tx/distributed/ItTransactionRecoveryTest.java | 7 +-
.../ignite/internal/tx/InternalTxOptions.java | 5 +
.../apache/ignite/internal/tx/LockException.java | 4 +-
.../TransactionConfigurationSchema.java | 4 +-
.../impl/FinishedReadOnlyTransactionTracker.java | 4 +-
.../ignite/internal/tx/impl/OrphanDetector.java | 4 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 10 +-
.../tx/impl/PrimaryReplicaExpiredException.java | 3 +-
.../tx/impl/RemoteReadWriteTransaction.java | 4 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 12 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 4 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 12 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 14 +-
...FinishedTransactionBatchRequestHandlerTest.java | 4 +-
.../internal/tx/impl/OrphanDetectorTest.java | 16 +-
.../tx/impl/ReadWriteTransactionImplTest.java | 6 +-
.../internal/worker/ThreadAssertingCursor.java | 1 -
521 files changed, 8375 insertions(+), 4147 deletions(-)
copy
examples/src/main/java/org/apache/ignite/example/{serialization/NativeTypeSerializationExample.java
=> code/deployment/CodeDeploymentExample.java} (51%)
create mode 100644
examples/src/main/java/org/apache/ignite/example/code/deployment/MyJob.java
create mode 100644
examples/src/main/java/org/apache/ignite/example/code/deployment/resources/script.sh
delete mode 100644
modules/api/src/main/java/org/apache/ignite/marshalling/JavaSerializationByteArrayMarshalling.java
copy modules/api/src/main/java/org/apache/ignite/tx/{package-info.java =>
IgniteTransactionDefaults.java} (79%)
copy modules/api/src/main/java/org/apache/ignite/tx/{package-info.java =>
RetriableTransactionException.java} (78%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/tx/RunInTransactionInternalImpl.java
create mode 100644
modules/api/src/test/java/org/apache/ignite/tx/RunInTransactionRetryTest.java
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/MixinTest.java
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{events/ItThinClientComputeEventsTest.java
=> ItFailoverCandidateNotFoundEmbeddedTest.java} (59%)
copy
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{events/ItThinClientComputeEventsTest.java
=> ItFailoverCandidateNotFoundThinClientTest.java} (70%)
rename
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItEmbeddedWorkerShutdownTest.java
=> ItWorkerShutdownEmbeddedTest.java} (94%)
rename
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/{ItThinClientWorkerShutdownTest.java
=> ItWorkerShutdownThinClientTest.java} (95%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/ItComputeEventsEmbeddedTest.java
rename
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/{ItThinClientComputeEventsTest.java
=> ItComputeEventsThinClientTest.java} (78%)
delete mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/events/ItEmbeddedComputeEventsTest.java
copy
modules/{runner/src/integrationTest/java/org/apache/ignite/internal/app/NoOpMapReduceTask.java
=>
compute/src/jobs/java/org/apache/ignite/internal/compute/FailingJobMapReduceTask.java}
(84%)
copy
modules/{runner/src/integrationTest/java/org/apache/ignite/internal/app/NoOpMapReduceTask.java
=>
compute/src/jobs/java/org/apache/ignite/internal/compute/FailingReduceMapReduceTask.java}
(78%)
copy
modules/{runner/src/integrationTest/java/org/apache/ignite/internal/app/NoOpMapReduceTask.java
=>
compute/src/jobs/java/org/apache/ignite/internal/compute/FailingSplitMapReduceTask.java}
(63%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/ExecutionContext.java
delete mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/RemoteExecutionContext.java
copy
modules/{network-api/src/main/java/org/apache/ignite/internal/network/ClusterNodeImpl.java
=>
core/src/main/java/org/apache/ignite/internal/network/PublicClusterNodeImpl.java}
(90%)
copy
modules/{eventlog/src/testFixtures/java/org/apache/ignite/internal/eventlog/impl/InMemoryCollectionSink.java
=>
core/src/testFixtures/java/org/apache/ignite/internal/testframework/log4j2/EventLogInspector.java}
(53%)
create mode 100644
modules/network-annotation-processor/src/test/java/org/apache/ignite/internal/network/processor/tests/SerializatersAndDeserializersFieldNamesTest.java
copy modules/{api/src/main/java/org/apache/ignite/network/ClusterNode.java =>
network-api/src/main/java/org/apache/ignite/internal/network/InternalClusterNode.java}
(82%)
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{ClusterNodeImpl.java
=> InternalClusterNodeImpl.java} (81%)
rename
modules/network-api/src/test/java/org/apache/ignite/internal/network/{ClusterNodeSerializerTest.java
=> InternalClusterNodeSerializerTest.java} (88%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/DirtyFullPageId.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PartitionDestructionLockManager.java
delete mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounterMap.java
delete mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/PartitionProcessingCounterMapTest.java
copy modules/platforms/cpp/ignite/{common/uuid.cpp =>
client/ignite_client_configuration.cpp} (72%)
copy
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/recovery/{ItDisasterRecoveryControllerRestartPartitionsTest.java
=> ItDisasterRecoveryControllerRestartPartitionsWithCleanupTest.java} (79%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_grouping_sets.test
create mode 100644
modules/sql-engine/src/integrationTest/sql/group1/aggregate/group/test_multicolumn_grouping_sets.test
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/agg/GroupingAccumulatorTest.java
create mode 100644 modules/sql-engine/src/test/resources/tpcds/plan/q27.plan
create mode 100644
modules/sql-engine/src/test/resources/tpcds/plan/q27_colocated.plan
