This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to branch
dependabot/gradle/io.github.goooler.shadow-8.1.8
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 336b74765e Bump io.github.goooler.shadow from 8.1.7 to 8.1.8
add 9b42e3e815 IGNITE-22073 Sql. Add processing of the provided query
timeout (#3953)
add aab9667bda IGNITE-22589 Fix FailureProcessor initialization (#3994)
add 6e7f25d33c IGNITE-22569 Java thin: fix SqlBatchException propagation
(#3982)
add 055b61f97c IGNITE-22539 .NET: Add JobTarget (#3993)
add 351c235c4e IGNITE-22540 .NET: Add ReceiverDescriptor to Data Streamer
(#3996)
add bd01805e70 IGNITE-22574 Ignite CLI: Allow to pass multiple files with
cluster configuration for init command. (#3986)
add f32aacace8 IGNITE-22532 Fix --metastorage-group option description
(#3992)
add 43260e7b05 IGNITE-22533 Extra error when trying to run non-existant
sql file (#3997)
add 9841802211 IGNITE-22224 Rework embedded mode API (#3908)
add 879936c865 IGNITE-22460 Rename libignite-client.so to
libignite3-client.so (#3998)
add b2695def59 IGNITE-22525 .NET: Rename JobStatus to JobState and vice
versa (#3999)
add 154d928095 IGNITE-22594 Fix compilation (#4000)
add 4ada0383ed IGNITE-22583 Get rid of byte[] in messages (#3990)
add 7bfa2a0fe8 IGNITE-20503 Sql. Support big clusters by mapping service
(#3966)
add 9a428ca373 IGNITE-22566 Add C++ docs generation to gradle (#4001)
add 2efe7840f4 IGNITE-22526 Rename job_state to job_status and vice versa
(#4002)
add 3acfe1c97e IGNITE-22264 Fix startup instructions in Ignite examples
(#3967)
add fa931b1c02 IGNITE-22426 Move deployment code to separate package
(#4008)
add 8a1a15a0d7 IGNITE-22364 Remove daemon mode in zip distribution (#3940)
add cb69d4f6f2 IGNITE-22527 C++ Add parameter object to Compute API (#4013)
add 079225e576 IGNITE-22603 Add InetSocketAddress caching for
DefaultMessagingService (#4011)
add ae3800ea82 IGNITE-22588 Fix performance of JDBC driver (#4012)
add 29b2e2b7fb IGNITE-22611 SQL. Statement should not extends AutoClosable
(#4015)
add 12c13ef177 IGNITE-22612 SQL highlighter sometimes fails (#4016)
add dc962df81b IGNITE-22434 Do not inherit TaskExecution from JobExecution
(#4007)
add 692ecdedc2 IGNITE-22478 Use single argument in Compute API (#3926)
add ea59431e01 IGNITE-22578 Sql. Extend test coverage for numeric to/from
decimal cast with overflow (#3985)
add 07dc45afc3 IGNITE-22614 Get rid of @Marshallable in package
org.apache.ignite.internal.partition.replicator.network (#4019)
add 9bc629a998 IGNITE-22618 Remove MvPartitionStorage#rowsCount (#4020)
add d9576076e1 IGNITE-22615 Get rid of @Marshallable in ReplicaRequest
(#4023)
add 787e868ede IGNITE-22632 Handle cluster configuration file reading
error (#4024)
add bd896fcf87 IGNITE-22597 Use SMFullThrowable when exception in user's
state machine happens. (#4022)
add a456027af3 IGNITE-22507 Add `MvPartitionStorage#estimatedSize` method
(#4025)
add a4ea716e72 IGNITE-22631 Get rid of @Marshallable in
org.apache.ignite.internal.tx.message (#4026)
add d6397cdaec IGNITE-22629 Disable
ItReplicaStateManagerTest.testReplicaStatesManagement (#4030)
add c8a03bc7f5 IGNITE-22410 Implement rebalance triggers for zone based
partitions (#3943)
add b68f771f3d IGNITE-22556 Fix exception in
IndexBuildController.requireMvTableStorageNonNull (#4033)
add 3279ae75f9 IGNITE-22448: Sql. Incorrect error message when aggregate
function is called with UUID type. (#4006)
add e1dca925ef IGNITE-22651 Add @Nullable for NetworkMessage fields for
generated classes (#4037)
add c76d322e12 IGNITE-22171: Sql. Row cast fails with NPE (#4010)
add cccb376830 IGNITE-22567 Add `containsAll` to `RecordView` and
`KeyValueView` (#4018)
add f8de23cd24 IGNITE-22408 Create MSI package for ODBC (#4041)
add 88782c880e IGNITE-22601 Pass instance of ValidationManager to
CmgRaftGroupListener constructor. (#4036)
add 548acde12f Bump org.rocksdb:rocksdbjni from 9.2.1 to 9.3.1 (#4039)
add f62f133bec Bump org.openapi.generator from 7.6.0 to 7.7.0 (#4029)
add d132b9f7db IGNITE-21512 Enable a test in ItSchemaSyncMultiNodeTest
(#4050)
add 086494ee07 IGNITE-22673 Fix predicate in candition of
IndexMetaStorage#saveToMetastore (#4051)
add 0799d6068b IGNITE-22674 Fix predicate in condition of
UpdateLogImpl#saveSnapshot (#4052)
add df2174bb0c IGNITE-22648: make linux packaging more native (#4046)
add 065700d196 IGNITE-22675 Recovery CLI commands don't accept profile
option (#4053)
add 4d2a6da039 IGNITE-22677 Fix C++ dependency handling for MacOS (#4054)
add 876a202f88 IGNITE-22415 Search for table in older versions of catalog
(#3885)
add 07fd38004c IGNITE-22668 Fix batch commit in StripeAwareLogManager
(#4047)
add 20a498fb49 IGNITE-22686 Fix ODBC MSI package build (#4058)
add 84b760b54c IGNITE-22315 Make raft-client starting only once and only
with raft-client and replica together (#3956)
add 4687dae71d IGNITE-22633 Catalog compaction. Implement choosing of
coordinator (#4042)
add eae38b8ee3 IGNITE-22521 Enable
ItIgniteNodeRestartTest.testSequentialAsyncTableCreationThenAlterZoneThenRestartOnMsSnapshot
(#4027)
add 044ad2a822 IGNITE-21303 Fix the way we save new assignments for
"resetPartitions" command (#4038)
add 8e0c592198 IGNITE-15624: Calcite. get rid of tests required support of
different connections in logical tests. (#4028)
add 57c07ee68d IGNITE-22465 Recover zones' replicas and pending/stable
events on a node restart (#4043)
add a5140d30ba IGNITE-22693 Add protection against internal thread
hijacking to PartitionManager (#4061)
add 2cc4e11381 IGNITE-22676 Add protection against internal thread
hijacking to IgniteCatalog (#4060)
add a00da3d757 IGNITE-22629 Fix
ItReplicaStateManagerTest.testReplicaStatesManagement (#4040)
add be15cc7c95 IGNITE-22150 .NET: Add PartitionManager API (#4062)
add a4d39fb194 IGNITE-22519: Sql. Numerics. Conversion produces incorrect
results (#4044)
add 2edaa01d00 IGNITE-22698 Sql. Extend test coverage for numeric
comparison with literal wider than numeric type (#4063)
add 618a0a9d83 Bump junit5 from 5.10.2 to 5.10.3 (#4003)
add d41170dd2d Bump net.bytebuddy:byte-buddy from 1.14.17 to 1.14.18
(#4064)
add 31c7dc5e9a Bump io.github.goooler.shadow from 8.1.7 to 8.1.8
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 (336b74765e)
\
N -- N -- N
refs/heads/dependabot/gradle/io.github.goooler.shadow-8.1.8 (31c7dc5e9a)
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:
.idea/inspectionProfiles/Project_Default.xml | 5 +-
docs/_docs/ignite-cli-tool.adoc | 2 +-
examples/README.md | 78 ++-
examples/config/ignite-config.conf | 23 +-
.../ignite/example/AbstractExamplesTest.java | 24 +-
.../apache/ignite/example/sql/SqlApiExample.java | 31 +-
.../ignite/example/sql/jdbc/SqlJdbcExample.java | 22 +-
.../PersistentPageMemoryStorageExample.java | 26 +-
.../example/storage/RocksDbStorageExample.java | 26 +-
.../storage/VolatilePageMemoryStorageExample.java | 26 +-
.../ignite/example/table/KeyValueViewExample.java | 22 +-
.../example/table/KeyValueViewPojoExample.java | 22 +-
.../ignite/example/table/RecordViewExample.java | 22 +-
.../example/table/RecordViewPojoExample.java | 22 +-
.../ignite/example/tx/TransactionsExample.java | 22 +-
gradle/libs.versions.toml | 10 +-
.../src/main/java/org/apache/ignite/Ignite.java | 2 +-
.../src/main/java/org/apache/ignite/Ignition.java | 91 ---
.../java/org/apache/ignite/IgnitionManager.java | 126 ----
.../org/apache/ignite/InitParametersBuilder.java | 123 ----
.../java/org/apache/ignite/compute/ComputeJob.java | 35 +-
.../org/apache/ignite/compute/IgniteCompute.java | 99 +--
.../org/apache/ignite/compute/JobDescriptor.java | 78 ++-
.../compute/{ComputeJob.java => TaskState.java} | 49 +-
.../org/apache/ignite/compute/TaskStatus.java} | 38 +-
.../apache/ignite/compute/task/MapReduceJob.java | 43 +-
.../apache/ignite/compute/task/MapReduceTask.java | 18 +-
.../apache/ignite/compute/task/TaskExecution.java | 47 +-
.../{compute => deployment}/DeploymentUnit.java | 4 +-
.../version/UnitVersion.java | 2 +-
.../{compute => deployment}/version/Version.java | 2 +-
.../version/VersionParseException.java | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 65 +-
.../ignite/marshaling/ByteArrayMarshaler.java | 56 ++
.../JavaSerializationByteArrayMarshallilng.java | 70 +++
.../org/apache/ignite/marshaling/Marshaler.java | 57 ++
.../ignite/marshaling/MarshallingException.java} | 31 +-
.../apache/ignite/marshaling/TupleMarshaller.java} | 17 +-
.../UnsupportedObjectTypeMarshalingException.java | 53 ++
.../org/apache/ignite/sql/SqlBatchException.java | 22 +-
.../java/org/apache/ignite/sql/SqlException.java | 9 +-
.../main/java/org/apache/ignite/sql/Statement.java | 2 +-
.../apache/ignite/table/DataStreamerReceiver.java | 11 +-
.../apache/ignite/table/DataStreamerTarget.java | 9 +-
.../java/org/apache/ignite/table/KeyValueView.java | 23 +-
.../apache/ignite/table/ReceiverDescriptor.java | 48 +-
.../java/org/apache/ignite/table/RecordView.java | 23 +-
.../version/VersionTest.java | 2 +-
.../ignite/marshaling/ByteArrayMarshalerTest.java | 167 +++++
modules/catalog-dsl/build.gradle | 2 +
.../catalog/ItCatalogApiThreadingTest.java | 184 ++++++
.../ignite/internal/catalog/ItCatalogDslTest.java | 138 +----
.../org/apache/ignite/internal/catalog/Pojo.java | 89 +++
.../apache/ignite/internal/catalog/PojoKey.java} | 25 +-
.../apache/ignite/internal/catalog/PojoValue.java | 82 +++
modules/catalog/build.gradle | 6 +
...ItCatalogCompactionCoordinatorChoosingTest.java | 118 ++++
.../internal/catalog/CatalogManagerImpl.java | 23 +-
.../internal/catalog/storage/UpdateLogImpl.java | 11 +-
.../catalog/storage/UpdateLogImplTest.java | 12 +-
...liCommandTestNotInitializedIntegrationBase.java | 2 +-
.../commands/cluster/init/ItClusterInitTest.java | 2 +-
.../internal/rest/ItGeneratedRestClientTest.java | 32 +-
.../recovery/reset/ResetPartitionsCallInput.java | 4 -
.../restart/RestartPartitionsCallInput.java | 4 -
.../recovery/{ => states}/PartitionStatesCall.java | 2 +-
.../{ => states}/PartitionStatesCallInput.java | 6 +-
.../ignite/internal/cli/commands/Options.java | 13 +-
.../commands/cluster/init/ClusterInitOptions.java | 30 +-
.../partitions/reset/ResetPartitionsCommand.java | 7 +-
.../partitions/reset/ResetPartitionsMixin.java | 10 -
.../reset/ResetPartitionsReplCommand.java | 7 +-
.../restart/RestartPartitionsCommand.java | 7 +-
.../partitions/restart/RestartPartitionsMixin.java | 10 -
.../restart/RestartPartitionsReplCommand.java | 7 +-
.../partitions/states/PartitionStatesCommand.java | 11 +-
.../partitions/states/PartitionStatesMixin.java | 10 -
.../states/PartitionStatesReplCommand.java | 11 +-
.../commands/treesitter/parser/SqlTokenType.java | 8 +-
.../handler/PicocliExecutionExceptionHandler.java | 3 +-
.../internal/cli/core/flow/builder/Flows.java | 30 +-
.../internal/cli/commands/CliCommandTestBase.java | 13 +
.../internal/cli/commands/ProfileMixinTest.java | 61 ++
.../internal/cli/commands/ProfileOptionTest.java | 97 +++
.../cli/commands/cluster/ClusterInitReplTest.java} | 21 +-
.../cli/commands/cluster/ClusterInitTest.java | 102 +++-
.../internal/cli/commands/flow/FlowTest.java | 53 ++
.../cluster-configuration-with-default.conf | 4 +
.../client/proto/ClientBinaryTupleUtils.java | 8 +-
.../internal/client/proto/ClientMessagePacker.java | 15 +-
.../client/proto/ClientMessageUnpacker.java | 13 +-
.../ignite/internal/client/proto/ClientOp.java | 6 +-
.../internal/client/proto/ErrorExtensions.java | 2 +
.../client/proto/StreamerReceiverSerializer.java | 30 +-
.../jdbc/proto/JdbcQueryCursorHandler.java | 10 -
.../internal/jdbc/proto/JdbcStatementType.java | 2 +-
.../jdbc/proto/event/JdbcBatchExecuteRequest.java | 25 +-
.../proto/event/JdbcBatchPreparedStmntRequest.java | 28 +-
.../internal/jdbc/proto/event/JdbcColumnMeta.java | 235 +++----
.../jdbc/proto/event/JdbcQueryExecuteRequest.java | 31 +-
.../jdbc/proto/event/JdbcQuerySingleResult.java | 46 +-
.../proto/ClientMessagePackerUnpackerTest.java | 8 +-
.../handler/ClientInboundMessageHandler.java | 35 +-
.../ignite/client/handler/JdbcHandlerBase.java | 50 +-
.../client/handler/JdbcQueryCursorHandlerImpl.java | 65 --
.../client/handler/JdbcQueryEventHandlerImpl.java | 43 +-
.../ClientComputeExecuteColocatedRequest.java | 8 +-
.../ClientComputeExecuteMapReduceRequest.java | 11 +-
.../compute/ClientComputeExecuteRequest.java | 21 +-
.../compute/ClientComputeGetStateRequest.java | 13 +
.../jdbc/ClientJdbcQueryMetadataRequest.java | 49 --
.../handler/requests/jdbc/JdbcMetadataCatalog.java | 2 +-
.../requests/sql/ClientSqlExecuteBatchRequest.java | 52 +-
...ClientStreamerWithReceiverBatchSendRequest.java | 37 +-
.../table/ClientTupleContainsAllKeysRequest.java | 61 ++
.../handler/JdbcQueryEventHandlerImplTest.java | 14 +-
.../apache/ignite/client/ClientOperationType.java | 9 +-
.../org/apache/ignite/client/IgniteClient.java | 4 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../apache/ignite/internal/client/ClientUtils.java | 76 +--
.../ignite/internal/client/TcpClientChannel.java | 35 +-
.../ignite/internal/client/TcpIgniteClient.java | 2 +-
.../internal/client/compute/ClientCompute.java | 130 ++--
.../client/compute/ClientJobExecution.java | 47 +-
.../client/compute/ClientTaskExecution.java | 11 +-
.../ignite/internal/client/sql/ClientSql.java | 50 +-
.../internal/client/table/AbstractClientView.java | 2 +-
.../internal/client/table/ClientDataStreamer.java | 13 +-
.../client/table/ClientKeyValueBinaryView.java | 37 +-
.../internal/client/table/ClientKeyValueView.java | 37 +-
.../client/table/ClientPartitionManager.java | 6 -
.../client/table/ClientRecordBinaryView.java | 37 +-
.../internal/client/table/ClientRecordView.java | 37 +-
.../ignite/internal/client/table/ClientTables.java | 2 +-
.../internal/client/tx/ClientTransaction.java | 2 +-
.../internal/client/tx/ClientTransactions.java | 2 +-
.../apache/ignite/client/ClientApiArchTest.java | 5 +-
.../apache/ignite/client/ClientComputeTest.java | 71 ++-
.../client/ClientKeyValueBinaryViewTest.java | 28 +
.../ignite/client/ClientKeyValueViewTest.java | 29 +
.../ignite/client/ClientPutGetBenchmark.java | 1 -
.../apache/ignite/client/ClientRecordViewTest.java | 41 ++
.../org/apache/ignite/client/ClientTableTest.java | 53 ++
.../apache/ignite/client/ConfigurationTest.java | 3 +-
.../org/apache/ignite/client/DataStreamerTest.java | 83 ++-
.../client/ObservableTimestampPropagationTest.java | 2 +-
.../ignite/client/PartitionAwarenessTest.java | 30 +-
.../apache/ignite/client/RequestBalancingTest.java | 2 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../apache/ignite/client/ServerMetricsTest.java | 8 +-
.../apache/ignite/client/fakes/FakeCompute.java | 59 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 7 -
.../ignite/client/fakes/FakeInternalTable.java | 3 +-
.../ignite/internal/client/ClientUtilsTest.java | 3 +-
.../cluster/management/ItClusterManagerTest.java | 32 +
.../management/raft/ItCmgRaftServiceTest.java | 15 +-
.../management/topology/ItLogicalTopologyTest.java | 7 +-
.../management/ClusterManagementGroupManager.java | 105 +++-
...anager.java => ClusterStateStorageManager.java} | 4 +-
.../management/raft/CmgRaftGroupListener.java | 51 +-
.../cluster/management/raft/ValidationManager.java | 37 +-
.../cluster/management/raft/ValidationResult.java | 6 +-
.../AbstractClusterStateStorageManagerTest.java | 6 +-
.../management/raft/CmgRaftGroupListenerTest.java | 11 +-
.../RocksDbClusterStateStorageManagerTest.java | 2 +-
.../raft/TestClusterStateStorageManagerTest.java | 2 +-
.../internal/cluster/management/MockNode.java | 2 +-
.../ignite/internal/deployment/DeployFiles.java | 2 +-
.../deployment/ItDeploymentUnitFailoverTest.java | 2 +-
.../internal/deployment/ItDeploymentUnitTest.java | 2 +-
.../apache/ignite/internal/deployment/Unit.java | 2 +-
.../internal/deployunit/DefaultNodeCallback.java | 4 +-
.../deployunit/DeployMessagingService.java | 2 +-
.../internal/deployunit/DeploymentManagerImpl.java | 2 +-
.../deployunit/DeploymentUnitAccessor.java | 2 +-
.../deployunit/DeploymentUnitAccessorImpl.java | 2 +-
.../deployunit/DeploymentUnitAcquiredWaiter.java | 2 +-
.../deployunit/DisposableDeploymentUnit.java | 2 +-
.../internal/deployunit/DownloadTracker.java | 2 +-
.../internal/deployunit/FileDeployerService.java | 2 +-
.../internal/deployunit/IgniteDeployment.java | 2 +-
.../ignite/internal/deployunit/UnitStatus.java | 2 +-
.../ignite/internal/deployunit/UnitStatuses.java | 2 +-
.../internal/deployunit/UnitVersionStatus.java | 2 +-
.../exception/DeploymentUnitNotFoundException.java | 2 +-
.../DeploymentUnitUnavailableException.java | 2 +-
.../metastore/ClusterEventCallbackImpl.java | 2 +-
.../metastore/DeploymentUnitFailover.java | 2 +-
.../deployunit/metastore/DeploymentUnitStore.java | 2 +-
.../metastore/DeploymentUnitStoreImpl.java | 2 +-
.../deployunit/metastore/NodeEventCallback.java | 2 +-
.../metastore/status/ClusterStatusKey.java | 2 +-
.../deployunit/metastore/status/NodeStatusKey.java | 2 +-
.../metastore/status/SerializeUtils.java | 4 +-
.../metastore/status/UnitClusterStatus.java | 2 +-
.../metastore/status/UnitNodeStatus.java | 2 +-
.../ignite/deployment/FileDeployerServiceTest.java | 2 +-
.../deployment/UnitStatusesSerializerTest.java | 2 +-
.../metastore/DeploymentUnitStoreImplTest.java | 4 +-
.../deployunit/DeploymentManagerImplTest.java | 2 +-
.../deployunit/DeploymentUnitAccessorImplTest.java | 2 +-
.../DeploymentUnitAcquiredWaiterTest.java | 2 +-
.../deployunit/metastore/status/UnitKeyTest.java | 2 +-
.../ignite/internal/compute/ItComputeBaseTest.java | 107 +++-
.../internal/compute/ItComputeErrorsBaseTest.java | 12 +-
.../internal/compute/ItComputeTestEmbedded.java | 47 +-
.../internal/compute/ItComputeTestStandalone.java | 12 +-
.../internal/compute/ItExecutionsCleanerTest.java | 5 +-
.../compute/ItFailoverCandidateNotFoundTest.java | 2 +-
.../ignite/internal/compute/ItMapReduceTest.java | 77 +--
.../internal/compute/ItWorkerShutdownTest.java | 7 +-
.../threading/ItComputeApiThreadingTest.java | 30 +-
.../internal/compute/utils/InteractiveJobs.java | 30 +-
.../internal/compute/utils/InteractiveTasks.java | 31 +-
.../apache/ignite/internal/compute/ConcatJob.java | 7 +-
.../apache/ignite/internal/compute/FailingJob.java | 4 +-
.../ignite/internal/compute/GetNodeNameJob.java | 4 +-
.../apache/ignite/internal/compute/MapReduce.java | 16 +-
.../internal/compute/NonEmptyConstructorJob.java | 4 +-
.../org/apache/ignite/internal/compute/Pojo.java} | 48 +-
.../{NonEmptyConstructorJob.java => PojoJob.java} | 26 +-
.../apache/ignite/internal/compute/SleepJob.java | 6 +-
.../internal/compute/AntiHijackIgniteCompute.java | 18 +-
.../internal/compute/AntiHijackJobExecution.java | 2 +-
.../ignite/internal/compute/ComputeComponent.java | 45 +-
.../internal/compute/ComputeComponentImpl.java | 45 +-
.../internal/compute/ComputeJobFailover.java | 25 +-
.../ignite/internal/compute/ComputeUtils.java | 28 +-
.../ignite/internal/compute/IgniteComputeImpl.java | 59 +-
.../internal/compute/IgniteComputeInternal.java | 10 +-
.../apache/ignite/internal/compute/JobStarter.java | 4 +-
.../internal/compute/RemoteExecutionContext.java | 28 +-
.../internal/compute/TaskExecutionWrapper.java | 25 +-
...ecution.java => TaskToJobExecutionWrapper.java} | 44 +-
.../internal/compute/executor/ComputeExecutor.java | 12 +-
.../compute/executor/ComputeExecutorImpl.java | 34 +-
.../internal/compute/loader/JobContextManager.java | 4 +-
.../compute/message/DeploymentUnitMsg.java | 2 +-
.../internal/compute/message/ExecuteRequest.java | 3 +-
.../compute/messaging/ComputeMessaging.java | 14 +-
.../compute/task/AntiHijackTaskExecution.java | 33 +-
.../compute/task/DelegatingTaskExecution.java | 9 +-
.../ignite/internal/compute/task/JobSubmitter.java | 4 +-
.../compute/task/TaskExecutionInternal.java | 74 +--
.../compute/ClassLoaderExceptionsMapperTest.java | 2 +-
.../internal/compute/ComputeComponentImplTest.java | 74 ++-
.../internal/compute/IgniteComputeImplTest.java | 28 +-
.../compute/executor/ComputeExecutorTest.java | 37 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 14 +-
.../compute/loader/JobContextManagerTest.java | 6 +-
.../compute/util/DummyIgniteDeployment.java | 2 +-
.../apache/ignite/internal/compute/UnitJob.java | 4 +-
.../apache/ignite/internal/compute/UnitJob.java | 4 +-
modules/core/build.gradle | 5 -
.../ignite/internal/compute/JobStateImpl.java | 2 +-
.../internal/compute/JobTaskStatusMapper.java | 84 +++
.../{JobStateImpl.java => TaskStateImpl.java} | 42 +-
.../apache/ignite/internal/sql/StatementImpl.java | 6 -
.../org/apache/ignite/internal/util/ByteUtils.java | 42 ++
.../apache/ignite/internal/util/Cancellable.java | 4 +-
.../org/apache/ignite/internal/util/ViewUtils.java | 115 ++++
.../apache/ignite/internal/util/ByteUtilsTest.java | 30 +
.../testframework/matchers/TaskStateMatcher.java | 133 ++++
...niteDistributionZoneManagerNodeRestartTest.java | 9 +-
.../distributionzones/DistributionZoneManager.java | 18 +-
.../rebalance/DistributionZoneRebalanceEngine.java | 70 ++-
.../DistributionZoneRebalanceEngineV2.java | 253 ++++++++
.../RebalanceRaftGroupEventsListener.java | 18 +-
.../distributionzones/rebalance/RebalanceUtil.java | 78 +--
...a => ZoneRebalanceRaftGroupEventsListener.java} | 340 ++++++-----
.../{RebalanceUtil.java => ZoneRebalanceUtil.java} | 407 +++++-------
.../DistributionZoneCausalityDataNodesTest.java | 3 +-
.../DistributionZoneRebalanceEngineTest.java | 22 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 15 +-
modules/failure-handler/build.gradle | 1 +
.../failure/handlers/FailureHandlerTest.java | 22 +-
.../ignite/internal/failure/FailureProcessor.java | 34 +-
.../ignite/internal/failure/NodeStopper.java} | 11 +-
.../failure/handlers/AbstractFailureHandler.java | 8 +-
.../internal/failure/handlers/FailureHandler.java | 10 +-
.../failure/handlers/NoOpFailureHandler.java | 4 +-
.../failure/handlers/StopNodeFailureHandler.java | 19 +-
.../handlers/StopNodeOrHaltFailureHandler.java | 26 +-
.../internal/failure/FailureProcessorTest.java | 42 +-
.../internal/failure/NoOpFailureProcessor.java | 11 +-
.../ignite/internal/index/ItBuildIndexTest.java | 10 +-
...IndexNodeFinishedRwTransactionsCheckerTest.java | 15 +-
.../index/IndexAvailabilityController.java | 2 +
.../internal/index/IndexBuildController.java | 5 +
.../ignite/internal/index/IndexBuildTask.java | 8 +-
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 42 +-
.../apache/ignite/jdbc/AbstractJdbcSelfTest.java | 20 +-
.../ignite/jdbc/ItJdbcAuthenticationTest.java | 7 +-
.../apache/ignite/jdbc/ItJdbcBatchSelfTest.java | 103 ++++
.../ignite/jdbc/ItJdbcComplexQuerySelfTest.java | 4 +-
.../ignite/jdbc/ItJdbcMultiStatementSelfTest.java | 49 ++
.../ignite/jdbc/ItJdbcStatementSelfTest.java | 67 ++
.../jdbc/JdbcClientQueryCursorHandler.java | 14 -
.../ignite/internal/jdbc/JdbcDatabaseMetadata.java | 503 +++++++--------
.../internal/jdbc/JdbcPreparedStatement.java | 2 +-
.../apache/ignite/internal/jdbc/JdbcResultSet.java | 77 +--
.../apache/ignite/internal/jdbc/JdbcStatement.java | 47 +-
.../ignite/internal/jdbc/JdbcResultSetTest.java | 2 +-
.../internal/metastorage/dsl/Conditions.java | 45 +-
.../ignite/internal/metastorage/dsl/Operation.java | 5 +-
.../internal/metastorage/dsl/Operations.java | 36 +-
.../internal/metastorage/dsl/SimpleCondition.java | 5 +-
.../internal/metastorage/dsl/StatementResult.java | 10 +-
.../metastorage/server/time/ClusterTime.java | 5 +
.../impl/ItIdempotentCommandCacheTest.java | 2 +-
.../impl/ItMetaStorageManagerImplTest.java | 2 +-
.../ItMetaStorageMultipleNodesAbstractTest.java | 2 +-
.../ItMetaStorageMultipleNodesRocksDbTest.java | 2 +-
...tMetaStorageSafeTimePropagationRocksDbTest.java | 2 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 2 +-
.../metastorage/impl/ItMetaStorageServiceTest.java | 5 +-
.../metastorage/impl/ItMetaStorageWatchTest.java | 4 +-
.../metastorage/command/GetAllCommand.java | 7 +-
.../internal/metastorage/command/GetCommand.java | 3 +-
.../metastorage/command/GetPrefixCommand.java | 3 +-
.../metastorage/command/GetRangeCommand.java | 5 +-
.../metastorage/command/PutAllCommand.java | 5 +-
.../internal/metastorage/command/PutCommand.java | 5 +-
.../metastorage/command/RemoveAllCommand.java | 3 +-
.../metastorage/command/RemoveCommand.java | 3 +-
.../metastorage/impl/ElectionListener.java} | 21 +-
.../impl/MetaStorageLeaderElectionListener.java | 8 +-
.../metastorage/impl/MetaStorageManagerImpl.java | 11 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 30 +-
.../server/persistence/RocksDbKeyValueStorage.java | 5 +-
.../server/raft/MetaStorageListener.java | 24 +-
.../server/raft/MetaStorageWriteHandler.java | 27 +-
.../metastorage/server/time/ClusterTimeImpl.java | 10 +-
.../impl/IdempotentCommandCacheTest.java | 9 +-
.../impl/MetaStorageRocksDbRangeTest.java | 2 +-
.../RocksDbCompactionKeyValueStorageTest.java | 2 +-
.../server/RocksDbKeyValueStorageTest.java | 2 +-
.../server/SimpleInMemoryKeyValueStorage.java | 11 +-
.../server/TestRocksDbKeyValueStorage.java | 2 +-
.../network/processor/MessageGeneratorUtils.java | 75 +++
.../messages/MessageBuilderGenerator.java | 67 +-
.../processor/messages/MessageImplGenerator.java | 45 +-
.../MessageDeserializerGenerator.java | 4 +-
.../serialization/MessageReaderMethodResolver.java | 4 +-
.../serialization/MessageWriterMethodResolver.java | 4 +-
.../internal/network/DefaultMessagingService.java | 39 +-
.../network/utils/ClusterServiceTestUtils.java | 2 +-
modules/partition-replicator/build.gradle | 1 +
.../replicator/ItReplicaLifecycleTest.java | 406 ++++++++++--
.../PartitionReplicaLifecycleManager.java | 680 ++++++++++++++++++++-
.../network/PartitionReplicationMessageGroup.java | 4 -
.../network/command/FinishTxCommand.java | 6 +-
.../network/command/UpdateAllCommand.java | 1 +
.../replicator/network/command/UpdateCommand.java | 1 +
.../network/disaster/LocalPartitionStateEnum.java | 9 +
.../disaster/LocalPartitionStateMessage.java | 17 +-
.../network/raft/SnapshotTxDataResponse.java | 6 +-
.../replication/MultipleRowPkReplicaRequest.java | 14 +-
.../replication/MultipleRowReplicaRequest.java | 14 +-
.../replication/ReadWriteReplicaRequest.java | 8 +-
.../network/replication/RequestType.java | 10 +
.../replication/SingleRowPkReplicaRequest.java | 14 +-
.../replication/SingleRowReplicaRequest.java | 14 +-
.../network/replication/SwapRowReplicaRequest.java | 14 +-
.../disaster/LocalPartitionStateEnumTest.java} | 22 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 3 +-
modules/platforms/build.gradle | 30 +-
modules/platforms/cpp/Doxyfile | 2 +-
modules/platforms/cpp/cmake/dependencies.cmake | 57 +-
modules/platforms/cpp/cmake/ignite_test.cmake | 4 +
modules/platforms/cpp/ignite/client/CMakeLists.txt | 10 +-
.../cpp/ignite/client/compute/compute.cpp | 24 +-
.../platforms/cpp/ignite/client/compute/compute.h | 67 +-
.../cpp/ignite/client/compute/job_descriptor.h | 126 ++++
.../cpp/ignite/client/compute/job_execution.cpp | 6 +-
.../cpp/ignite/client/compute/job_execution.h | 29 +-
.../ignite/client/compute/job_execution_options.h | 4 +-
.../cpp/ignite/client/compute/job_state.h | 31 +-
.../cpp/ignite/client/compute/job_status.h | 33 +-
.../ignite/client/detail/compute/compute_impl.cpp | 88 ++-
.../ignite/client/detail/compute/compute_impl.h | 30 +-
.../client/detail/compute/job_execution_impl.cpp | 29 +-
.../client/detail/compute/job_execution_impl.h | 26 +-
.../cpp/ignite/client/detail/table/table_impl.h | 13 +-
.../compute/job_state.h => common/binary_object.h} | 46 +-
modules/platforms/cpp/ignite/common/error_codes.h | 35 +-
modules/platforms/cpp/ignite/common/ignite_error.h | 44 +-
.../platforms/cpp/ignite/network/CMakeLists.txt | 9 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 14 +-
modules/platforms/cpp/ignite/odbc/odbc_error.h | 21 +
.../ignite/odbc/query/column_metadata_query.cpp | 32 +-
.../cpp/ignite/odbc/query/column_metadata_query.h | 3 -
.../platforms/cpp/ignite/odbc/query/data_query.cpp | 69 ++-
.../platforms/cpp/ignite/odbc/query/data_query.h | 7 +
.../platforms/cpp/ignite/odbc/sql_connection.cpp | 15 +-
modules/platforms/cpp/ignite/odbc/sql_connection.h | 36 ++
modules/platforms/cpp/ignite/protocol/utils.cpp | 18 +-
modules/platforms/cpp/ignite/protocol/utils.h | 9 +
modules/platforms/cpp/ignite/tuple/tuple_test.cpp | 7 +-
.../platforms/cpp/tests/client-test/CMakeLists.txt | 2 +-
.../cpp/tests/client-test/compute_test.cpp | 174 ++++--
.../cpp/tests/client-test/ignite_runner_suite.h | 1 +
.../client-test/schema_synchronization_test.cpp | 3 +-
.../platforms/cpp/tests/odbc-test/CMakeLists.txt | 2 +-
.../cpp/tests/odbc-test/odbc_connection.h | 6 +-
.../cpp/tests/test-common/basic_auth_test_suite.h | 4 +-
.../Apache.Ignite.Tests/BasicAuthenticatorTests.cs | 5 +-
.../Compute/ComputeClusterAwarenessTests.cs | 19 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 265 ++++----
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 27 +-
.../dotnet/Apache.Ignite.Tests/IgniteTestsBase.cs | 1 +
.../PartitionAwarenessRealClusterTests.cs | 9 +-
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 24 +-
.../Proto/ColocationHashTests.cs | 42 +-
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 170 +++---
.../Table/PartitionManagerTests.cs | 180 ++++++
.../Table/SchemaSynchronizationTest.cs | 19 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 3 +
.../dotnet/Apache.Ignite.Tests/ToStringTests.cs | 5 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 7 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 61 +-
.../dotnet/Apache.Ignite/Compute/IJobExecution.cs | 2 +-
.../dotnet/Apache.Ignite/Compute/IJobTarget.cs} | 21 +-
.../dotnet/Apache.Ignite/Compute/JobDescriptor.cs | 4 +-
.../dotnet/Apache.Ignite/Compute/JobState.cs | 46 +-
.../dotnet/Apache.Ignite/Compute/JobStatus.cs | 48 +-
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 87 +++
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 61 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 171 +++---
.../Apache.Ignite/Internal/Compute/JobExecution.cs | 10 +-
.../Apache.Ignite/Internal/IgniteClientInternal.cs | 8 +-
.../Apache.Ignite/Internal/Network/ClusterNode.cs | 28 +
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 3 +
.../Internal/Proto/ClientOpExtensions.cs | 1 +
.../Internal/Proto/MsgPack/MsgPackWriter.cs | 18 +
.../Internal/Table/DataStreamerWithReceiver.cs | 22 +-
.../Apache.Ignite/Internal/Table/HashPartition.cs} | 24 +-
.../Apache.Ignite/Internal/Table/KeyValueView.cs | 27 +-
.../Internal/Table/PartitionManager.cs | 224 +++++++
.../Apache.Ignite/Internal/Table/RecordView.cs | 28 +-
.../Serialization/IRecordSerializerHandler.cs | 24 +
.../dotnet/Apache.Ignite/Internal/Table/Table.cs | 5 +
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 1 +
.../Apache.Ignite/Table/IDataStreamerTarget.cs | 27 +-
.../dotnet/Apache.Ignite/Table/IPartition.cs} | 19 +-
.../Apache.Ignite/Table/IPartitionManager.cs | 61 ++
.../platforms/dotnet/Apache.Ignite/Table/ITable.cs | 5 +
.../Apache.Ignite/Table/ReceiverDescriptor.cs | 42 ++
.../apache/ignite/internal/raft/ItLozaTest.java | 237 +++++--
.../storage/impl/DefaultLogStorageFactory.java | 25 +-
.../raft/storage/impl/RocksDbSharedLogStorage.java | 12 +-
.../raft/storage/impl/StripeAwareLogManager.java | 29 +-
.../jraft/rpc/impl/ActionRequestProcessor.java | 8 +-
.../raft/jraft/rpc/impl/SMCompactedThrowable.java | 3 +
.../ItPlacementDriverReplicaSideTest.java | 7 +-
.../ignite/internal/replicator/ReplicaImpl.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 150 +++--
.../ignite/internal/replicator/ReplicaService.java | 4 +-
.../replicator/ZonePartitionReplicaImpl.java | 15 +-
.../replicator/message/ReplicaMessageGroup.java | 6 +
.../replicator/message/ReplicaMessageUtils.java | 59 ++
.../replicator/message/ReplicaRequest.java | 11 +-
...Request.java => ReplicationGroupIdMessage.java} | 18 +-
.../message}/TablePartitionIdMessage.java | 21 +-
...icaRequest.java => ZonePartitionIdMessage.java} | 36 +-
.../rest/exception/handler/ErrorHandlingTest.java | 1 +
.../ignite/internal/rest/AbstractRestTestBase.java | 31 +-
...terStateHttpServerFilterNotInitializedTest.java | 2 +-
.../rest/ItNotInitializedClusterRestTest.java | 4 +-
.../internal/rest/ItRestAddressReportTest.java | 102 ----
.../ignite/internal/rest/ItRestPortsTest.java | 7 +-
.../org/apache/ignite/internal/rest/RestNode.java | 26 +-
.../cluster/ItClusterManagementControllerTest.java | 2 +-
.../rest/compute/ItComputeControllerTest.java | 6 +-
.../ignite/internal/rest/ssl/ItRestSslTest.java | 13 +-
.../rest/authentication/IgniteSecurityFilter.java | 2 +
.../deployment/DeploymentManagementController.java | 2 +-
.../handler/VersionParseExceptionHandler.java | 2 +-
modules/runner/build.gradle | 3 +-
.../benchmark/AbstractMultiNodeBenchmark.java | 32 +-
.../ignite/internal/benchmark/SelectBenchmark.java | 6 +-
.../cluster/management/ItClusterInitTest.java | 33 +-
.../ItDistributedConfigurationPropertiesTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 2 +-
.../inmemory/ItRaftStorageVolatilityTest.java | 4 +-
.../runner/app/AbstractSchemaChangeTest.java | 43 +-
.../internal/runner/app/IgniteRunnerTest.java | 25 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 59 +-
.../app/ItIgniteInMemoryNodeRestartTest.java | 33 +-
.../runner/app/ItIgniteNodeRestartTest.java | 18 +-
...ItIgnitionTest.java => ItIgniteServerTest.java} | 119 ++--
.../internal/runner/app/ItNoThreadsLeftTest.java | 29 +-
.../runner/app/ItReplicaStateManagerTest.java | 67 +-
.../internal/runner/app/ItSingleNodeTest.java | 46 +-
.../internal/runner/app/ItTablesApiTest.java | 30 +-
.../runner/app/PlatformBenchmarkNodeRunner.java | 6 +-
.../runner/app/PlatformTestNodeRunner.java | 128 ++--
.../app/client/ItAbstractThinClientTest.java | 23 +-
.../client/ItThinClientComputeMarshallingTest.java | 140 +++++
.../runner/app/client/ItThinClientComputeTest.java | 234 ++++---
.../client/ItThinClientPartitionAwarenessTest.java | 9 +-
.../schemasync/ItSchemaSyncMultiNodeTest.java | 3 -
.../apache/ignite/internal/start/ItStartTest.java | 26 +-
.../streamer/ItAbstractDataStreamerTest.java | 28 +-
.../ignite/internal/table/ItDurableFinishTest.java | 4 +-
.../ignite/internal/table/ItInternalTableTest.java | 22 +-
.../main/java/org/apache/ignite/IgniteServer.java | 194 ++++++
.../java/org/apache/ignite/InitParameters.java | 13 -
.../org/apache/ignite/InitParametersBuilder.java | 210 +++++++
.../org/apache/ignite/internal/app/IgniteImpl.java | 329 +++++-----
.../apache/ignite/internal/app/IgniteRunner.java | 14 +-
.../ignite/internal/app/IgniteServerImpl.java | 289 +++++++++
.../apache/ignite/internal/app/IgnitionImpl.java | 256 --------
.../ignite/internal/app/LifecycleManager.java | 19 +-
.../internal/component/RestAddressReporter.java | 83 ---
.../threading/PublicApiThreadingIgniteCatalog.java | 148 +++++
.../ignite/lang/ClusterInitFailureException.java} | 29 +-
.../lang/ClusterNotInitializedException.java} | 25 +-
.../ignite/lang/NodeNotStartedException.java} | 24 +-
.../apache/ignite/lang/NodeStartException.java} | 28 +-
.../component/RestAddressReporterTest.java | 125 ----
.../DistributedConfigurationStorageTest.java | 5 +-
.../ignite/internal/BaseIgniteRestartTest.java | 73 ++-
.../java/org/apache/ignite/internal/Cluster.java | 94 +--
.../internal/ClusterPerClassIntegrationTest.java | 7 +-
.../internal/ClusterPerTestIntegrationTest.java | 6 +-
.../ignite/internal/IgniteIntegrationTest.java | 31 -
.../internal/junit/StopAllIgnitesAfterTests.java | 66 --
.../testframework/TestIgnitionManager.java | 19 +-
.../org/apache/ignite/internal/ssl/ItSslTest.java | 26 +-
.../ignite/internal/sql/api/ItSqlApiBaseTest.java | 99 +++
.../internal/sql/engine/ItDataTypesTest.java | 442 +++++++++-----
.../ignite/internal/sql/engine/ItDmlTest.java | 2 +-
.../sql/engine/ItDynamicParameterTest.java | 38 +-
.../internal/sql/engine/ItFunctionsTest.java | 3 +-
.../sql/engine/ItPkOnlyTableCrossApiTest.java | 2 +-
.../internal/sql/sqllogic/ItSqlLogicTest.java | 41 +-
.../sql/threading/ItSqlApiThreadingTest.java | 1 -
.../sql/aggregate/aggregates/test_avg.test | 7 +-
.../sql/aggregate/aggregates/test_sum.test | 9 +
.../aggregate/group/test_group_by_distinct.test | 10 +-
.../sql/basic_queries/test_simple_table.test | 2 +-
.../integrationTest/sql/cast/test_cast_bigint.test | 6 +-
.../sql/cast/test_cast_decimal.test | 2 -
.../integrationTest/sql/cast/test_cast_float.test | 8 +-
.../integrationTest/sql/cast/test_cast_int.test | 4 +-
.../integrationTest/sql/cast/test_cast_real.test | 8 +-
.../sql/cast/test_cast_smallint.test | 4 +-
.../sql/cast/test_cast_tinyint.test | 4 +-
.../generic/test_in_list_of_single_element.test | 10 +-
.../integrationTest/sql/set/test_intersect.test | 2 +-
.../sql/types/decimal/test_decimal.test | 22 +
.../integrationTest/sql/types/row/test_row.test | 49 ++
.../sql/update/test_big_string_update.test | 47 ++
.../sql/update/test_big_string_update.test_ignore | 96 ---
.../sql/update/test_null_update.test | 40 ++
.../sql/update/test_null_update.test_ignore | 194 ------
.../update/test_repeated_string_update.test_ignore | 62 --
.../sql/update/test_string_update.test_ignore | 66 --
.../test_string_update_many_strings.test_ignore | 128 ----
.../sql/update/test_string_update_null.test_ignore | 40 --
.../update/test_string_update_rollback.test_ignore | 118 ----
.../test_string_update_rollback_null.test_ignore | 89 ---
.../sql/update/test_update.test_ignore | 80 ---
.../test_update_delete_same_tuple.test_ignore | 44 --
.../sql/update/test_update_from.test_ignore | 160 -----
.../update/test_update_many_updaters.test_ignore | 316 ----------
.../test_update_many_updaters_nulls.test_ignore | 119 ----
.../sql/update/test_update_mix.test_ignore | 75 ---
.../sql/update/test_update_same_value.test_ignore | 180 ------
.../ignite/internal/sql/api/IgniteSqlImpl.java | 9 +-
.../ignite/internal/sql/engine/QueryCancel.java | 107 +++-
.../sql/engine/QueryCancelledException.java | 22 +-
.../internal/sql/engine/SqlOperationContext.java | 6 +-
.../internal/sql/engine/SqlQueryProcessor.java | 73 ++-
.../internal/sql/engine/exec/ExecutionContext.java | 11 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 124 +++-
.../sql/engine/exec/UpdatableTableImpl.java | 36 +-
.../sql/engine/exec/exp/ConverterUtils.java | 49 +-
.../sql/engine/exec/exp/ExpressionFactoryImpl.java | 91 ++-
.../sql/engine/exec/exp/IgniteExpressions.java | 51 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 5 +-
.../sql/engine/exec/mapping/ExecutionTarget.java | 17 +-
.../sql/engine/exec/mapping/FragmentMapper.java | 6 +-
.../sql/engine/exec/mapping/MappingContext.java | 7 +-
.../AbstractTarget.java | 151 +++--
.../AllOfTarget.java | 10 +-
.../LargeClusterFactory.java} | 56 +-
.../OneOfTarget.java | 30 +-
.../PartitionedTarget.java | 46 +-
.../SomeOfTarget.java | 25 +-
.../exec/mapping/smallcluster/AbstractTarget.java | 42 +-
.../exec/mapping/smallcluster/AllOfTarget.java | 5 -
.../exec/mapping/smallcluster/OneOfTarget.java | 8 +-
.../mapping/smallcluster/PartitionedTarget.java | 7 +-
.../mapping/smallcluster/SmallClusterFactory.java | 19 +-
.../exec/mapping/smallcluster/SomeOfTarget.java | 5 -
.../sql/engine/prepare/IgniteSqlValidator.java | 215 ++++---
.../sql/engine/prepare/KeyValueGetPlan.java | 11 +
.../sql/engine/prepare/KeyValueModifyPlan.java | 11 +
.../sql/engine/prepare/PlanningContext.java | 2 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 70 ++-
.../internal/sql/engine/rex/IgniteRexBuilder.java | 13 +
.../sql/engine/sql/fun/IgniteSqlOperatorTable.java | 16 +
.../ignite/internal/sql/engine/util/Commons.java | 22 -
.../internal/sql/engine/util/IgniteMath.java | 204 ++++++-
.../internal/sql/engine/util/IgniteResource.java | 7 +
.../internal/sql/engine/util/Primitives.java | 27 +
.../ignite/internal/sql/engine/util/RexUtils.java | 6 +-
.../internal/sql/engine/util/cache/Cache.java | 14 +
.../engine/util/cache/CaffeineCacheFactory.java | 10 +
.../internal/sql/api/StatementBuilderImplTest.java | 16 +-
.../sql/engine/benchmarks/MappingBenchmark.java | 180 ++++++
.../sql/engine/exec/ExecutionServiceImplTest.java | 298 ++++++++-
.../engine/exec/NoOpExecutableTableRegistry.java | 27 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 111 +++-
.../mapping/ExecutionTargetFactorySelfTest.java | 284 +++++++++
.../sql/engine/exec/rel/AbstractExecutionTest.java | 7 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 4 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 2 +-
.../sql/engine/framework/TestBuilders.java | 31 +-
.../internal/sql/engine/framework/TestIndex.java | 15 +-
.../internal/sql/engine/framework/TestNode.java | 3 +-
.../sql/engine/planner/AbstractPlannerTest.java | 2 +
.../sql/engine/planner/DynamicParametersTest.java | 18 +-
.../sql/engine/planner/PlannerTimeoutTest.java | 4 +-
.../sql/engine/prepare/PrepareServiceImplTest.java | 101 ++-
.../sql/engine/util/EmptyCacheFactory.java | 10 +
.../internal/sql/engine/util/QueryCheckerImpl.java | 4 +-
.../internal/storage/MvPartitionStorage.java | 29 +-
.../storage/ThreadAssertingMvPartitionStorage.java | 12 +-
.../AbstractMvPartitionStorageConcurrencyTest.java | 39 ++
.../storage/AbstractMvPartitionStorageTest.java | 113 +++-
.../storage/AbstractMvTableStorageTest.java | 69 ++-
.../storage/impl/TestMvPartitionStorage.java | 45 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 25 +-
.../PersistentPageMemoryMvTableStorageTest.java | 13 +
.../VolatilePageMemoryMvTableStorageTest.java | 13 +
.../AbstractPageMemoryMvPartitionStorageTest.java | 37 ++
...ageMemoryMvPartitionStorageConcurrencyTest.java | 7 +
...ageMemoryMvPartitionStorageConcurrencyTest.java | 7 +
.../internal/storage/rocksdb/GarbageCollector.java | 2 +-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 26 +-
.../RocksDbMvPartitionStorageConcurrencyTest.java | 7 +
.../rocksdb/RocksDbMvPartitionStorageTest.java | 37 ++
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 13 +
.../ignite/distributed/ReplicaUnavailableTest.java | 11 +-
.../ItDisasterRecoveryReconfigurationTest.java | 11 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 7 +-
.../rebalance/ItRebalanceDistributedTest.java | 118 +++-
.../rebalance/ItRebalanceRecoveryTest.java | 7 +-
.../ignite/internal/rebalance/ItRebalanceTest.java | 65 +-
.../rebalance/ItRebalanceTriggersRecoveryTest.java | 19 +-
.../ignite/internal/table/ItColocationTest.java | 41 +-
.../threading/ItKvRecordApiThreadingTest.java | 1 -
.../ItPartitionManagerApiThreadingTest.java | 120 ++++
.../threading/ItTablesApiThreadingTest.java | 1 -
.../ignite/internal/table/AbstractTableView.java | 24 +-
.../ignite/internal/table/InternalTable.java | 5 +-
.../internal/table/KeyValueBinaryViewImpl.java | 45 +-
.../ignite/internal/table/KeyValueViewImpl.java | 47 +-
.../table/PublicApiThreadingKeyValueView.java | 10 +
.../table/PublicApiThreadingRecordView.java | 10 +
.../internal/table/PublicApiThreadingViewBase.java | 8 +-
.../internal/table/RecordBinaryViewImpl.java | 39 +-
.../ignite/internal/table/RecordViewImpl.java | 39 +-
.../table/distributed/PublicApiThreadingTable.java | 7 +-
.../internal/table/distributed/TableManager.java | 401 +++++++-----
.../disaster/DisasterRecoveryManager.java | 24 +-
.../disaster/ManualGroupUpdateRequest.java | 101 ++-
.../table/distributed/index/IndexMetaStorage.java | 8 +-
.../table/distributed/raft/PartitionListener.java | 2 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 2 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 26 +-
.../replicator/PartitionReplicaListener.java | 69 ++-
.../replicator/TransactionStateResolver.java | 23 +-
.../distributed/storage/InternalTableImpl.java | 182 +++---
.../PublicApiThreadingPartitionManager.java | 68 +++
.../UpdateCommandsMarshalingMicroBenchmark.java | 18 +-
.../table/KeyValueBinaryViewOperationsTest.java | 40 ++
.../internal/table/KeyValueViewOperationsTest.java | 34 ++
.../table/RecordBinaryViewOperationsTest.java | 45 ++
.../internal/table/RecordViewOperationsTest.java | 37 ++
.../table/distributed/IndexCleanupTest.java | 17 +-
.../table/distributed/StorageCleanupTest.java | 76 +--
.../distributed/StorageUpdateHandlerTest.java | 26 +-
.../distributed/TableManagerRecoveryTest.java | 3 -
.../table/distributed/TableManagerTest.java | 3 -
.../PartitionRaftCommandsSerializationTest.java | 47 +-
.../index/BaseIndexMetaStorageTest.java | 2 +-
.../raft/PartitionCommandListenerTest.java | 82 ++-
.../incoming/IncomingSnapshotCopierTest.java | 12 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 18 +-
.../PartitionReplicaListenerIndexLockingTest.java | 58 +-
.../replication/PartitionReplicaListenerTest.java | 235 ++++---
.../replicator/action/RequestTypeTest.java | 8 +
.../CheckCatalogVersionOnActionRequestTest.java | 2 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 5 -
.../apache/ignite/internal/tx/TransactionMeta.java | 6 +
.../java/org/apache/ignite/internal/tx/TxMeta.java | 25 +-
.../org/apache/ignite/internal/tx/TxState.java | 8 +
.../org/apache/ignite/internal/tx/TxStateMeta.java | 33 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 27 +-
.../ignite/internal/tx/TxStateMetaFinishing.java | 23 +
.../ignite/internal/tx/impl/OrphanDetector.java | 11 +-
.../tx/impl/PersistentTxStateVacuumizer.java | 6 +-
.../internal/tx/impl/TxCleanupRequestHandler.java | 79 ++-
.../internal/tx/impl/TxCleanupRequestSender.java | 10 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 7 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 70 ++-
.../tx/message/CleanupReplicatedInfoMessage.java} | 34 +-
.../tx/message/TransactionMetaMessage.java} | 49 +-
.../internal/tx/message/TxCleanupMessage.java | 9 +-
.../tx/message/TxCleanupMessageResponse.java | 7 +-
.../tx/message/TxFinishReplicaRequest.java | 12 +-
.../ignite/internal/tx/message/TxMessageGroup.java | 14 +
.../ignite/internal/tx/message/TxMetaMessage.java | 50 ++
...ponse.java => TxStateMetaAbandonedMessage.java} | 33 +-
...ponse.java => TxStateMetaFinishingMessage.java} | 30 +-
.../internal/tx/message/TxStateMetaMessage.java | 59 ++
.../internal/tx/message/TxStateResponse.java | 7 +-
.../org/apache/ignite/internal/tx/TxStateTest.java | 13 +-
packaging/README.md | 6 +-
packaging/db/build.gradle | 46 +-
packaging/db/linux/common.sh | 9 +-
packaging/db/linux/deb/postUninstall.sh | 5 +-
packaging/db/linux/postInstall.sh | 15 +-
packaging/db/linux/rpm/postUninstall.sh | 2 +-
packaging/db/linux/service/ignite3db.service | 2 +-
packaging/db/zip/linux/ignite3db | 61 +-
packaging/odbc/build.gradle | 46 +-
packaging/odbc/template.wxs | 38 ++
733 files changed, 17177 insertions(+), 10173 deletions(-)
delete mode 100644 modules/api/src/main/java/org/apache/ignite/Ignition.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/IgnitionManager.java
delete mode 100644
modules/api/src/main/java/org/apache/ignite/InitParametersBuilder.java
copy modules/api/src/main/java/org/apache/ignite/compute/{ComputeJob.java =>
TaskState.java} (51%)
copy modules/{platforms/cpp/ignite/client/compute/job_state.h =>
api/src/main/java/org/apache/ignite/compute/TaskStatus.java} (62%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/DeploymentUnit.java (96%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/UnitVersion.java (98%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/Version.java (97%)
rename modules/api/src/main/java/org/apache/ignite/{compute =>
deployment}/version/VersionParseException.java (96%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/ByteArrayMarshaler.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/JavaSerializationByteArrayMarshallilng.java
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/Marshaler.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/QueryCancelledException.java
=> api/src/main/java/org/apache/ignite/marshaling/MarshallingException.java}
(51%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
api/src/main/java/org/apache/ignite/marshaling/TupleMarshaller.java} (72%)
create mode 100644
modules/api/src/main/java/org/apache/ignite/marshaling/UnsupportedObjectTypeMarshalingException.java
rename modules/api/src/test/java/org/apache/ignite/{compute =>
deployment}/version/VersionTest.java (98%)
create mode 100644
modules/api/src/test/java/org/apache/ignite/marshaling/ByteArrayMarshalerTest.java
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/ItCatalogApiThreadingTest.java
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/Pojo.java
copy
modules/{cluster-management/src/test/java/org/apache/ignite/internal/cluster/management/raft/RocksDbClusterStateStorageManagerTest.java
=>
catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/PojoKey.java}
(65%)
create mode 100644
modules/catalog-dsl/src/integrationTest/java/org/apache/ignite/internal/catalog/PojoValue.java
create mode 100644
modules/catalog/src/integrationTest/java/org/apache/ignite/internal/catalog/ItCatalogCompactionCoordinatorChoosingTest.java
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/{ =>
states}/PartitionStatesCall.java (98%)
rename
modules/cli/src/main/java/org/apache/ignite/internal/cli/call/recovery/{ =>
states}/PartitionStatesCallInput.java (96%)
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/ProfileOptionTest.java
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/NoOpFailureHandler.java
=>
cli/src/test/java/org/apache/ignite/internal/cli/commands/cluster/ClusterInitReplTest.java}
(63%)
mode change 100755 => 100644
create mode 100644
modules/cli/src/test/resources/cluster-configuration-with-default.conf
delete mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/jdbc/ClientJdbcQueryMetadataRequest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientTupleContainsAllKeysRequest.java
rename
modules/cluster-management/src/main/java/org/apache/ignite/internal/cluster/management/raft/{RaftStorageManager.java
=> ClusterStateStorageManager.java} (97%)
copy
modules/{failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/StopNodeFailureHandler.java
=> compute/src/jobs/java/org/apache/ignite/internal/compute/Pojo.java} (52%)
copy
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/{NonEmptyConstructorJob.java
=> PojoJob.java} (64%)
copy
modules/compute/src/main/java/org/apache/ignite/internal/compute/{AntiHijackJobExecution.java
=> TaskToJobExecutionWrapper.java} (56%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/compute/JobTaskStatusMapper.java
copy
modules/core/src/main/java/org/apache/ignite/internal/compute/{JobStateImpl.java
=> TaskStateImpl.java} (84%)
create mode 100644
modules/core/src/main/java/org/apache/ignite/internal/util/ViewUtils.java
create mode 100644
modules/core/src/testFixtures/java/org/apache/ignite/internal/testframework/matchers/TaskStateMatcher.java
create mode 100644
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/DistributionZoneRebalanceEngineV2.java
copy
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/{RebalanceRaftGroupEventsListener.java
=> ZoneRebalanceRaftGroupEventsListener.java} (70%)
copy
modules/distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/rebalance/{RebalanceUtil.java
=> ZoneRebalanceUtil.java} (64%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
failure-handler/src/main/java/org/apache/ignite/internal/failure/NodeStopper.java}
(75%)
copy
modules/metastorage/src/{test/java/org/apache/ignite/internal/metastorage/impl/MetaStorageRocksDbRangeTest.java
=>
main/java/org/apache/ignite/internal/metastorage/impl/ElectionListener.java}
(58%)
create mode 100644
modules/network-annotation-processor/src/main/java/org/apache/ignite/internal/network/processor/MessageGeneratorUtils.java
copy
modules/partition-replicator/src/{main/java/org/apache/ignite/internal/partition/replicator/network/replication/SingleRowPkReplicaRequest.java
=>
test/java/org/apache/ignite/internal/partition/replicator/network/disaster/LocalPartitionStateEnumTest.java}
(66%)
create mode 100644 modules/platforms/cpp/ignite/client/compute/job_descriptor.h
copy modules/platforms/cpp/ignite/{client/compute/job_state.h =>
common/binary_object.h} (59%)
mode change 100755 => 100644 modules/platforms/cpp/ignite/common/error_codes.h
create mode 100644
modules/platforms/dotnet/Apache.Ignite.Tests/Table/PartitionManagerTests.cs
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
platforms/dotnet/Apache.Ignite/Compute/IJobTarget.cs} (73%)
create mode 100644 modules/platforms/dotnet/Apache.Ignite/Compute/JobTarget.cs
mode change 100755 => 100644
modules/platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> platforms/dotnet/Apache.Ignite/Internal/Table/HashPartition.cs} (66%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Table/PartitionManager.cs
copy
modules/{core/src/main/java/org/apache/ignite/internal/util/Cancellable.java =>
platforms/dotnet/Apache.Ignite/Table/IPartition.cs} (73%)
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/IPartitionManager.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Table/ReceiverDescriptor.cs
create mode 100644
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/ReplicaMessageUtils.java
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ReplicaRequest.java
=> ReplicationGroupIdMessage.java} (76%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/command
=>
replicator/src/main/java/org/apache/ignite/internal/replicator/message}/TablePartitionIdMessage.java
(67%)
copy
modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{ReplicaRequest.java
=> ZonePartitionIdMessage.java} (55%)
delete mode 100644
modules/rest/src/integrationTest/java/org/apache/ignite/internal/rest/ItRestAddressReportTest.java
rename
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/{ItIgnitionTest.java
=> ItIgniteServerTest.java} (57%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientComputeMarshallingTest.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/IgniteServer.java
rename modules/{api =>
runner}/src/main/java/org/apache/ignite/InitParameters.java (86%)
create mode 100644
modules/runner/src/main/java/org/apache/ignite/InitParametersBuilder.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/IgniteServerImpl.java
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/app/IgnitionImpl.java
delete mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/component/RestAddressReporter.java
create mode 100644
modules/runner/src/main/java/org/apache/ignite/internal/threading/PublicApiThreadingIgniteCatalog.java
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/TxCleanupMessageResponse.java
=>
runner/src/main/java/org/apache/ignite/lang/ClusterInitFailureException.java}
(55%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=>
runner/src/main/java/org/apache/ignite/lang/ClusterNotInitializedException.java}
(59%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> runner/src/main/java/org/apache/ignite/lang/NodeNotStartedException.java}
(61%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/TransactionMeta.java
=> runner/src/main/java/org/apache/ignite/lang/NodeStartException.java} (58%)
delete mode 100644
modules/runner/src/test/java/org/apache/ignite/internal/component/RestAddressReporterTest.java
delete mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/IgniteIntegrationTest.java
delete mode 100644
modules/runner/src/testFixtures/java/org/apache/ignite/internal/junit/StopAllIgnitesAfterTests.java
rename modules/{core =>
runner}/src/testFixtures/java/org/apache/ignite/internal/testframework/TestIgnitionManager.java
(93%)
create mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_big_string_update.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_big_string_update.test_ignore
create mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_null_update.test
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_null_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_repeated_string_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_many_strings.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_null.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_rollback.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_string_update_rollback_null.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_delete_same_tuple.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_from.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_many_updaters.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_many_updaters_nulls.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_mix.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/update/test_update_same_value.test_ignore
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/AbstractTarget.java (57%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/AllOfTarget.java (93%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster/SmallClusterFactory.java
=> largecluster/LargeClusterFactory.java} (68%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/OneOfTarget.java (83%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/PartitionedTarget.java (75%)
copy
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/{smallcluster
=> largecluster}/SomeOfTarget.java (84%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/benchmarks/MappingBenchmark.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/mapping/ExecutionTargetFactorySelfTest.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/internal/threading/ItPartitionManagerApiThreadingTest.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/partition/PublicApiThreadingPartitionManager.java
rename
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/command/TablePartitionIdMessage.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/message/CleanupReplicatedInfoMessage.java}
(50%)
copy
modules/{partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/command/FinishTxCommand.java
=>
transactions/src/main/java/org/apache/ignite/internal/tx/message/TransactionMetaMessage.java}
(55%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxMetaMessage.java
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxStateResponse.java
=> TxStateMetaAbandonedMessage.java} (51%)
copy
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/{TxStateResponse.java
=> TxStateMetaFinishingMessage.java} (54%)
create mode 100644
modules/transactions/src/main/java/org/apache/ignite/internal/tx/message/TxStateMetaMessage.java
create mode 100644 packaging/odbc/template.wxs
