This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-25872
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from c28872302c3 styles
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 30de7d3def2 Merge branch 'main' into ignite-25872
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 -
gradle/libs.versions.toml | 8 +-
.../apache/ignite/catalog/annotations/Zone.java | 7 -
.../ignite/catalog/definitions/ZoneDefinition.java | 34 --
.../org/apache/ignite/network/IgniteCluster.java | 8 +
.../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 -
.../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 +
.../ignite/internal/cli/commands/MixinTest.java | 246 +++++++++
.../partitions/restart/RestartPartitionsTest.java | 64 +++
.../handler/ClientInboundMessageHandler.java | 16 +-
.../ClientComputeExecuteColocatedRequest.java | 17 +-
.../ClientComputeExecuteMapReduceRequest.java | 18 +-
.../compute/ClientComputeExecuteRequest.java | 3 +-
.../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 +
.../apache/ignite/client/fakes/FakeCompute.java | 43 +-
.../ignite/internal/deployunit/UnitDownloader.java | 21 +-
.../ignite/internal/compute/ItMapReduceTest.java | 85 ++-
.../internal/compute/events/EventMatcher.java | 32 +-
.../events/ItComputeEventsEmbeddedTest.java | 58 ++
.../compute/events/ItComputeEventsTest.java | 90 +++-
.../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 | 37 +-
.../internal/compute/ComputeComponentImpl.java | 72 +--
.../internal/compute/ComputeJobFailover.java | 38 +-
.../ignite/internal/compute/ExecutionContext.java | 118 +++++
.../ignite/internal/compute/IgniteComputeImpl.java | 132 ++---
.../internal/compute/IgniteComputeInternal.java | 45 +-
.../apache/ignite/internal/compute/JobStarter.java | 18 +-
.../internal/compute/RemoteExecutionContext.java | 72 ---
.../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 +-
.../platform/PlatformComputeConnection.java | 4 +-
.../platform/dotnet/DotNetComputeExecutor.java | 52 +-
.../compute/messaging/ComputeMessaging.java | 29 +-
.../compute/queue/PriorityQueueExecutor.java | 20 +-
.../internal/compute/queue/QueueExecutionImpl.java | 4 +-
.../ignite/internal/compute/task/JobSubmitter.java | 8 +-
.../compute/task/TaskExecutionInternal.java | 90 +++-
.../internal/compute/ComputeComponentImplTest.java | 23 +-
.../internal/compute/IgniteComputeImplTest.java | 34 +-
.../platform/dotnet/DotNetComputeExecutorTest.java | 33 ++
.../compute/queue/PriorityQueueExecutorTest.java | 3 +-
.../distributionzones/DataNodesManager.java | 6 -
.../utils/CatalogAlterZoneEventListener.java | 16 -
.../distributionzones/DataNodesManagerTest.java | 25 +-
.../rebalance/ZoneMetricSourceTest.java | 1 -
.../ZoneRebalanceUtilUpdateAssignmentsTest.java | 1 -
.../utils/CatalogAlterZoneEventListenerTest.java | 32 --
.../internal/eventlog/api/IgniteEventType.java | 6 +
.../ignite/internal/network/IgniteClusterImpl.java | 13 +-
.../network/PublicApiThreadingIgniteCluster.java | 6 +
.../ItBplusTreePersistentPageMemoryTest.java | 4 +-
...BplusTreeReuseListPersistentPageMemoryTest.java | 4 +-
.../PartitionDestructionLockManager.java | 44 ++
.../persistence/PartitionMetaManager.java | 2 +-
.../persistence/PartitionProcessingCounterMap.java | 84 ---
.../persistence/PersistentPageMemory.java | 12 +-
.../persistence/checkpoint/CheckpointManager.java | 30 +-
.../persistence/checkpoint/CheckpointPages.java | 50 --
.../checkpoint/CheckpointPagesWriter.java | 35 +-
.../checkpoint/CheckpointPagesWriterFactory.java | 11 +-
.../checkpoint/CheckpointProgressImpl.java | 71 ---
.../persistence/checkpoint/Checkpointer.java | 54 +-
.../persistence/compaction/Compactor.java | 35 +-
.../replacement/DelayedDirtyPageWrite.java | 15 +-
.../replacement/DelayedPageReplacementTracker.java | 10 +-
.../PartitionProcessingCounterMapTest.java | 79 ---
.../checkpoint/CheckpointPagesWriterTest.java | 10 +-
.../checkpoint/CheckpointProgressImplTest.java | 48 --
.../persistence/checkpoint/CheckpointerTest.java | 102 ++--
.../persistence/compaction/CompactorTest.java | 66 +--
.../replacement/AbstractPageReplacementTest.java | 20 +-
.../throttling/PageMemoryThrottlingTest.java | 3 +-
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 +-
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 3 -
modules/platforms/python/tests/test_fetch_table.py | 3 +-
.../rest/api/recovery/DisasterRecoveryApi.java | 28 +
.../ItDisasterRecoveryColocationDisabledTest.java | 14 +
...terRecoveryControllerRestartPartitionsTest.java | 1 -
...ontrollerRestartPartitionsWithCleanupTest.java} | 49 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 1 -
.../rest/recovery/DisasterRecoveryController.java | 28 +
.../network/ItAbstractIgniteClusterTest.java | 8 +
.../runner/app/client/ItThinClientComputeTest.java | 35 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 2 +-
.../restart/RestartProofIgniteCluster.java | 6 +
.../internal/schema/BinaryTupleComparatorTest.java | 5 +
.../schema/PartialBinaryTupleMatcherTest.java | 134 +----
.../schema/BinaryTupleComparatorBaseTest.java | 139 +++++
.../ignite/internal/sql/engine/ItZoneDdlTest.java | 7 +-
.../prepare/ddl/DdlSqlToCommandConverter.java | 5 -
.../sql/engine/prepare/ddl/ZoneOptionEnum.java | 3 -
.../DistributionZoneSqlToCommandConverterTest.java | 6 -
...ributionZoneObsoleteSyntaxSqlDdlParserTest.java | 8 +-
.../sql/engine/sql/SqlReservedWordsTest.java | 581 +++++++++++++++++++++
.../pagememory/PersistentPageMemoryDataRegion.java | 3 +-
.../PersistentPageMemoryTableStorage.java | 20 +-
.../sorted/comparator/JitComparatorGenerator.java | 46 +-
.../sorted/comparator/JitComparatorOptions.java | 24 +-
.../PersistentPageMemoryMvTableStorageTest.java | 125 +++++
.../pagememory/PersistentPageMemoryNoLoadTest.java | 6 +-
.../index/sorted/comparator/JitComparatorTest.java | 6 +
.../disaster/ManualGroupRestartRequest.java | 17 +-
154 files changed, 2963 insertions(+), 1862 deletions(-)
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/MixinTest.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
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%)
