This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/org.slf4j-slf4j-jdk14-2.0.13
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 898e64018f Bump org.slf4j:slf4j-jdk14 from 2.0.12 to 2.0.13
add 6cb005b220 IGNITE-22039 Getting rid of InconsistentIndexStateException
for SortedIndexStorage#tolerantScan (#3674)
add 1ee67f4cc9 Bump io.github.bonede:tree-sitter-json from 0.20.1 to
0.21.0 (#3664)
add e20961ff4d IGNITE-21720 Sql. Implement hash join (#3608)
add 6705eb6f36 IGNITE-19762 Remove data region remnants from RocksDb
storage (#3677)
add 76d95724c8 IGNITE-21859 Causality token stays 0 for default zone
(#3653)
add 4bab4fa9c6 IGNITE-21763 Adjust TxnResourceVacuumTask in order to
vacuum persistent txn state (#3591)
add 1aec35c848 Bump io.github.bonede:tree-sitter from 0.22.2 to 0.22.5
(#3661)
add 66172ffc2c IGNITE-22086 Thin client: initialize observableTimestamp in
handshake (#3679)
add f7c25c937d IGNITE-18275 Remove obsolete TODOs (#3685)
add 193173cc92 IGNITE-22147 Disabled
ItTxResourcesVacuumTest.testRecoveryAfterPersistentStateVacuumized (#3686)
add d65970556f IGNITE-21731 Sql. Split TableRowConverter#toBinaryRow on
two methods (#3688)
add 8749e4da5a [IGNITE-22121] Change parameters for disaster recovery
partition states api (#3671)
add b02882dd7a IGNITE-21908 Add metrics of distribution among stripes in
disruptor (#3645)
add e034ed0e9b Bump com.netflix.nebula.ospackage from 11.8.1 to 11.9.0
(#3682)
add cb34325ecc IGNITE-22064 General MapReduce API (#3665)
add 78e1ae6fca IGNITE-21732: Sql. Split TableRowConverterImpl on two
different implementations (#3687)
add ef50f41d93 IGNITE-21962 Fix client tests relying on specific product
version (#3693)
add 0a46272fa6 [IGNITE-22091] Implement CLI for disaster recovery:
partition states (#3668)
add 654a11a4a0 IGNITE-22128 Balancing partitions across stripes (#3690)
add 7f93d63d09 [IGNITE-21999] Merge partition free-lists into one (#3615)
add 054ef3e484 [IGNITE-21295] Implement REST API for manual raft group
configuration update (#3701)
add 80ff031014 IGNITE-21300 Implement disaster recovery for secondary
indexes (#3698)
add e1012bf1b0 IGNITE-22163 Fix potential NPE in IndexManager (#3699)
add 6de12ae35e IGNITE-22159: unmute tests (#3695)
add 8aabfa8277 IGNITE-22156 Replace inheritance with delegation for
UpgradingRowAdapter class. (#3696)
add 3182188010 IGNITE-22175 Improve handling for RocksDb resources on
RocksDbKeyValueStorage (#3709)
add 43c00984cf Bump com.github.spotbugs from 6.0.12 to 6.0.14 (#3707)
add 0fee2fcf87 Bump org.slf4j:slf4j-jdk14 from 2.0.12 to 2.0.13
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 (898e64018f)
\
N -- N -- N
refs/heads/dependabot/gradle/org.slf4j-slf4j-jdk14-2.0.13 (0fee2fcf87)
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:
check-rules/spotbugs-excludes.xml | 2 +-
gradle/libs.versions.toml | 8 +-
.../java/org/apache/ignite/compute/ComputeJob.java | 5 +-
.../org/apache/ignite/compute/IgniteCompute.java | 61 +-
.../apache/ignite/compute/JobExecutionContext.java | 5 +
.../org/apache/ignite/compute/TaskExecution.java | 51 +
.../ignite/compute/task/ComputeJobRunner.java | 215 ++++
.../apache/ignite/compute/task/MapReduceTask.java | 50 +
.../TaskExecutionContext.java} | 16 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 19 +-
.../apache/ignite/lang/TableNotFoundException.java | 9 +
.../apache/ignite/internal/catalog/Catalog.java | 46 +-
.../internal/catalog/CatalogManagerImpl.java | 75 +-
.../AlterZoneSetDefaultCatalogCommand.java | 3 +-
.../internal/catalog/commands/CatalogUtils.java | 31 +-
.../catalog/commands/CreateTableCommand.java | 13 +-
.../internal/catalog/commands/DropZoneCommand.java | 3 +-
.../storage/AbstractChangeIndexStatusEntry.java | 3 +-
.../internal/catalog/storage/AlterColumnEntry.java | 3 +-
.../internal/catalog/storage/AlterZoneEntry.java | 3 +-
.../internal/catalog/storage/DropColumnsEntry.java | 3 +-
.../internal/catalog/storage/DropTableEntry.java | 4 +-
.../internal/catalog/storage/DropZoneEntry.java | 3 +-
.../internal/catalog/storage/NewColumnsEntry.java | 3 +-
.../internal/catalog/storage/NewIndexEntry.java | 4 +-
.../catalog/storage/NewSystemViewEntry.java | 4 +-
.../internal/catalog/storage/NewTableEntry.java | 4 +-
.../internal/catalog/storage/NewZoneEntry.java | 4 +-
.../catalog/storage/ObjectIdGenUpdateEntry.java | 4 +-
.../internal/catalog/storage/RemoveIndexEntry.java | 3 +-
.../internal/catalog/storage/RenameIndexEntry.java | 3 +-
.../internal/catalog/storage/RenameTableEntry.java | 3 +-
.../internal/catalog/storage/SnapshotEntry.java | 21 +-
.../internal/catalog/storage/UpdateLogImpl.java | 6 +-
...CatalogManagerDescriptorCausalityTokenTest.java | 61 +-
.../catalog/CatalogManagerRecoveryTest.java | 27 +-
.../internal/catalog/CatalogManagerSelfTest.java | 307 +++---
...ractChangeIndexStatusCommandValidationTest.java | 2 +-
.../commands/AbstractCommandValidationTest.java | 20 +-
.../AlterTableAddColumnCommandValidationTest.java | 4 +-
...AlterTableAlterColumnCommandValidationTest.java | 4 +-
.../AlterTableDropColumnCommandValidationTest.java | 4 +-
.../commands/AlterZoneCommandValidationTest.java | 2 +-
.../catalog/commands/CatalogUtilsTest.java | 6 +-
.../CreateAbstractIndexCommandValidationTest.java | 4 +-
.../commands/CreateTableCommandValidationTest.java | 19 +-
.../commands/DropIndexCommandValidationTest.java | 4 +-
.../commands/DropTableCommandValidationTest.java | 4 +-
.../commands/DropZoneCommandValidationTest.java | 4 +-
.../commands/RenameTableCommandValidationTest.java | 4 +-
.../commands/RenameZoneCommandValidationTest.java | 2 +-
.../internal/catalog/BaseCatalogManagerTest.java | 8 +-
.../ignite/internal/catalog/CatalogTestUtils.java | 27 +
.../ignite/internal/cli/CliIntegrationTest.java | 48 +
.../recovery/ItPartitionStatesCommandTest.java} | 24 +-
.../ItPartitionStatesReplCommandTest.java} | 21 +-
.../commands/recovery/ItPartitionStatesTest.java | 314 ++++++
.../cli/call/recovery/PartitionStatesCall.java | 125 +++
.../call/recovery/PartitionStatesCallInput.java | 146 +++
.../ignite/internal/cli/commands/Options.java | 20 +
.../internal/cli/commands/TopLevelCliCommand.java | 4 +-
.../cli/commands/TopLevelCliReplCommand.java | 4 +-
.../cli/commands/recovery/RecoveryCommand.java} | 25 +-
.../commands/recovery/RecoveryReplCommand.java} | 25 +-
.../partitions/PartitionStatesCommand.java | 50 +
.../recovery/partitions/PartitionStatesMixin.java | 123 +++
.../partitions/PartitionStatesReplCommand.java | 52 +
.../client/handler/ItClientHandlerMetricsTest.java | 26 +-
.../ignite/client/handler/ItClientHandlerTest.java | 26 +-
.../apache/ignite/client/handler/TestServer.java | 4 +-
.../handler/ClientInboundMessageHandler.java | 2 +
.../requests/table/ClientHandlerTupleTests.java | 6 +-
.../ignite/internal/client/ClientChannel.java | 15 -
.../internal/client/ClientChannelFactory.java | 5 +-
.../ignite/internal/client/ReliableChannel.java | 12 +-
.../ignite/internal/client/TcpClientChannel.java | 44 +-
.../ignite/internal/client/TcpIgniteClient.java | 3 +-
.../internal/client/compute/ClientCompute.java | 38 +-
.../client/compute/task/ClientTaskExecution.java} | 38 +-
.../apache/ignite/client/ClientMetricsTest.java | 8 +-
.../client/ObservableTimestampPropagationTest.java | 6 +
.../java/org/apache/ignite/client/TestServer.java | 4 +-
.../apache/ignite/client/fakes/FakeCompute.java | 37 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 4 +-
.../RepeatedFinishClientTransactionTest.java | 11 -
modules/cluster-management/build.gradle | 2 +
.../management/raft/ItCmgRaftServiceTest.java | 3 +-
.../management/ClusterManagementGroupManager.java | 2 -
.../internal/cluster/management/MockNode.java | 3 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 44 +
.../internal/compute/ItComputeTestEmbedded.java | 6 -
.../ignite/internal/compute/ItMapReduceTest.java | 296 ++++++
.../internal/compute/utils/InteractiveJobs.java | 34 +-
.../internal/compute/utils/InteractiveTasks.java | 248 +++++
.../apache/ignite/internal/compute/MapReduce.java | 59 ++
.../internal/compute/AntiHijackIgniteCompute.java | 12 +
.../internal/compute/AntiHijackJobExecution.java | 2 +-
.../ignite/internal/compute/ComputeComponent.java | 35 +-
.../internal/compute/ComputeComponentImpl.java | 61 +-
.../ignite/internal/compute/ComputeUtils.java | 53 +-
.../ignite/internal/compute/ExecutionManager.java | 15 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 54 +-
.../internal/compute/TaskExecutionWrapper.java} | 38 +-
.../internal/compute/executor/ComputeExecutor.java | 7 +-
.../compute/executor/ComputeExecutorImpl.java | 14 +
.../compute/messaging/ComputeMessaging.java | 16 +-
.../compute/task/AntiHijackTaskExecution.java | 49 +
.../DelegatingTaskExecution.java} | 41 +-
.../internal/compute/task/JobSubmitter.java} | 18 +-
.../compute/task/TaskExecutionInternal.java | 294 ++++++
.../internal/testframework/IgniteTestUtils.java | 8 +-
modules/distribution-zones/build.gradle | 2 +
...niteDistributionZoneManagerNodeRestartTest.java | 13 +
.../DistributionZoneNotFoundException.java | 9 +
.../distributionzones/rebalance/RebalanceUtil.java | 61 +-
.../BaseDistributionZoneManagerTest.java | 3 +
.../DistributionZonesTestUtil.java | 2 +-
modules/index/build.gradle | 1 +
.../internal/index/ItBuildIndexOneNodeTest.java | 105 ++
.../index/IndexAvailabilityController.java | 7 +-
.../index/IndexBuildCompletionListener.java | 12 +-
.../internal/index/IndexBuildController.java | 82 +-
.../ignite/internal/index/IndexBuildTask.java | 20 +-
.../apache/ignite/internal/index/IndexBuilder.java | 83 +-
.../apache/ignite/internal/index/IndexManager.java | 5 +-
.../index/ChangeIndexStatusTaskControllerTest.java | 8 +-
.../internal/index/ChangeIndexStatusTaskTest.java | 3 +
.../index/IndexAvailabilityControllerTest.java | 12 +-
.../internal/index/IndexBuildControllerTest.java | 108 +-
.../ignite/internal/index/IndexBuilderTest.java | 67 +-
.../ignite/internal/index/IndexManagerTest.java | 3 +
modules/metastorage/build.gradle | 2 +
.../impl/ItMetaStorageManagerImplTest.java | 4 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 2 +
.../metastorage/impl/ItMetaStorageServiceTest.java | 2 +
.../metastorage/impl/ItMetaStorageWatchTest.java | 2 +
.../server/persistence/RocksDbKeyValueStorage.java | 47 +-
modules/metrics/build.gradle | 3 +
.../metrics/exporters/ItJvmMetricSourceTest.java | 3 +-
.../exporters/ItMetricExportersLoadingTest.java | 3 +-
.../apache/ignite/internal/metrics/LongGauge.java | 2 +-
.../ignite/internal/metrics/MetricManager.java | 213 +---
.../{MetricManager.java => MetricManagerImpl.java} | 121 +--
.../internal/metrics/SimpleMovingAverage.java | 80 ++
.../configuration/MetricConfigurationModule.java | 3 +-
.../internal/metrics/exporters/MetricExporter.java | 5 +-
.../LogPushExporterConfigurationSchema.java} | 21 +-
.../metrics/exporters/jmx/MetricSetMbean.java | 4 +-
.../metrics/exporters/log/LogPushExporter.java | 90 ++
.../internal/metrics/sources/JvmMetricSource.java | 27 +-
.../internal/metrics/MetricConfigurationTest.java | 2 +-
.../ignite/internal/metrics/MovingAverageTest.java | 90 ++
.../ignite/internal/metrics/NoOpMetricManager.java | 96 ++
.../internal/pagememory/PageMemoryIoModule.java | 4 +-
.../ignite/internal/pagememory/Storable.java | 57 +-
.../pagememory/datapage/DataPageReader.java | 4 +-
.../datapage/NonFragmentableDataPageReader.java | 4 +-
.../datapage/ReadPageMemoryRowValue.java | 5 +
.../pagememory/datastructure/DataStructure.java | 2 +-
.../internal/pagememory/freelist/FreeList.java | 19 +-
.../{AbstractFreeList.java => FreeListImpl.java} | 115 +--
.../internal/pagememory/freelist/PagesList.java | 13 +-
.../{AbstractDataPageIo.java => DataPageIo.java} | 139 +--
.../pagememory/persistence/PartitionMeta.java | 71 +-
.../pagememory/persistence/io/PartitionMetaIo.java | 47 +-
...ractFreeListTest.java => FreeListImplTest.java} | 44 +-
.../pagememory/freelist/TestDataPageIo.java | 75 --
.../internal/pagememory/freelist/TestDataRow.java | 27 +-
.../persistence/PartitionMetaManagerTest.java | 13 +-
.../pagememory/persistence/PartitionMetaTest.java | 22 +-
.../persistence/checkpoint/CheckpointerTest.java | 2 +-
modules/placement-driver/build.gradle | 2 +
.../ItPrimaryReplicaChoiceTest.java | 6 +-
.../MultiActorPlacementDriverTest.java | 4 +-
.../PlacementDriverManagerTest.java | 2 +
.../internal/placementdriver/LeaseUpdater.java | 21 +-
.../cpp/ignite/client/detail/node_connection.cpp | 14 +-
.../cpp/ignite/client/detail/node_connection.h | 7 +
modules/platforms/cpp/ignite/common/error_codes.h | 11 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 7 +-
modules/platforms/cpp/ignite/protocol/messages.cpp | 2 +
modules/platforms/cpp/ignite/protocol/messages.h | 3 +
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 14 +
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 6 +-
.../Transactions/TransactionsTests.cs | 21 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 23 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 25 +-
.../Apache.Ignite/Internal/ConnectionContext.cs | 2 +
modules/raft/build.gradle | 3 +
.../ignite/internal/raft/ItLearnersTest.java | 3 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 3 +-
.../internal/raft/ItRaftGroupServiceTest.java | 9 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 3 +-
.../internal/metrics/sources/RaftMetricSource.java | 178 ++++
.../java/org/apache/ignite/internal/raft/Loza.java | 15 +
.../internal/raft/server/impl/JraftServerImpl.java | 17 +-
.../raft/storage/impl/StripeAwareLogManager.java | 21 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 30 +-
.../raft/jraft/disruptor/StripedDisruptor.java | 98 +-
.../raft/jraft/option/LogManagerOptions.java | 11 +
.../ignite/raft/jraft/option/NodeOptions.java | 16 +
.../ignite/disruptor/StripedDisruptorTest.java | 56 +-
.../org/apache/ignite/internal/raft/LozaTest.java | 3 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 11 +-
.../raft/jraft/core/ReadOnlyServiceTest.java | 11 +-
.../raft/jraft/storage/impl/LogManagerTest.java | 11 +-
modules/replicator/build.gradle | 2 +
.../ItPlacementDriverReplicaSideTest.java | 2 +
.../rest/api/recovery/DisasterRecoveryApi.java | 52 +-
.../api/recovery/GlobalPartitionStateResponse.java | 8 +
.../recovery/GlobalPartitionStatesResponse.java | 3 +
.../api/recovery/LocalPartitionStateResponse.java | 8 +
.../api/recovery/LocalPartitionStatesResponse.java | 3 +
.../rest/api/recovery/ResetPartitionsRequest.java | 79 ++
.../exception/handler/IgniteExceptionHandler.java | 10 +-
.../handler/IgniteInternalExceptionHandler.java | 12 +-
...asterRecoveryControllerResetPartitionsTest.java | 80 ++
.../recovery/ItDisasterRecoveryControllerTest.java | 379 ++++++-
.../rest/recovery/DisasterRecoveryController.java | 48 +-
modules/runner/build.gradle | 1 +
.../internal/benchmark/SqlJoinBenchmark.java | 136 +++
.../ItDistributedConfigurationPropertiesTest.java | 9 +-
.../ItDistributedConfigurationStorageTest.java | 10 +-
.../runner/app/ItIgniteNodeRestartTest.java | 7 +-
.../ItRaftCommandLeftInLogUntilRestartTest.java | 3 +-
.../internal/runner/app/ItTablesApiTest.java | 4 +-
.../ignite/internal/table/ItDurableFinishTest.java | 4 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 9 +-
.../internal/ClusterPerClassIntegrationTest.java | 3 +-
.../apache/ignite/internal/table/NodeUtils.java | 98 +-
.../schema/registry/UpgradingRowAdapter.java | 167 +++-
.../org/apache/ignite/internal/schema/row/Row.java | 144 +--
.../internal/schema/row/{Row.java => RowImpl.java} | 60 +-
.../schema/registry/UpgradingRowAdapterTest.java | 137 +--
.../internal/sql/engine/ItAggregatesTest.java | 1 +
.../internal/sql/engine/ItCorrelatesTest.java | 7 +-
.../internal/sql/engine/ItCreateTableDdlTest.java | 3 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 6 +-
.../sql/engine/ItHashSpoolIntegrationTest.java | 3 +-
.../internal/sql/engine/ItIndexSpoolTest.java | 2 +-
.../ignite/internal/sql/engine/ItJoinTest.java | 230 ++++-
.../internal/sql/engine/ItSecondaryIndexTest.java | 4 +-
.../sql/aggregate/aggregates/test_sum.test | 2 -
...ontraint.test => test_not_null_constraint.test} | 2 -
.../sql/filter/test_zonemap.test_ignore | 2 +-
.../sql/function/generic/test_large_in.test_ignore | 2 +-
.../sql/join/natural/natural_join.test | 2 +
.../test_cross_product_parallelism.test_ignore | 2 +-
.../sql/order/test_order_same_value.test | 2 +-
.../sql/types/decimal/decimal_arithmetic.test | 16 +-
.../decimal/decimal_decimal_overflow_cast.test | 20 -
..._overflow.test_ignore => decimal_overflow.test} | 53 +-
.../sql/types/decimal/decimal_overflow_table.test | 18 +-
.../sql/types/decimal/test_decimal.test | 21 +-
.../sql/types/decimal/test_decimal_cast.test | 2 +-
.../sql/types/string/test_scan_big_varchar.test | 12 +-
.../sql/engine/exec/LogicalRelImplementor.java | 20 +
...pl.java => ProjectedTableRowConverterImpl.java} | 51 +-
.../sql/engine/exec/ScannableTableImpl.java | 2 +-
.../sql/engine/exec/SqlOutputBinaryRow.java | 25 +-
.../sql/engine/exec/TableRowConverter.java | 22 +-
.../engine/exec/TableRowConverterFactoryImpl.java | 6 +-
.../sql/engine/exec/TableRowConverterImpl.java | 62 +-
.../sql/engine/exec/UpdatableTableImpl.java | 16 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 6 +
.../rel/AbstractRightMaterializedJoinNode.java | 169 ++++
.../internal/sql/engine/exec/rel/HashJoinNode.java | 707 +++++++++++++
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 164 +--
.../sql/engine/prepare/IgniteRelShuttle.java | 7 +
.../internal/sql/engine/prepare/PlannerPhase.java | 2 +
.../internal/sql/engine/rel/IgniteHashJoin.java | 111 +++
.../internal/sql/engine/rel/IgniteRelVisitor.java | 5 +
.../sql/engine/rule/HashJoinConverterRule.java | 95 ++
.../sql/engine/exec/ExecutionServiceImplTest.java | 13 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 122 +++
.../sql/engine/exec/TableRowConverterSelfTest.java | 13 +-
.../engine/exec/mapping/FragmentMappingTest.java | 14 +
...ionTest.java => AbstractJoinExecutionTest.java} | 221 ++--
.../sql/engine/exec/rel/ExecutionTest.java | 172 ----
.../sql/engine/exec/rel/HashJoinExecutionTest.java | 141 +++
.../exec/rel/NestedLoopJoinExecutionTest.java | 360 +------
.../engine/exec/rel/ScannableTableSelfTest.java | 7 +-
.../exec/rel/TableScanNodeExecutionTest.java | 7 +-
.../sql/engine/framework/TestBuilders.java | 4 +-
.../sql/engine/planner/AggregatePlannerTest.java | 3 +-
.../planner/ColocatedHashAggregatePlannerTest.java | 3 +-
.../planner/ColocatedSortAggregatePlannerTest.java | 3 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 4 +-
.../sql/engine/planner/HashIndexPlannerTest.java | 4 +-
.../engine/planner/HashIndexSpoolPlannerTest.java | 6 +-
.../sql/engine/planner/HashJoinPlannerTest.java | 190 ++++
.../sql/engine/planner/ImplicitCastsTest.java | 2 +-
.../engine/planner/JoinColocationPlannerTest.java | 129 ++-
.../sql/engine/planner/JoinCommutePlannerTest.java | 16 +-
.../planner/MapReduceHashAggregatePlannerTest.java | 3 +-
.../planner/MapReduceSortAggregatePlannerTest.java | 3 +-
.../sql/engine/planner/MergeJoinPlannerTest.java | 3 +-
.../sql/engine/planner/PlannerTimeoutTest.java | 4 +-
.../planner/SortedIndexSpoolPlannerTest.java | 6 +-
.../sql/engine/planner/TableSpoolPlannerTest.java | 2 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 4 +-
.../sql/metrics/PlanningCacheMetricsTest.java | 3 +-
.../src/test/resources/mapping/correlated.test | 10 +-
.../src/test/resources/mapping/hash_join.test | 102 ++
.../src/test/resources/mapping/merge_join.test | 6 +-
.../resources/mapping/test_partition_pruning.test | 6 +-
.../internal/sql/BaseSqlIntegrationTest.java | 16 +-
.../index/InconsistentIndexStateException.java | 39 -
.../internal/storage/index/SortedIndexStorage.java | 2 -
.../storage/AbstractMvTableStorageTest.java | 63 ++
.../PersistentPageMemoryTableStorage.java | 95 +-
.../pagememory/VolatilePageMemoryDataRegion.java | 52 +-
.../VolatilePageMemoryStorageEngine.java | 8 +-
.../pagememory/VolatilePageMemoryTableStorage.java | 8 +-
.../index/AbstractPageMemoryIndexStorage.java | 12 +-
.../pagememory/index/IndexPageIoModule.java | 3 -
.../storage/pagememory/index/IndexPageTypes.java | 13 +-
.../pagememory/index/freelist/IndexColumns.java | 43 +-
.../index/freelist/IndexColumnsFreeList.java | 105 --
.../index/freelist/ReadIndexColumnsValue.java | 5 +
.../index/freelist/io/IndexColumnsDataIo.java | 85 --
.../hash/InsertHashIndexRowInvokeClosure.java | 8 +-
.../index/hash/PageMemoryHashIndexStorage.java | 6 +-
.../hash/RemoveHashIndexRowInvokeClosure.java | 8 +-
.../sorted/InsertSortedIndexRowInvokeClosure.java | 8 +-
.../index/sorted/PageMemorySortedIndexStorage.java | 6 +-
.../sorted/RemoveSortedIndexRowInvokeClosure.java | 8 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 38 +-
.../storage/pagememory/mv/BlobStorage.java | 2 +-
.../pagememory/mv/CommitWriteInvokeClosure.java | 54 +-
.../storage/pagememory/mv/IndexStorageFactory.java | 39 +-
.../storage/pagememory/mv/MvPageIoModule.java | 2 -
.../storage/pagememory/mv/MvPageTypes.java | 11 +-
.../mv/PersistentPageMemoryMvPartitionStorage.java | 57 +-
.../storage/pagememory/mv/ReadRowVersionValue.java | 5 +
.../mv/RemoveWriteOnGcInvokeClosure.java | 60 +-
.../mv/RenewablePartitionStorageState.java | 23 +-
.../internal/storage/pagememory/mv/RowVersion.java | 71 +-
.../storage/pagememory/mv/RowVersionFreeList.java | 187 ----
.../mv/VolatilePageMemoryMvPartitionStorage.java | 12 +-
.../storage/pagememory/mv/io/RowVersionDataIo.java | 154 ---
.../VolatilePageMemoryMvTableStorageTest.java | 21 +-
.../storage/rocksdb/RocksDbStorageEngine.java | 67 +-
...bDataRegion.java => RocksDbStorageProfile.java} | 31 +-
.../schema/RocksDbProfileConfigurationSchema.java | 2 +-
.../instance/SharedRocksDbInstanceCreator.java | 6 +-
.../instance/SharedRocksDbInstanceTest.java | 18 +-
modules/table/build.gradle | 3 +
.../ReplicasSafeTimePropagationTest.java | 2 +
.../ItDisasterRecoveryReconfigurationTest.java | 79 +-
.../rebalance/ItRebalanceDistributedTest.java | 10 +-
.../table/ItTransactionPrimaryChangeTest.java | 20 +-
.../internal/table/ItTransactionRecoveryTest.java | 15 +-
.../internal/table/ItTxResourcesVacuumTest.java | 1054 ++++++++++++++++++++
.../internal/table/MutableRowTupleAdapter.java | 4 +-
.../internal/table/RecordBinaryViewImpl.java | 22 +
.../ignite/internal/table/RecordViewImpl.java | 6 +-
.../disaster/DisasterRecoveryManager.java | 306 ++++--
.../distributed/disaster/GlobalPartitionState.java | 5 +-
.../distributed/disaster/LocalPartitionState.java | 5 +-
...onState.java => LocalPartitionStateByNode.java} | 34 +-
.../disaster/LocalPartitionStateMessageByNode.java | 53 +
.../disaster/ManualGroupUpdateRequest.java | 10 +-
.../exceptions/DisasterRecoveryException.java} | 24 +-
.../exceptions/IllegalPartitionIdException.java | 38 +
.../NodesNotFoundException.java} | 20 +-
.../ZonesNotFoundException.java} | 20 +-
.../messages/LocalPartitionStatesRequest.java | 7 +-
.../table/distributed/raft/PartitionListener.java | 32 +-
.../replicator/PartitionReplicaListener.java | 30 +-
.../CatalogStorageIndexDescriptorSupplierTest.java | 4 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../internal/table/distributed/TableUtilsTest.java | 2 +-
.../FullStateTransferIndexChooserTest.java | 2 +-
.../snapshot/outgoing/SnapshotMetaUtilsTest.java | 4 +-
.../replicator/ReplicatorUtilsTest.java | 2 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +
modules/transactions/build.gradle | 7 +
.../org/apache/ignite/internal/tx/TxManager.java | 10 +-
.../org/apache/ignite/internal/tx/TxStateMeta.java | 2 +
.../tx/impl/PersistentTxStateVacuumizer.java | 129 +++
.../internal/tx/impl/ResourceVacuumManager.java | 28 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 27 +-
.../tx/impl/VolatileTxStateMetaStorage.java | 138 ++-
.../ignite/internal/tx/message/TxMessageGroup.java | 10 +
.../tx/message/VacuumTxStateReplicaRequest.java} | 19 +-
.../tx/message/VacuumTxStatesCommand.java} | 19 +-
.../state/ThreadAssertingTxStateStorage.java | 4 +-
.../internal/tx/storage/state/TxStateStorage.java | 4 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 15 +-
.../storage/state/AbstractTxStateStorageTest.java | 4 +-
.../tx/storage/state/test/TestTxStateStorage.java | 7 +-
.../internal/tx/test/ItTransactionTestUtils.java | 233 +++++
393 files changed, 11358 insertions(+), 4163 deletions(-)
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/TaskExecution.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/task/ComputeJobRunner.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/compute/task/MapReduceTask.java
copy
modules/api/src/main/java/org/apache/ignite/compute/{JobExecutionContext.java
=> task/TaskExecutionContext.java} (76%)
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/ItPartitionStatesCommandTest.java}
(59%)
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/ItPartitionStatesReplCommandTest.java}
(66%)
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/recovery/ItPartitionStatesTest.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/PartitionStatesCall.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/PartitionStatesCallInput.java
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/RecoveryCommand.java}
(61%)
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/RecoveryReplCommand.java}
(60%)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/PartitionStatesCommand.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/PartitionStatesMixin.java
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/commands/recovery/partitions/PartitionStatesReplCommand.java
copy
modules/{compute/src/main/java/org/apache/ignite/internal/compute/AntiHijackJobExecution.java
=>
client/src/main/java/org/apache/ignite/internal/client/compute/task/ClientTaskExecution.java}
(52%)
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/ItMapReduceTest.java
create mode 100644
modules/compute/src/integrationTest/java/org/apache/ignite/internal/compute/utils/InteractiveTasks.java
create mode 100644
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/MapReduce.java
copy
modules/{metrics/src/main/java/org/apache/ignite/internal/metrics/LongGauge.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/TaskExecutionWrapper.java}
(51%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/task/AntiHijackTaskExecution.java
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{AntiHijackJobExecution.java
=> task/DelegatingTaskExecution.java} (53%)
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
compute/src/main/java/org/apache/ignite/internal/compute/task/JobSubmitter.java}
(67%)
create mode 100644
modules/compute/src/main/java/org/apache/ignite/internal/compute/task/TaskExecutionInternal.java
copy
modules/metrics/src/main/java/org/apache/ignite/internal/metrics/{MetricManager.java
=> MetricManagerImpl.java} (75%)
create mode 100644
modules/metrics/src/main/java/org/apache/ignite/internal/metrics/SimpleMovingAverage.java
copy
modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java
=>
metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/LogPushExporterConfigurationSchema.java}
(60%)
create mode 100644
modules/metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/log/LogPushExporter.java
create mode 100644
modules/metrics/src/test/java/org/apache/ignite/internal/metrics/MovingAverageTest.java
create mode 100644
modules/metrics/src/testFixtures/java/org/apache/ignite/internal/metrics/NoOpMetricManager.java
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/freelist/{AbstractFreeList.java
=> FreeListImpl.java} (89%)
rename
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/io/{AbstractDataPageIo.java
=> DataPageIo.java} (92%)
rename
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/freelist/{AbstractFreeListTest.java
=> FreeListImplTest.java} (87%)
delete mode 100644
modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/freelist/TestDataPageIo.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/metrics/sources/RaftMetricSource.java
create mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/ResetPartitionsRequest.java
create mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/recovery/ItDisasterRecoveryControllerResetPartitionsTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/SqlJoinBenchmark.java
copy
modules/schema/src/main/java/org/apache/ignite/internal/schema/row/{Row.java =>
RowImpl.java} (71%)
rename
modules/sql-engine/src/integrationTest/sql/contstraint/{test_not_null_contraint.test
=> test_not_null_constraint.test} (99%)
rename
modules/sql-engine/src/integrationTest/sql/types/decimal/{decimal_overflow.test_ignore
=> decimal_overflow.test} (76%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/{TableRowConverterImpl.java
=> ProjectedTableRowConverterImpl.java} (63%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/AbstractRightMaterializedJoinNode.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinNode.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rel/IgniteHashJoin.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/HashJoinConverterRule.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/ProjectedTableRowConverterSelfTest.java
copy
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/{NestedLoopJoinExecutionTest.java
=> AbstractJoinExecutionTest.java} (68%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/HashJoinExecutionTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/planner/HashJoinPlannerTest.java
create mode 100644 modules/sql-engine/src/test/resources/mapping/hash_join.test
delete mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/InconsistentIndexStateException.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/freelist/IndexColumnsFreeList.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/index/freelist/io/IndexColumnsDataIo.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/RowVersionFreeList.java
delete mode 100644
modules/storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/io/RowVersionDataIo.java
rename
modules/storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/{RocksDbDataRegion.java
=> RocksDbStorageProfile.java} (62%)
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/table/ItTxResourcesVacuumTest.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{LocalPartitionState.java
=> LocalPartitionStateByNode.java} (53%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalPartitionStateMessageByNode.java
copy
modules/{storage-page-memory/src/main/java/org/apache/ignite/internal/storage/pagememory/mv/ReadRowVersionValue.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/DisasterRecoveryException.java}
(61%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/IllegalPartitionIdException.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{LocalPartitionState.java
=> exceptions/NodesNotFoundException.java} (60%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{GlobalPartitionState.java
=> exceptions/ZonesNotFoundException.java} (59%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/impl/PersistentTxStateVacuumizer.java
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionStatesRequest.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/message/VacuumTxStateReplicaRequest.java}
(64%)
copy
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/messages/LocalPartitionStatesRequest.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/message/VacuumTxStatesCommand.java}
(65%)
create mode 100644
modules/transactions/src/testFixtures/java/org/apache/ignite/internal/tx/test/ItTransactionTestUtils.java
