This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-20680
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 882cbdad53 Fix catalog compaction tests.
omit 112d37ab82 wip.
omit 067426c061 wip.
omit 62f23f70db Postpone table structures destruction.
add 7a26a6714d IGNITE-21213 Coordination of mechanisms of determination
for primar (#3097)
add 164eb449dc IGNITE-21111 Add mechanism to wait for completion of
in-flight operations of RW transactions started before index appearance (#3160)
add 74d5aee1ff IGNITE-21468 Removed unused TxMeta.enlistedPartitions
(#3162)
add ba014437fd IGNITE-21391 Disable flaky ItNodeTest.testSetPeer2 test
(#3166)
add f3e9af8819 IGNITE-21457 Disable flaky ItNodeTest.testSetPeer2 test
(#3168)
add c0f92249c2 IGNITE-21470 Wait for sender to appear before applying an
ack silencer (#3163)
add 8e79cf047c Enable Dependabot version updates (#3167)
add 65b5e41c16 IGNITE-21322 Add tests for multiline sql execution from
file (#3164)
add 1d1313634c IGNITE-21471 Change approach in sendMessagesTwoChannels in
DefaultMessagingServiceTest (#3165)
add d9675ad06f IGNITE-21310 Sql. Introduce partition provider for further
pruning usage (#3102)
add c97d7c5db3 IGNITE-21247 Log enhancements for LeaseUpdater (#3109)
add f2c02191d0 IGNITE-21289 .NET: Implement job execution interface (#3159)
add 71727ef7be IGNITE-21477 Fix jvmArgs propagation in tests (#3174)
add 8be6c8ebcc IGNITE-21248 Add abandoned locks handling to
HeapUnboundedLockManager (#3161)
add 4550e073d9 IGNITE-21438 Add thread assertions to MV partition and
index storages (#3149)
add 6729811f99 IGNITE-21479 Fix race with setting priority in
PriorityQueueExecutorTest (#3176)
add 53eff5b338 IGNITE-20452 Integrate failure handler processor into
Ignite components (#3090)
add a339584db4 IGNITE-21230 Custom serialization of catalog commands
(#3058)
add 5b360b8198 IGNITE-21473 Adjust Tx tests structure (#3169)
add a46b779688 IGNITE-21488 Disable thread assertions by default (#3182)
add 60ea39dbdd IGNITE-21317 Disable
ItRebalanceDistributedTest#testClientsAreUpdatedAfterPendingRebalanceHandled
(#3183)
add d56c817421 IGNITE-21486 Pass node name to NamedThreadFactory where
possible (#3181)
add bf43c0b8ef IGNITE-21402 DataStreamer data removal: refactor client
streamer to use dedicated internal API (#3184)
add 3e09d9b8c0 IGNITE-20125 Write to writable indices when writing to
partition (#3177)
add 593161d287 IGNITE-16094 Add caching for Tuple marshallers (#3146)
add 214d1debfd IGNITE-21453 Fix force index hint test (#3175)
add 8ad9c384a7 Postpone table structures destruction.
add 017227b448 Trigger catalog truncation on UpdataLog event.
add e0059ec604 Fix catalog compaction tests.
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 (882cbdad53)
\
N -- N -- N refs/heads/ignite-20680 (e0059ec604)
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:
.github/dependabot.yml | 8 +
build.gradle | 50 ++-
.../java/org/apache/ignite/compute/JobState.java | 2 +-
.../java/org/apache/ignite/compute/JobStatus.java | 73 ++++
.../java/org/apache/ignite/lang/ErrorGroups.java | 13 +
.../apache/ignite/table/DataStreamerOptions.java | 1 +
.../org/apache/ignite/table/mapper/Mapper.java | 1 -
.../apache/ignite/table/mapper/MapperBuilder.java | 1 +
modules/catalog/build.gradle | 1 +
.../ignite/internal/catalog/ClockWaiter.java | 4 +-
.../descriptors/CatalogColumnCollation.java | 15 +
.../descriptors/CatalogDataStorageDescriptor.java | 32 +-
.../descriptors/CatalogHashIndexDescriptor.java | 69 +++-
.../descriptors/CatalogIndexColumnDescriptor.java | 25 +-
.../descriptors/CatalogIndexDescriptor.java | 45 ++-
.../catalog/descriptors/CatalogIndexStatus.java | 37 +-
.../descriptors/CatalogObjectDescriptor.java | 5 +-
.../descriptors/CatalogSchemaDescriptor.java | 48 ++-
.../descriptors/CatalogSortedIndexDescriptor.java | 65 ++-
.../descriptors/CatalogSystemViewDescriptor.java | 83 +++-
.../descriptors/CatalogTableColumnDescriptor.java | 66 +++-
.../descriptors/CatalogTableDescriptor.java | 151 ++++++-
.../descriptors/CatalogTableSchemaVersions.java | 58 ++-
.../catalog/descriptors/CatalogZoneDescriptor.java | 88 ++++-
.../internal/catalog/storage/AlterColumnEntry.java | 35 +-
.../internal/catalog/storage/AlterZoneEntry.java | 29 +-
.../internal/catalog/storage/DropColumnsEntry.java | 37 +-
.../internal/catalog/storage/DropIndexEntry.java | 31 +-
.../internal/catalog/storage/DropTableEntry.java | 31 +-
.../internal/catalog/storage/DropZoneEntry.java | 29 +-
.../catalog/storage/MakeIndexAvailableEntry.java | 29 +-
.../internal/catalog/storage/NewColumnsEntry.java | 35 +-
.../internal/catalog/storage/NewIndexEntry.java | 32 +-
.../catalog/storage/NewSystemViewEntry.java | 32 +-
.../internal/catalog/storage/NewTableEntry.java | 31 +-
.../internal/catalog/storage/NewZoneEntry.java | 29 +-
.../catalog/storage/ObjectIdGenUpdateEntry.java | 29 +-
.../internal/catalog/storage/RemoveIndexEntry.java | 29 +-
.../internal/catalog/storage/RenameTableEntry.java | 31 +-
.../internal/catalog/storage/SnapshotEntry.java | 65 ++-
.../catalog/storage/StartBuildingIndexEntry.java | 29 +-
.../internal/catalog/storage/UpdateEntry.java | 4 +-
.../internal/catalog/storage/UpdateLogEvent.java | 4 +-
.../internal/catalog/storage/UpdateLogImpl.java | 48 ++-
.../internal/catalog/storage/VersionedUpdate.java | 56 ++-
.../CatalogEntrySerializerProvider.java | 93 +++++
.../serialization/CatalogObjectSerializer.java} | 25 +-
.../serialization/CatalogSerializationUtils.java | 166 ++++++++
.../MarshallableEntry.java} | 15 +-
.../serialization/MarshallableEntryType.java | 64 +++
.../serialization/UpdateLogMarshaller.java} | 23 +-
.../serialization/UpdateLogMarshallerImpl.java | 119 ++++++
.../storage/CatalogEntrySerializationTest.java | 440 +++++++++++++++++++++
.../catalog/storage/UpdateLogImplTest.java | 64 ++-
.../cli/commands/sql/ItSqlCommandTest.java | 24 +-
.../cli/commands/sql/ItSqlReplCommandTest.java | 24 +-
.../src/integrationTest/resources/multiline.sql | 8 +
.../internal/cli/commands/sql/SqlCommand.java | 2 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 2 +-
.../internal/client/proto/ClientMessagePacker.java | 13 +
.../client/proto/ClientMessageUnpacker.java | 10 +
.../ignite/internal/client/proto/ClientOp.java | 3 +
.../handler/ClientInboundMessageHandler.java | 4 +
.../table/ClientStreamerBatchSendRequest.java | 58 +++
.../apache/ignite/client/ClientOperationType.java | 7 +-
.../org/apache/ignite/client/RetryReadPolicy.java | 1 +
.../apache/ignite/internal/client/ClientUtils.java | 3 +
.../ignite/internal/client/TcpIgniteClient.java | 8 +-
.../internal/client/sql/ClientAsyncResultSet.java | 12 +-
.../ignite/internal/client/sql/ClientSession.java | 8 +-
.../internal/client/sql/ClientSessionBuilder.java | 18 +-
.../ignite/internal/client/sql/ClientSql.java | 12 +-
...ctClientStreamerPartitionAwarenessProvider.java | 25 +-
.../internal/client/table/AbstractClientView.java | 2 +-
.../internal/client/table/ClientDataStreamer.java | 6 +-
.../client/table/ClientKeyValueBinaryView.java | 8 +-
.../internal/client/table/ClientKeyValueView.java | 11 +-
.../client/table/ClientRecordBinaryView.java | 8 +-
.../client/table/ClientRecordSerializer.java | 23 ++
.../internal/client/table/ClientRecordView.java | 8 +-
.../ignite/internal/client/table/ClientSchema.java | 86 +++-
.../ignite/internal/client/table/ClientTable.java | 25 +-
.../ignite/internal/client/table/ClientTables.java | 11 +-
.../client/table/ClientTupleSerializer.java | 58 +++
.../client/table/PartitionAwarenessProvider.java | 27 +-
.../apache/ignite/client/ClientMetricsTest.java | 2 +-
.../org/apache/ignite/client/ClientTupleTest.java | 7 +-
.../org/apache/ignite/client/DataStreamerTest.java | 6 +-
.../ignite/client/PartitionAwarenessTest.java | 40 +-
.../ignite/client/fakes/FakeInternalTable.java | 15 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 5 +-
.../management/ClusterManagementGroupManager.java | 7 +-
.../internal/deployunit/DeploymentManagerImpl.java | 2 +-
.../internal/deployunit/FileDeployerService.java | 11 +-
.../metastore/NodeStatusWatchListener.java | 7 +-
.../ignite/deployment/FileDeployerServiceTest.java | 2 +-
.../internal/compute/queue/QueueExecutionImpl.java | 24 +-
.../compute/loader/JobContextManagerTest.java | 2 +-
.../compute/queue/PriorityQueueExecutorTest.java | 5 +-
.../internal/streamer/StreamerBatchSender.java | 5 +-
.../internal/streamer/StreamerSubscriber.java | 3 +-
.../ignite/internal/thread/IgniteThread.java | 25 +-
.../ignite/internal/thread/ThreadAttributes.java} | 24 +-
.../ignite/internal/thread/ThreadOperation.java} | 14 +-
.../internal/tostring/IgniteToStringBuilder.java | 52 ++-
.../ignite/internal/util/CollectionUtils.java | 26 ++
.../internal/streamer/StreamerSubscriberTest.java | 2 +-
.../ignite/internal/util/CollectionUtilsTest.java | 22 ++
modules/distribution-zones/build.gradle | 1 +
...niteDistributionZoneManagerNodeRestartTest.java | 6 +-
.../build.gradle | 25 +-
.../failure/handlers/FailureHandlerTest.java | 72 ++++
.../ignite/internal/failure/FailureContext.java | 65 +++
.../ignite/internal/failure/FailureProcessor.java | 128 ++++++
.../ignite/internal/failure/FailureType.java} | 19 +-
.../internal/failure/handlers/FailureHandler.java} | 26 +-
.../failure/handlers/NoOpFailureHandler.java} | 21 +-
.../failure/handlers/StopNodeFailureHandler.java} | 36 +-
.../handlers/StopNodeOrHaltFailureHandler.java | 117 ++++++
.../internal/failure/FailureProcessorTest.java | 52 +++
.../index/ItRwTransactionAndIndexesTest.java | 145 +++++++
.../internal/index/IndexBuildController.java | 3 +-
.../ignite/internal/index/IndexBuildTask.java | 25 +-
.../apache/ignite/internal/index/IndexBuilder.java | 7 +-
.../index/IndexAvailabilityControllerTest.java | 18 +-
.../internal/index/IndexBuildControllerTest.java | 23 +-
.../ignite/internal/index/IndexBuilderTest.java | 26 +-
.../ignite/internal/index/IndexManagerTest.java | 4 +-
modules/marshaller-common/build.gradle | 1 +
.../ignite/internal/marshaller/Marshaller.java | 2 +-
.../internal/marshaller/MarshallerColumn.java | 22 ++
.../internal/marshaller/MarshallerSchema.java} | 19 +-
.../internal/marshaller/MarshallersProvider.java | 87 ++++
.../marshaller/ReflectionMarshallersProvider.java | 202 ++++++++++
.../ReflectionMarshallersProviderSelfTest.java | 209 ++++++++++
modules/network/build.gradle | 3 +
.../network/netty/ItConnectionManagerTest.java | 21 +-
.../netty/OutgoingAcknowledgementSilencer.java | 5 +
.../internal/network/netty/ConnectionManager.java | 20 +-
.../network/netty/NamedNioEventLoopGroup.java | 14 +-
.../ignite/internal/network/netty/NettySender.java | 8 +
.../recovery/RecoveryClientHandshakeManager.java | 16 +-
.../recovery/RecoveryServerHandshakeManager.java | 17 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 8 +-
.../network/DefaultMessagingServiceTest.java | 136 ++-----
.../network/netty/RecoveryHandshakeTest.java | 11 +-
.../RecoveryClientHandshakeManagerTest.java | 7 +-
.../RecoveryServerHandshakeManagerTest.java | 7 +-
.../network/utils/ClusterServiceTestUtils.java | 5 +-
modules/page-memory/build.gradle | 3 +
.../persistence/checkpoint/CheckpointManager.java | 10 +-
.../CheckpointReadLockTimeoutException.java | 9 +-
.../checkpoint/CheckpointTimeoutLock.java | 27 +-
.../persistence/checkpoint/Checkpointer.java | 20 +-
.../persistence/compaction/Compactor.java | 13 +-
.../persistence/store/FilePageStoreManager.java | 17 +-
.../PersistentPageMemoryNoLoadTest.java | 10 +-
.../checkpoint/CheckpointManagerTest.java | 3 +
.../checkpoint/CheckpointTimeoutLockTest.java | 95 ++++-
.../persistence/checkpoint/CheckpointerTest.java | 9 +
.../persistence/compaction/CompactorTest.java | 55 ++-
.../store/FilePageStoreManagerTest.java | 8 +-
.../checkpoint/CheckpointTestUtils.java | 4 +-
.../ItPrimaryReplicaChoiceTest.java | 6 +
.../internal/placementdriver/LeaseUpdater.java | 99 ++++-
modules/platforms/cpp/ignite/common/error_codes.h | 9 +-
modules/platforms/cpp/ignite/odbc/common_types.cpp | 5 +
.../Compute/ComputeClusterAwarenessTests.cs | 21 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 173 ++++++--
.../dotnet/Apache.Ignite.Tests/FakeServer.cs | 22 +-
.../PartitionAwarenessRealClusterTests.cs | 4 +-
.../Proto/ColocationHashTests.cs | 8 +-
.../Table/SchemaSynchronizationTest.cs | 5 +-
.../dotnet/Apache.Ignite/ClientOperationType.cs | 17 +-
.../dotnet/Apache.Ignite/Compute/ICompute.cs | 8 +-
.../dotnet/Apache.Ignite/Compute/IJobExecution.cs | 67 ++++
.../dotnet/Apache.Ignite/Compute/JobState.cs} | 59 +--
.../dotnet/Apache.Ignite/Compute/JobStatus.cs} | 38 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 17 +
.../Apache.Ignite/Internal/Compute/Compute.cs | 129 ++++--
.../Apache.Ignite/Internal/Compute/JobExecution.cs | 95 +++++
.../Apache.Ignite/Internal/Proto/ClientOp.cs | 11 +-
.../Internal/Proto/ClientOpExtensions.cs | 3 +
.../Internal/Proto/MsgPack/MsgPackReader.cs | 15 +
.../dotnet/Apache.Ignite/RetryReadPolicy.cs | 3 +
modules/raft/build.gradle | 1 +
.../raft/ItTruncateSuffixAndRestartTest.java | 6 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 1 +
.../internal/raft/server/impl/JraftServerImpl.java | 4 +-
.../storage/impl/DefaultLogStorageFactory.java | 13 +-
.../impl/VolatileLogStorageFactoryCreator.java | 4 +-
.../raft/storage/logit/LogitLogStorageFactory.java | 4 +-
.../jraft/storage/impl/LogStorageBenchmark.java | 2 +-
.../jraft/storage/logit/LogitLogStorageTest.java | 2 +-
.../ignite/internal/replicator/ReplicaManager.java | 56 +--
.../ignite/internal/replicator/ReplicaService.java | 8 +-
.../replicator/listener/ReplicaListener.java | 18 -
modules/runner/build.gradle | 2 +
.../configuration/generator/DefaultsGenerator.java | 2 +-
.../ItDistributedConfigurationPropertiesTest.java | 2 +-
.../ItDistributedConfigurationStorageTest.java | 2 +-
.../runner/app/ItIgniteNodeRestartTest.java | 17 +-
.../ignite/internal/table/ItDurableFinishTest.java | 2 -
.../internal/table/ItThinClientColocationTest.java | 5 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 58 ++-
.../storage/DistributedConfigurationStorage.java | 6 +-
.../storage/LocalFileConfigurationStorage.java | 20 +-
.../DistributedConfigurationStorageTest.java | 2 +-
.../internal/ClusterPerClassIntegrationTest.java | 38 +-
.../ignite/internal/schema/SchemaDescriptor.java | 59 +++
.../marshaller/reflection/KvMarshallerImpl.java | 12 +-
.../reflection/RecordMarshallerImpl.java | 19 +-
.../reflection/ReflectionMarshallerFactory.java | 8 +-
.../schema/marshaller/KvMarshallerTest.java | 30 +-
.../schema/marshaller/RecordMarshallerTest.java | 24 +-
.../ignite/internal/sql/engine/ItDmlTest.java | 1 -
.../sql/engine/exec/DestinationFactory.java | 18 +-
.../internal/sql/engine/exec/ExecutableTable.java | 7 +
.../engine/exec/ExecutableTableRegistryImpl.java | 16 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 4 -
.../sql/engine/exec/LogicalRelImplementor.java | 5 +-
.../engine/exec/RehashingPartitionExtractor.java | 51 +++
.../sql/engine/exec/ResolvedDependencies.java | 11 +
.../sql/engine/exec/RowPartitionExtractor.java} | 17 +-
.../sql/engine/exec/TablePartitionExtractor.java | 61 +++
.../sql/engine/prepare/PrepareServiceImpl.java | 2 +-
.../internal/sql/engine/schema/IgniteTable.java | 5 +
.../sql/engine/schema/IgniteTableImpl.java | 29 ++
.../sql/engine/schema/PartitionCalculator.java | 66 ++++
.../internal/sql/engine/trait/Partitioned.java | 12 +-
.../sql/engine/util/HashFunctionFactory.java | 58 ---
.../sql/engine/util/HashFunctionFactoryImpl.java | 119 ------
.../exec/ExecutionDependencyResolverSelfTest.java | 7 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 6 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 2 +-
.../engine/exec/NoOpExecutableTableRegistry.java | 7 +
.../sql/engine/exec/PartitionsResolutionTest.java | 115 ++++++
.../sql/engine/framework/TestBuilders.java | 7 +
.../planner/hints/ForceIndexHintPlannerTest.java | 19 +-
.../sql/engine/prepare/TypeCoercionTest.java | 7 +
.../sql/engine/util/HashFunctionsTest.java | 111 ------
modules/storage-api/build.gradle | 3 +
.../ignite/internal/storage/DataStorageModule.java | 5 +-
.../internal/storage/DataStorageModules.java | 7 +-
.../internal/storage/ThreadAssertingCursor.java} | 46 ++-
.../storage/ThreadAssertingMvPartitionStorage.java | 164 ++++++++
.../ThreadAssertingPartitionTimestampCursor.java | 48 +++
.../engine/ThreadAssertingMvTableStorage.java | 162 ++++++++
.../engine/ThreadAssertingStorageEngine.java | 62 +++
.../index/ThreadAssertingHashIndexStorage.java | 51 +++
.../storage/index/ThreadAssertingIndexStorage.java | 76 ++++
.../storage/index/ThreadAssertingPeekCursor.java} | 43 +-
.../index/ThreadAssertingSortedIndexStorage.java | 52 +++
.../internal/storage/DataStorageManagerTest.java | 15 +-
.../internal/storage/DataStorageModulesTest.java | 6 +-
.../storage/impl/TestDataStorageModule.java | 4 +-
.../internal/storage/impl/TestMvTableStorage.java | 4 +-
modules/storage-page-memory/build.gradle | 1 +
.../PersistentPageMemoryDataStorageModule.java | 12 +-
.../PersistentPageMemoryStorageEngine.java | 12 +-
.../VolatilePageMemoryDataStorageModule.java | 4 +-
.../PersistentPageMemoryMvTableStorageTest.java | 4 +-
.../PersistentPageMemoryStorageEngineTest.java | 6 +-
.../PersistentPageMemoryHashIndexStorageTest.java | 4 +-
...PersistentPageMemorySortedIndexStorageTest.java | 10 +-
...ageMemoryMvPartitionStorageConcurrencyTest.java | 3 +-
...rsistentPageMemoryMvPartitionStorageGcTest.java | 3 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 3 +-
modules/storage-rocksdb/build.gradle | 1 +
.../storage/rocksdb/RocksDbDataStorageModule.java | 4 +-
modules/table/build.gradle | 3 +
.../apache/ignite/distributed/ItLockTableTest.java | 4 +-
.../ItTxAbstractDistributedTestSingleNode.java | 194 +++++++++
.../ItTxDistributedCleanupRecoveryTest.java | 12 +-
.../distributed/ItTxDistributedTestSingleNode.java | 241 +----------
.../ItTxDistributedTestSingleNodeCollocated.java | 2 +-
...xDistributedTestSingleNodeNoCleanupMessage.java | 12 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 3 +-
.../ignite/distributed/ItTxStateLocalMapTest.java | 2 +-
.../ignite/distributed/ReplicaUnavailableTest.java | 2 +-
.../rebalance/ItRebalanceDistributedTest.java | 16 +-
.../ignite/internal/table/ItColocationTest.java | 3 +-
.../internal/table/ItTransactionRecoveryTest.java | 146 ++++++-
.../ignite/internal/table/AbstractTableView.java | 9 +-
.../internal/table/KeyValueBinaryViewImpl.java | 21 +-
.../ignite/internal/table/KeyValueViewImpl.java | 27 +-
.../internal/table/RecordBinaryViewImpl.java | 29 +-
.../ignite/internal/table/RecordViewImpl.java | 25 +-
.../apache/ignite/internal/table/TableImpl.java | 26 +-
.../internal/table/distributed/LowWatermark.java | 14 +-
.../table/distributed/StorageUpdateHandler.java | 81 ++--
.../internal/table/distributed/TableManager.java | 35 +-
.../internal/table/distributed/TableUtils.java | 56 +++
.../table/distributed/command/FinishTxCommand.java | 6 -
.../table/distributed/gc/GcUpdateHandler.java | 3 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 3 +-
.../distributed/index/IndexUpdateHandler.java | 81 +++-
.../table/distributed/raft/PartitionListener.java | 40 +-
.../raft/snapshot/PartitionAccessImpl.java | 6 +-
.../outgoing/OutgoingSnapshotsManager.java | 16 +-
.../request/BuildIndexReplicaRequest.java | 3 +
.../replicator/PartitionReplicaListener.java | 181 +++------
.../table/KeyValueBinaryViewOperationsTest.java | 7 +-
.../internal/table/KeyValueViewOperationsTest.java | 7 +-
.../table/RecordBinaryViewOperationsTest.java | 4 +-
.../internal/table/RecordViewOperationsTest.java | 7 +-
.../internal/table/distributed/IndexBaseTest.java | 5 +-
.../table/distributed/IndexCleanupTest.java | 12 +-
.../table/distributed/LowWatermarkTest.java | 3 +-
.../table/distributed/StorageCleanupTest.java | 146 +++----
.../distributed/StorageUpdateHandlerTest.java | 9 +-
.../table/distributed/TableManagerTest.java | 6 +-
.../internal/table/distributed/TableUtilsTest.java | 123 ++++++
.../PartitionRaftCommandsSerializationTest.java | 3 -
.../gc/AbstractGcUpdateHandlerTest.java | 23 +-
.../PersistentPageMemoryGcUpdateHandlerTest.java | 4 +-
.../raft/PartitionCommandListenerTest.java | 19 +-
.../raft/snapshot/PartitionAccessImplTest.java | 9 +-
.../incoming/IncomingSnapshotCopierTest.java | 4 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 7 +-
.../PartitionReplicaListenerIndexLockingTest.java | 6 +
.../replication/PartitionReplicaListenerTest.java | 165 ++++++--
.../PartitionCommandsMarshallerImplTest.java | 2 -
.../apache/ignite/distributed/ItTxTestCluster.java | 57 ++-
.../ignite/internal/table/TxAbstractTest.java | 396 ++++++++++---------
.../table/impl/DummyInternalTableImpl.java | 9 +-
.../org/apache/ignite/internal/tx/TxManager.java | 9 +-
.../java/org/apache/ignite/internal/tx/TxMeta.java | 17 +-
.../ignite/internal/tx/impl/HeapLockManager.java | 11 +-
.../internal/tx/impl/HeapUnboundedLockManager.java | 35 +-
.../internal/tx/impl/ReadWriteTransactionImpl.java | 28 +-
.../internal/tx/impl/TxCleanupRequestSender.java | 21 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 55 +--
.../ignite/internal/tx/impl/TxMessageSender.java | 3 +-
.../tx/message/TxFinishReplicaRequest.java | 4 +-
.../apache/ignite/internal/tx/TxCleanupTest.java | 38 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 24 +-
.../storage/state/AbstractTxStateStorageTest.java | 46 +--
modules/workers/build.gradle | 2 +
.../internal/worker/CriticalWorkerWatchdog.java | 46 ++-
.../ignite/internal/worker/ThreadAssertions.java | 75 ++++
settings.gradle | 2 +
342 files changed, 8647 insertions(+), 2293 deletions(-)
create mode 100644 .github/dependabot.yml
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogEntrySerializerProvider.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTable.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogObjectSerializer.java}
(57%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/CatalogSerializationUtils.java
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/{UpdateLogEvent.java
=> serialization/MarshallableEntry.java} (68%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/MarshallableEntryType.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTable.java
=>
catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/UpdateLogMarshaller.java}
(59%)
create mode 100644
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/serialization/UpdateLogMarshallerImpl.java
create mode 100644
modules/catalog/src/test/java/org/apache/ignite/internal/catalog/storage/CatalogEntrySerializationTest.java
create mode 100644 modules/cli/src/integrationTest/resources/multiline.sql
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/requests/table/ClientStreamerBatchSendRequest.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTable.java
=> core/src/main/java/org/apache/ignite/internal/thread/ThreadAttributes.java}
(61%)
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java
=> core/src/main/java/org/apache/ignite/internal/thread/ThreadOperation.java}
(69%)
copy modules/{marshaller-common => failure-handler}/build.gradle (65%)
create mode 100755
modules/failure-handler/src/integrationTest/java/org/apache/ignite/internal/failure/handlers/FailureHandlerTest.java
create mode 100644
modules/failure-handler/src/main/java/org/apache/ignite/internal/failure/FailureContext.java
create mode 100644
modules/failure-handler/src/main/java/org/apache/ignite/internal/failure/FailureProcessor.java
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java
=>
failure-handler/src/main/java/org/apache/ignite/internal/failure/FailureType.java}
(64%)
copy
modules/{core/src/main/java/org/apache/ignite/internal/streamer/StreamerBatchSender.java
=>
failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/FailureHandler.java}
(54%)
rename
modules/{network/src/main/java/org/apache/ignite/internal/network/recovery/FailureHandler.java
=>
failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/NoOpFailureHandler.java}
(61%)
mode change 100644 => 100755
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogIndexColumnDescriptor.java
=>
failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/StopNodeFailureHandler.java}
(55%)
create mode 100644
modules/failure-handler/src/main/java/org/apache/ignite/internal/failure/handlers/StopNodeOrHaltFailureHandler.java
create mode 100644
modules/failure-handler/src/test/java/org/apache/ignite/internal/failure/FailureProcessorTest.java
create mode 100644
modules/index/src/integrationTest/java/org/apache/ignite/internal/index/ItRwTransactionAndIndexesTest.java
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java
=>
marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/MarshallerSchema.java}
(68%)
create mode 100644
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/MarshallersProvider.java
create mode 100644
modules/marshaller-common/src/main/java/org/apache/ignite/internal/marshaller/ReflectionMarshallersProvider.java
create mode 100644
modules/marshaller-common/src/test/java/org/apache/ignite/internal/marshaller/ReflectionMarshallersProviderSelfTest.java
mode change 100644 => 100755 modules/platforms/cpp/ignite/common/error_codes.h
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Compute/IJobExecution.cs
copy modules/{api/src/main/java/org/apache/ignite/compute/JobState.java =>
platforms/dotnet/Apache.Ignite/Compute/JobState.cs} (51%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/IgniteTable.java
=> platforms/dotnet/Apache.Ignite/Compute/JobStatus.cs} (59%)
mode change 100644 => 100755
modules/platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs
create mode 100644
modules/platforms/dotnet/Apache.Ignite/Internal/Compute/JobExecution.cs
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RehashingPartitionExtractor.java
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/storage/UpdateLogEvent.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/RowPartitionExtractor.java}
(72%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/TablePartitionExtractor.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/schema/PartitionCalculator.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/HashFunctionFactory.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/util/HashFunctionFactoryImpl.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/PartitionsResolutionTest.java
delete mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/util/HashFunctionsTest.java
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogIndexColumnDescriptor.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/ThreadAssertingCursor.java}
(51%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/ThreadAssertingMvPartitionStorage.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/ThreadAssertingPartitionTimestampCursor.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/ThreadAssertingMvTableStorage.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/engine/ThreadAssertingStorageEngine.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingHashIndexStorage.java
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingIndexStorage.java
copy
modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/descriptors/CatalogIndexColumnDescriptor.java
=>
storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingPeekCursor.java}
(50%)
create mode 100644
modules/storage-api/src/main/java/org/apache/ignite/internal/storage/index/ThreadAssertingSortedIndexStorage.java
create mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItTxAbstractDistributedTestSingleNode.java
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableUtils.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/distributed/TableUtilsTest.java
create mode 100644
modules/workers/src/main/java/org/apache/ignite/internal/worker/ThreadAssertions.java
