This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-26090
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 6584a80ef62 minor after review
add debb7a03879 IGNITE-26473 Persist index memtable on checkpoint (#6636)
add 62a19d817be IGNITE-20320 Avoid sharing HybridClock between nodes in
tests (#6642)
add 4d443c571d1 IGNITE-26518 Fix free list corruption caused by specific
binary rows (#6652)
add 9368ef31c98 IGNITE-26455 Add support for deploy units with folders
structure (#6625)
add c5486a37c1c IGNITE-25868 Add client name configuration (#6645)
add 4adf0436ff5 Bump value from 2.11.3 to 2.11.4 (#6655)
add 694ef61aa00 IGNITE-26092 Add aipersist storage format compatibility
tests (#6643)
add c59ccbbd41a IGNITE-26528 Fix flaky DeploymentManagementControllerTest
(#6657)
add 12d933e0c67 IGNITE-26522 Fix timeouts in
ItTxDistributedTestSingleNode.testImplicitTransactionTimeout (#6653)
add b688491699a IGNITE-26494 Raft heartbeats use fork-join common thread
pool (#6640)
add c2a3e76a5ff Bump org.apache.commons:commons-lang3 from 3.18.0 to
3.19.0 (#6650)
add c5302d320e7 IGNITE-26535 Remove unused parameters in
RecoveryHandshakeTest (#6658)
add 1540b414c12 IGNITE-24632 add CatalogTableDescriptor.Builder (#6648)
add 92844b66f1a IGNITE-26395 Correct processing of initial empty data
nodes (#6604)
add 9279e9e6529 IGNITE-26545 Fix shutdown TableManager#rebalanceScheduler
(#6668)
add 2f4dabcd96c IGNITE-26520 Migration Tools: Refactor SqlDdlGenerator
(#6656)
add 757cb6b1aa1 IGNITE-26551 Expand the information in
RejectedExecutionException for pools from ExecutorServiceExtension (#6669)
add 226cb5e5d29 IGNITE-26281 Implement index file meta for the new log
storage (#6661)
add 43281e73eef IGNITE-25306 Implement all type sql test on top of old
work dir (#6356)
add ab65435b83d IGNITE-26537 Allow overriding JVM properties for CLI
(#6662)
add ed4eff4a981 IGNITE-26549 Async file io uses default pool (#6673)
add b220103c920 IGNITE-26533 Job class loader is leaking (#6660)
add 1f0cfe1d146 IGNITE-26538 Specify config and logs directory for CLI in
the docker (#6663)
add 5b38be74f89 IGNITE-26555 Fix inconsistent RO TX read timestamp on
client (#6672)
add d49610e2902 IGNITE-26530 Fix ByteArrayMarshaller (#6679)
add c17c383804b Merge branch 'main' into ignite-26090
add 3740a5391bd styles
No new revisions were added by this update.
Summary of changes:
gradle/libs.versions.toml | 4 +-
.../migration-tools-commons-tests/build.gradle | 6 +-
.../tests/models/InterceptingFieldsModel.java | 112 ++++++
.../sql/FieldNameConflictException.java | 3 +-
.../ignite/migrationtools/sql/SqlDdlGenerator.java | 403 ++++++++++-----------
.../PersistentTableTypeRegistryImpl.java | 67 +++-
.../RegisterOnlyTableTypeRegistry.java | 9 +-
.../tablemanagement/TableTypeDescriptor.java | 78 ++++
.../tablemanagement/TableTypeRegistry.java | 11 +-
.../tablemanagement/TableTypeRegistryMapImpl.java | 19 +-
.../tablemanagement/TableTypeRegistryUtils.java | 48 +++
.../migrationtools/types/InspectedField.java | 159 ++++++++
.../migrationtools/types/InspectedFieldType.java | 11 +-
.../ignite/migrationtools/types/TypeInspector.java | 138 +++++++
.../sql/sql/SqlDdlGeneratorTest.java | 225 ++++++++++--
.../migrationtools/types/TypeInspectorTest.java | 114 ++++++
.../persistence/Ignite2PersistentCacheTools.java | 2 +-
.../java/org/apache/ignite/lang/ErrorGroups.java | 9 +
.../ignite/marshalling/ByteArrayMarshaller.java | 7 +-
.../catalog/commands/CreateTableCommand.java | 22 +-
.../internal/catalog/commands/DefaultValue.java | 2 +-
.../descriptors/CatalogTableDescriptor.java | 305 ++++++++++++----
.../CatalogTableDescriptorSerializers.java | 52 +--
.../internal/catalog/storage/AlterColumnEntry.java | 43 +--
.../internal/catalog/storage/DropColumnsEntry.java | 42 +--
.../internal/catalog/storage/NewColumnsEntry.java | 37 +-
.../internal/catalog/storage/RenameTableEntry.java | 36 +-
.../{RenameTableEntry.java => UpdateTable.java} | 79 ++--
.../ignite/internal/catalog/CatalogTableTest.java | 11 +-
.../commands/AbstractCommandValidationTest.java | 21 +-
.../catalog/commands/CatalogUtilsTest.java | 12 +-
.../descriptors/CatalogTableDescriptorTest.java | 134 ++++++-
.../storage/CatalogEntrySerializationTest.java | 22 +-
.../catalog/storage/TestTableDescriptors.java | 124 ++++---
.../internal/compute/SharedComputeUtils.java | 49 ++-
.../ignite/client/handler/FakeCatalogService.java | 23 +-
.../org/apache/ignite/client/IgniteClient.java | 22 +-
.../ignite/client/IgniteClientConfiguration.java | 12 +
.../client/IgniteClientConfigurationImpl.java | 22 +-
.../ignite/internal/client/TcpIgniteClient.java | 25 +-
.../internal/client/tx/ClientLazyTransaction.java | 8 +-
.../internal/client/tx/ClientTransactions.java | 5 +-
.../ignite/internal/client/tx/DirectTxUtils.java | 2 +-
.../apache/ignite/client/ClientMetricsTest.java | 65 +++-
.../apache/ignite/client/ConfigurationTest.java | 1 +
.../org/apache/ignite/client/ConnectionTest.java | 4 +-
.../ignite/client/FeatureCompatibilityTest.java | 6 +-
.../ObservableTimestampComputePropagationTest.java | 5 +-
.../client/ObservableTimestampPropagationTest.java | 6 +-
.../ignite/client/PartitionAwarenessTest.java | 14 +-
.../org/apache/ignite/client/RetryPolicyTest.java | 2 +-
.../apache/ignite/client/TestLoggerFactory.java | 5 +
.../java/org/apache/ignite/client/TestServer.java | 15 +-
.../org/apache/ignite/client/fakes/FakeIgnite.java | 20 +-
.../ignite/internal/deployment/DeployFile.java | 9 +-
.../ignite/internal/deployment/DeployFiles.java | 104 ++++--
.../internal/deployment/ItDeploymentUnitTest.java | 18 +
.../apache/ignite/internal/deployment/Unit.java | 35 +-
.../internal/deployunit/DeployerProcessor.java | 86 +++++
.../ignite/internal/deployunit/DeploymentUnit.java | 50 +--
.../deployunit/DeploymentUnitProcessor.java | 59 +++
.../internal/deployunit/FileDeployerService.java | 25 +-
...eploymentUnit.java => FilesDeploymentUnit.java} | 28 +-
.../ignite/internal/deployunit/UnitContent.java | 23 +-
.../internal/deployunit/ZipDeploymentUnit.java | 66 ++++
...eption.java => DeploymentUnitZipException.java} | 21 +-
.../ignite/deployment/FileDeployerServiceTest.java | 31 +-
modules/compatibility-tests/build.gradle | 9 +
.../org/apache/ignite/internal/CheckpointJob.java | 119 ++++++
.../ignite/internal/ItCompatibilityTest.java | 103 +++++-
.../internal/PersistentCompatibilityTest.java | 258 +++++++++++++
.../internal/compute/ItComputeTestStandalone.java | 3 +-
.../org/apache/ignite/internal/compute/Pojo.java | 62 ----
.../ignite/internal/compute/ComputeUtils.java | 12 +-
.../compute/executor/ComputeExecutorImpl.java | 4 +-
.../internal/compute/loader/JobClassLoader.java | 17 +-
.../compute/task/TaskExecutionInternal.java | 4 +-
.../compute/loader/JobClassLoaderFactoryTest.java | 81 ++++-
.../ExecutorServiceExtensionTest.java | 4 +-
.../testframework/ExecutorServiceExtension.java | 83 ++++-
.../internal/testframework/IgniteTestUtils.java | 26 ++
.../testframework/WorkDirectoryExtension.java | 15 +-
.../distributionzones/ItEmptyDataNodesTest.java | 127 +++++++
.../rebalance/ItRebalanceDistributedTest.java | 12 +-
.../distributionzones/DistributionZoneManager.java | 33 +-
.../exception/EmptyDataNodesException.java} | 27 +-
.../distributionzones/rebalance/RebalanceUtil.java | 11 +-
.../rebalance/ZoneRebalanceUtil.java | 8 +-
.../RebalanceUtilUpdateAssignmentsTest.java | 30 +-
modules/file-io/build.gradle | 1 +
.../apache/ignite/internal/fileio/AsyncFileIo.java | 7 +-
.../ignite/internal/fileio/AsyncFileIoFactory.java | 23 +-
.../ignite/internal/jdbc/JdbcConnection.java | 5 +-
.../impl/ItMetaStorageManagerImplTest.java | 6 +-
.../impl/ItMetaStorageServicePersistenceTest.java | 7 +-
.../service/ItAbstractListenerSnapshotTest.java | 5 +-
.../ignite/internal/metrics/MetricManagerImpl.java | 8 +-
.../network/netty/RecoveryHandshakeTest.java | 43 +--
.../ignite/internal/pagememory/io/DataPageIo.java | 9 +-
.../partition/replicator/fixtures/Node.java | 16 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 1 -
.../PartitionReplicaLifecycleManager.java | 5 +-
.../schema/CatalogValidationSchemasSource.java | 12 +-
.../schemacompat/SchemaCompatibilityValidator.java | 8 +-
.../raft/ZonePartitionRaftListenerTest.java | 1 -
.../SnapshotAwarePartitionDataStorageTest.java | 22 +-
.../schema/CatalogValidationSchemasSourceTest.java | 20 +-
.../EmptyAssignmentsException.java} | 17 +-
.../MultiActorPlacementDriverTest.java | 4 +-
.../PlacementDriverManagerTest.java | 4 +-
.../placementdriver/AssignmentsTracker.java | 7 +-
.../placementdriver/PlacementDriverManager.java | 16 +-
.../ignite/internal/placementdriver/Utils.java | 50 +++
.../placementdriver/leases/LeaseTracker.java | 77 +++-
.../internal/placementdriver/ActiveActorTest.java | 4 +-
.../placementdriver/LeaseNegotiationTest.java | 15 +-
.../internal/placementdriver/LeaseTrackerTest.java | 8 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 6 +-
.../placementdriver/PlacementDriverTest.java | 20 +-
modules/platforms/cpp/ignite/common/error_codes.h | 3 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 3 +
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 9 +
modules/raft/build.gradle | 2 +
.../raft/storage/segstore/CheckpointQueue.java | 8 +-
.../raft/storage/segstore/GroupIndexMeta.java | 81 +++++
.../raft/storage/segstore/IndexFileManager.java | 273 ++++++++++++++
.../raft/storage/segstore/IndexFileMeta.java | 77 ++++
.../raft/storage/segstore/IndexFileMetaArray.java | 97 +++++
.../raft/storage/segstore/IndexFilePointer.java} | 23 +-
.../raft/storage/segstore/IndexMemTable.java | 91 ++++-
.../raft/storage/segstore/RaftLogCheckpointer.java | 36 +-
.../storage/segstore/ReadModeIndexMemTable.java} | 37 +-
.../raft/storage/segstore/SegmentFileManager.java | 23 +-
.../raft/storage/segstore/SegmentFilePointer.java} | 25 +-
.../raft/storage/segstore/SegmentInfo.java | 41 ++-
...exMemTable.java => WriteModeIndexMemTable.java} | 51 +--
.../org/apache/ignite/raft/jraft/NodeManager.java | 33 +-
.../ignite/raft/jraft/rpc/InvokeCallback.java | 4 +-
.../raft/storage/segstore/ByteChannelUtils.java} | 29 +-
.../raft/storage/segstore/CheckpointQueueTest.java | 18 +-
.../storage/segstore/DeserializedIndexFile.java | 154 ++++++++
.../segstore/DeserializedSegmentPayload.java | 71 ++--
.../raft/storage/segstore/GroupIndexMetaTest.java | 107 ++++++
.../storage/segstore/IndexFileManagerTest.java | 146 ++++++++
.../storage/segstore/IndexFileMetaArrayTest.java | 93 +++++
.../raft/storage/segstore/IndexMemTableTest.java | 33 ++
.../storage/segstore/RaftLogCheckpointerTest.java | 16 +-
.../storage/segstore/SegmentFileManagerTest.java | 118 ++++--
.../storage/segstore/SegstoreLogStorageTest.java | 25 +-
.../ignite/raft/jraft/rpc/AbstractRpcTest.java | 37 +-
.../rest/api/deployment/DeploymentCodeApi.java | 38 ++
.../DeploymentManagementControllerTest.java | 174 +++++++--
.../deployment/CompletedFileUploadSubscriber.java | 62 ++--
.../deployment/DeploymentManagementController.java | 46 ++-
.../rest/deployment/InputStreamCollector.java | 63 ++++
.../rest/deployment/InputStreamCollectorImpl.java | 57 +++
.../rest/deployment/ZipInputStreamCollector.java | 98 +++++
...java => DeploymentUnitZipExceptionHandler.java} | 13 +-
.../runner/app/ItIgniteNodeRestartTest.java | 14 +-
.../app/client/ItThinClientTransactionsTest.java | 19 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 38 +-
.../ignite/internal/app/ThreadPoolsManager.java | 11 +
.../ignite/internal/schema/SchemaManager.java | 2 +-
.../apache/ignite/internal/schema/SchemaUtils.java | 2 +-
.../ignite/internal/schema/SchemaManagerTest.java | 45 +--
.../CatalogToSchemaDescriptorConverterTest.java | 37 +-
.../internal/sql/engine/ItFloatingPointTest.java | 7 +-
.../sql/engine/schema/SqlSchemaManagerImpl.java | 6 +-
.../statistic/SqlStatisticManagerImplTest.java | 49 ++-
.../engine/ThreadAssertingStorageEngine.java | 8 +-
.../storage/AbstractMvPartitionStorageTest.java | 22 ++
.../internal/storage/BaseMvTableStorageTest.java | 33 +-
.../storage/index/AbstractIndexStorageTest.java | 28 +-
.../PersistentPageMemoryStorageEngine.java | 34 +-
.../ItTxAbstractDistributedTestSingleNode.java | 29 +-
.../internal/table/distributed/TableManager.java | 1 -
.../table/distributed/index/IndexMeta.java | 2 +-
.../replicator/PartitionReplicaListener.java | 2 +-
.../distributed/schema/SchemaVersionsImpl.java | 2 +-
.../PartitionRaftCommandsSerializationTest.java | 5 +-
.../index/BaseIndexMetaStorageTest.java | 2 +-
.../raft/PartitionCommandListenerTest.java | 8 +-
.../PartitionReplicaListenerIndexLockingTest.java | 2 +-
...itionReplicaListenerSortedIndexLockingTest.java | 2 +-
.../replication/PartitionReplicaListenerTest.java | 41 ++-
.../ZonePartitionReplicaListenerTest.java | 37 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 2 +-
.../table/impl/DummyInternalTableImpl.java | 2 +-
packaging/cli/start.sh | 2 +-
packaging/docker/Dockerfile | 1 +
packaging/docker/docker-entrypoint.sh | 3 +-
191 files changed, 5893 insertions(+), 1628 deletions(-)
create mode 100644
migration-tools/modules/migration-tools-commons-tests/src/main/java/org/apache/ignite/migrationtools/tests/models/InterceptingFieldsModel.java
create mode 100644
migration-tools/modules/migration-tools-commons/src/main/java/org/apache/ignite/migrationtools/tablemanagement/TableTypeDescriptor.java
create mode 100644
migration-tools/modules/migration-tools-commons/src/main/java/org/apache/ignite/migrationtools/tablemanagement/TableTypeRegistryUtils.java
create mode 100644
migration-tools/modules/migration-tools-commons/src/main/java/org/apache/ignite/migrationtools/types/InspectedField.java
copy dev-utilities/build.gradle =>
migration-tools/modules/migration-tools-commons/src/main/java/org/apache/ignite/migrationtools/types/InspectedFieldType.java
(81%)
create mode 100644
migration-tools/modules/migration-tools-commons/src/main/java/org/apache/ignite/migrationtools/types/TypeInspector.java
create mode 100644
migration-tools/modules/migration-tools-commons/src/test/java/org/apache/ignite/migrationtools/types/TypeInspectorTest.java
copy
modules/catalog/src/main/java/org/apache/ignite/internal/catalog/storage/{RenameTableEntry.java
=> UpdateTable.java} (55%)
create mode 100644
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeployerProcessor.java
create mode 100644
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/DeploymentUnitProcessor.java
copy
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/{DeploymentUnit.java
=> FilesDeploymentUnit.java} (54%)
create mode 100644
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/ZipDeploymentUnit.java
copy
modules/code-deployment/src/main/java/org/apache/ignite/internal/deployunit/exception/{DeploymentUnitAlreadyExistsException.java
=> DeploymentUnitZipException.java} (67%)
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/CheckpointJob.java
create mode 100644
modules/compatibility-tests/src/integrationTest/java/org/apache/ignite/internal/PersistentCompatibilityTest.java
delete mode 100644
modules/compute/src/jobs/java/org/apache/ignite/internal/compute/Pojo.java
create mode 100644
modules/distribution-zones/src/integrationTest/java/org/apache/ignite/internal/distributionzones/ItEmptyDataNodesTest.java
copy
modules/{code-deployment/src/main/java/org/apache/ignite/internal/deployunit/exception/DeploymentUnitAlreadyExistsException.java
=>
distribution-zones/src/main/java/org/apache/ignite/internal/distributionzones/exception/EmptyDataNodesException.java}
(60%)
copy
modules/{raft-api/src/main/java/org/apache/ignite/internal/raft/GroupOverloadedException.java
=>
placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/EmptyAssignmentsException.java}
(59%)
create mode 100644
modules/placement-driver/src/main/java/org/apache/ignite/internal/placementdriver/Utils.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/GroupIndexMeta.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/IndexFileManager.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/IndexFileMeta.java
create mode 100644
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/IndexFileMetaArray.java
copy
modules/{eventlog/src/test/java/org/apache/ignite/internal/eventlog/ser/Message.java
=>
raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/IndexFilePointer.java}
(66%)
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/call/CallOutput.java
=>
raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/ReadModeIndexMemTable.java}
(54%)
copy
modules/{security/src/main/java/org/apache/ignite/internal/security/authentication/basic/BasicUser.java
=>
raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/SegmentFilePointer.java}
(68%)
copy
modules/raft/src/main/java/org/apache/ignite/internal/raft/storage/segstore/{IndexMemTable.java
=> WriteModeIndexMemTable.java} (55%)
copy
modules/{compute/src/jobs/java/org/apache/ignite/internal/compute/NonEmptyConstructorJob.java
=>
raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/ByteChannelUtils.java}
(58%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/DeserializedIndexFile.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/GroupIndexMetaTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/IndexFileManagerTest.java
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/storage/segstore/IndexFileMetaArrayTest.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/InputStreamCollector.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/InputStreamCollectorImpl.java
create mode 100644
modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/ZipInputStreamCollector.java
copy
modules/rest/src/main/java/org/apache/ignite/internal/rest/deployment/exception/handler/{DeploymentUnitNotFoundExceptionHandler.java
=> DeploymentUnitZipExceptionHandler.java} (77%)
