This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-27391
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 77f5437ca24 revert changes in test
add f477c5550be IGNITE-27258 Wait for all nodes in MULTI_NODE disaster
recovery requests (#7156)
add f1f7198f1fa IGNITE-27456 Add test for race between starting index
build and writing committed values (#7311)
add 2f74b03afd8 IGNITE-27458 Stop PartitionReplicaListener being
ReplicaListener (#7313)
add 35d373c931f IGNITE-27452 Add --timed option to CLI (#7314)
add fb591a48fb7 IGNITE-27462 Restore specifics of
ItTxDistributedTestSingleNodeNoCleanupMessage (#7316)
add d25a5c2ac25 IGNITE-27345 NullPointerException in
WriteIntentSwitchRequestHandler (#7315)
add 49b45b03721 IGNITE-27293 Improve test coverage of InternalTable.scan
methods (#7270)
add 4cff628f9bb IGNITE-25836 Suppress client handler logs for cancellation
errors (#7306)
add fbf86d06945 IGNITE-27255 Fixed TxIdMismatchException due to write
attempt by RW transaction after write intent resolution (#7263)
add d90255b5bbe ignite-27446 Extended string and literals in union (#7297)
add 1b1f8af9950 IGNITE-27346 Handle 'LWM below earliest Catalog ts' on
recovery (#7326)
add 04fc38f6f3a IGNITE-27434 Create new RAFT client to wait for group
availability (#7286)
add b5bf0bb452c IGNITE-27453 Handle SafeTimeSyncCommand on zone level
(#7307)
add 87aafb41db1 IGNITE-24345 Defer zone destruction after drop (#7322)
add 0e18f86bf1c IGNITE-27278 .NET: Add mapper support to SQL, Compute,
PartitionManager APIs (#7305)
add 0202698b703 IGNITE-27323 Add suggestion about DDL queries batching
(#7246)
add 7df27a595d8 IGNITE-27188 Java client: Fix node restart handling (#7327)
add d94067c4dda IGNITE-27142 Remove non-clocated code (disaster recovery)
(#7265)
add 51ad1f918d3 IGNITE-27481 Do not take partition snapshot lock in table
raft processor (#7332)
add eed4ba0edd8 IGNITE-27477 Raise LWM on recovery if it lags behind
Catalog history (#7330)
add be5df8031e6 IGNITE-27356 Add checkpoint metrics (#7250)
add 14e03754680 IGNITE-27358 Add page memory metrics (#7320)
add ac18ff2b5e6 IGNITE-27488 Remove TablePartitionKey (#7335)
add 29afe19116b IGNITE-27479 System View. Introduce late materialization
for row from system views (#7333)
add 942e99fa932 IGNITE-26636 Introduce basic API for expression execution
and predicate implementation (#7303)
add 3b43d82d51e IGNITE-27421 Remove
IgniteSystemProperties#colocationEnabled usages from tests (#7334)
add 22ec1841def Bump com.github.siom79.japicmp:japicmp from 0.25.0 to
0.25.1 (#7296)
add b1451f8f189 Bump io.swagger.parser.v3:swagger-parser from 2.1.36 to
2.1.37 (#7281)
add 536a5817590 IGNITE-25801 Sql. Use
CoreRules.JOIN_SUB_QUERY_TO_CORRELATE instead of IgniteSubQueryRemoveRule
(#7337)
add 081a4e1b203 IGNITE-23226 Remove using javax.annotation.Nullable (#7342)
add 0eebf87abf0 Bump org.bouncycastle:bcpkix-jdk18on from 1.82 to 1.83
(#7338)
add 6bbf4137d60 Bump log4j from 2.25.2 to 2.25.3 (#7280)
add 1a958b56e68 Bump org.openapi.generator from 7.17.0 to 7.18.0 (#7339)
add c37bdf2edc5 IGNITE-27480 Flaky
testWriteIntentResolutionAfterTableAlreadyDestroyed (#7331)
add d11e62b50f1 IGNITE-24813 Java client: fix logging on server disconnect
(#7336)
add 8d3ca8cf4b9 IGNITE-27497 Reduce network timeout in
IncomingSnapshotCopier (#7344)
add ff9e052c23d IGNITE-22303 Sql. Retry operation when plan gets outdated
by the time of execution (#7309)
add eb52738326f Bump io.opentelemetry:opentelemetry-exporter-otlp from
1.55.0 to 1.57.0 (#7346)
add 9e435433044 Bump com.google.protobuf:protobuf-java from 4.33.1 to
4.33.2 (#7347)
add 512cf3fa3f1 Bump net.bytebuddy:byte-buddy from 1.18.1 to 1.18.3 (#7348)
add 075e6cef950 IGNITE-27504 Wait for partitions to be healthy before
restarting them in CLI tests (#7354)
add 110b103448e IGNITE-27498 Improve sendServerExceptionStackTraceToClient
message (#7345)
add 4aae911fec0 [IGNITE-27395] remove Todo (#7340)
add 74591aa468c IGNITE-27243 Throw a NullPointerException instead of a
BinaryTupleFormatException when attempting to read a null value into a
primitive (#7319)
add ae7dfca2d25 IGNITE-27486 .NET: Skip intensive tests on Windows (#7359)
add 9b7ebc3b641 IGNITE-27485 Increase timeouts in
ItAbstractDataStreamerTest (#7358)
add c3f458dc95c IGNITE-27509 Remove unnecessary classes in migration-tools
(#7366)
add 1b1df57e0a4 IGNITE-27503 Add DEVNOTES about client connection
management (#7357)
add dd80a5d6810 Bump com.github.spotbugs from 6.4.7 to 6.4.8 (#7352)
add 35c6f4a4fb7 Bump org.junit.platform:junit-platform-testkit from 1.14.0
to 1.14.1 (#7353)
add 7dec3be3789 Bump testcontainers from 2.0.0 to 2.0.3 (#7351)
add 16d400b0c5f IGNITE-27308 Improve the delta file merge pause strategy
(#7360)
add c254ff249a9 IGNITE-27517 Simplify the generic parameter of
TimeoutObject (#7368)
add d20d772b2b4 IGNITE-27505 Clarify OS CpuLoad metric description (#7378)
add 93bd10767d4 IGNITE-27519 Add CLAUDE.md with development guidelines for
AI assistants (#7373)
add 779a6051241 IGNITE-27487 .NET: Fix GetConnections race condition
(#7375)
add 74daeb948eb IGNITE-27525 .NET: Add version to api docs footer (#7376)
add 3977887c2c1 IGNITE-27004 Add tx labels to system views (#7323)
add e997cdf9ec9 IGNITE-27528 Make ConfigOverride repeatable (#7381)
add c8b8b0d287a Bump io.github.bonede:tree-sitter from 0.25.3 to 0.26.3
(#7371)
add 1c7f06d4b28 Bump value from 2.12.0 to 2.12.1 (#7370)
add 42b18d49fe7 IGNITE-22377 Fail one of nodes if a stale node detected
(#7248)
add f668aea589d Bump junit5 from 5.14.1 to 5.14.2 (#7369)
add 0151462aa58 IGNITE-27185 ItMetastorageRaftSnapshotCompatibilityTest is
broken (#7341)
add b246612777f IGNITE-27529 Fix circular exception chain in
ClientFutureUtils.doWithRetryAsync (#7384)
add dbabb463aa4 Merge branch 'main' into ignite-27391
No new revisions were added by this update.
Summary of changes:
.claude/skills/ignite-cluster-setup/SKILL.md | 60 +
.justfile | 173 +++
.../platform_tests/PlatformDotnetTestsWindows.kt | 4 +-
CLAUDE.md | 124 ++
RELEASE.md | 7 +-
gradle/libs.versions.toml | 28 +-
.../SkipUnsupportedOperationsHandlers.java | 51 -
.../java/org/apache/ignite/lang/ErrorGroups.java | 6 +
.../java/org/apache/ignite/table/TupleImpl.java | 50 +-
.../org/apache/ignite/table/TupleImplTest.java | 5 +
.../ignite/table/AbstractImmutableTupleTest.java | 62 +
.../ignite/table/AbstractMutableTupleTest.java | 33 +
.../internal/binarytuple/BinaryTupleReader.java | 36 +-
modules/catalog-compaction/build.gradle | 4 +
...eryAfterCatalogTruncatedAboveStoredLwmTest.java | 126 ++
.../compaction/CatalogCompactionRunner.java | 20 +-
.../CatalogCompactionRunnerSelfTest.java | 2 +
.../systemviews/TablesSystemViewProvider.java | 23 +-
.../cli/commands/ItNotInitializedClusterTest.java | 4 +-
.../partitions/reset/ItResetPartitionsTest.java | 25 -
.../restart/ItRestartPartitionsTest.java | 44 +-
.../partitions/states/ItPartitionStatesTest.java | 22 +-
.../cli/commands/sql/ItSqlTimedOptionTest.java | 134 +++
.../repl/executor/ItIgnitePicocliCommandsTest.java | 3 +-
.../ignite/internal/cli/ssl/ItJdbcSslTest.java | 6 +-
.../call/recovery/reset/ResetPartitionsCall.java | 21 +-
.../recovery/reset/ResetPartitionsCallInput.java | 20 +-
.../recovery/restart/RestartPartitionsCall.java | 34 +-
.../restart/RestartPartitionsCallInput.java | 20 +-
.../call/recovery/states/PartitionStatesCall.java | 80 +-
.../ignite/internal/cli/commands/Options.java | 12 +-
.../partitions/reset/ResetPartitionsMixin.java | 10 -
.../partitions/restart/RestartPartitionsMixin.java | 12 +-
.../internal/cli/commands/sql/SqlCommand.java | 54 +-
.../internal/cli/commands/sql/SqlExecCommand.java | 7 +-
.../cli/commands/sql/SqlExecReplCommand.java | 7 +-
.../internal/cli/commands/sql/SqlReplCommand.java | 53 +-
.../cli/decorators/SqlQueryResultDecorator.java | 8 +-
.../apache/ignite/internal/cli/sql/SqlManager.java | 2 +
.../ignite/internal/cli/sql/SqlQueryResult.java | 37 +-
.../internal/cli/commands/ProfileMixinTest.java | 4 +-
.../partitions/restart/RestartPartitionsTest.java | 10 +-
.../internal/cli/commands/sql/SqlCommandTest.java | 12 +
.../table/MutableTupleBinaryTupleAdapter.java | 169 ++-
.../client/handler/ItClientHandlerMetricsTest.java | 2 +-
.../ignite/client/handler/ItClientHandlerTest.java | 19 +-
.../apache/ignite/client/handler/TestServer.java | 5 +-
.../ignite/client/handler/ClientHandlerModule.java | 24 +-
.../handler/ClientInboundMessageHandler.java | 39 +-
.../handler/ClientPrimaryReplicaTracker.java | 25 +-
.../client/handler/DdlBatchingSuggester.java | 72 ++
.../requests/sql/ClientSqlExecuteRequest.java | 9 +-
.../handler/ClientPrimaryReplicaTrackerTest.java | 4 +-
.../client/handler/DdlBatchingSuggesterTest.java | 62 +
.../requests/table/ClientHandlerTupleTests.java | 50 +
.../ignite/client/handler/FakePlacementDriver.java | 21 +-
modules/client/DEVNOTES.md | 111 ++
modules/client/build.gradle | 1 +
.../ignite/internal/client/ClientFutureUtils.java | 28 +-
.../ignite/internal/client/ReliableChannel.java | 4 +-
.../ignite/internal/client/TcpClientChannel.java | 17 +-
.../client/io/ClientConnectionStateHandler.java | 2 +-
.../client/io/netty/NettyClientConnection.java | 3 +-
.../client/io/netty/NettyClientMessageHandler.java | 16 +-
.../org/apache/ignite/client/ClientTupleTest.java | 28 +
.../org/apache/ignite/client/ConnectionTest.java | 24 +
.../org/apache/ignite/client/ReconnectTest.java | 30 +-
.../ignite/client/TestClientHandlerModule.java | 7 +-
.../java/org/apache/ignite/client/TestServer.java | 41 +-
.../apache/ignite/client/fakes/FakeTxManager.java | 12 +
.../internal/client/ClientFutureUtilsTest.java | 40 +
.../internal/client/sql/ClientSqlRowTest.java | 100 ++
.../management/topology/ItLogicalTopologyTest.java | 6 +
...ItMetastorageRaftSnapshotCompatibilityTest.java | 5 +-
.../ignite/internal/OpenApiCompatibilityTest.java | 31 +-
.../org/apache/ignite/internal/OpenApiMatcher.java | 22 +-
...SequentialDdlExecutionConfigurationSchema.java} | 14 +-
...stionsClusterExtensionConfigurationSchema.java} | 12 +-
.../SuggestionsConfigurationSchema.java} | 10 +-
...SuggestionsDistributedConfigurationModule.java} | 8 +-
.../components/SystemPropertiesNodeProperties.java | 35 -
.../internal/future/timeout/TimeoutObject.java | 4 +-
.../apache/ignite/internal/type/NativeTypes.java | 12 +-
.../org/apache/ignite/internal/util/Constants.java | 3 +
...teringIterator.java => FlatteningIterator.java} | 74 +-
.../apache/ignite/internal/util/IgniteUtils.java | 24 +
.../ignite/internal/util}/LongPriorityQueue.java | 4 +-
.../internal/util/SafeTimeValuesTracker.java | 2 +
.../internal/future/timeout/TimeoutWorkerTest.java | 29 +-
.../internal/util/FlatteningIteratorTest.java | 225 ++++
.../internal/util}/LongPriorityQueueSelfTest.java | 2 +-
.../util/PendingComparableValuesTrackerTest.java | 87 +-
.../PendingComparableValuesTrackerTestBase.java | 88 ++
.../internal/util/SafeTimeValuesTrackerTest.java | 86 ++
.../ItRebalanceByPendingAssignmentsQueueTest.java | 9 +-
.../rebalance/ItRebalanceDistributedTest.java | 12 +-
.../internal/rebalance/ItRebalanceMetricsTest.java | 2 -
.../distributionzones/DataNodesManager.java | 20 +-
.../distributionzones/DistributionZoneManager.java | 19 +-
...ibutionZoneManagerConfigurationChangesTest.java | 15 -
...istributionZoneManagerScaleUpScaleDownTest.java | 66 --
.../internal/network/file/TestTopologyService.java | 9 +-
.../index/ItIndexBuildCompletenessTest.java | 73 +-
.../ignite/internal/index/ItIndexRecoveryTest.java | 12 +-
.../index/ChangeIndexStatusTaskController.java | 2 +-
.../internal/index/IndexBuildingManager.java | 2 +-
.../apache/ignite/internal/index/IndexManager.java | 2 +-
.../RetryingFinalTransactionStateResolver.java | 4 +-
.../internal/jdbc/ItJdbcMetadataSelfTest.java | 9 +
.../ignite/jdbc/ItJdbcConnectionFailoverTest.java | 1 -
.../ignite/internal/lowwatermark/LowWatermark.java | 11 +
.../internal/lowwatermark/LowWatermarkImpl.java | 18 +-
.../internal/lowwatermark/TestLowWatermark.java | 5 +
.../server/raft/ItMetaStorageRaftGroupTest.java | 2 +-
.../service/ItAbstractListenerSnapshotTest.java | 2 +-
.../internal/metrics/sources/OsMetricSource.java | 2 +-
...des.java => LogicalTopologyEventsListener.java} | 8 +-
.../ignite/internal/network/TopologyService.java | 7 +-
modules/network/build.gradle | 1 +
.../node/ItNodeStalenessAndRestartTest.java | 39 +-
.../internal/network/DefaultMessagingService.java | 8 +-
.../internal/network/netty/ConnectionManager.java | 3 +-
.../network/recovery/HandshakeManagerUtils.java | 29 +
.../recovery/RecoveryAcceptorHandshakeManager.java | 50 +-
.../RecoveryInitiatorHandshakeManager.java | 32 +-
...s.java => StaleNodeHandlingParametersImpl.java} | 20 +-
.../recovery/message/HandshakeStartMessage.java | 5 +-
.../message/HandshakeStartResponseMessage.java | 5 +-
...ssage.java => StaleNodeHandlingParameters.java} | 12 +-
.../scalecube/ScaleCubeTopologyService.java | 14 +-
.../network/netty/RecoveryHandshakeTest.java | 3 +-
.../RecoveryAcceptorHandshakeManagerTest.java | 4 +-
.../pagememory/persistence/PageCacheMetrics.java} | 16 +-
.../persistence/PersistentPageMemory.java | 66 +-
.../PersistentPageMemoryMetricSource.java | 9 +
.../persistence/PersistentPageMemoryMetrics.java | 98 +-
.../persistence/checkpoint/CheckpointManager.java | 5 +-
.../checkpoint/CheckpointReadWriteLock.java | 63 +-
.../checkpoint/CheckpointReadWriteLockMetrics.java | 120 ++
.../persistence/checkpoint/Checkpointer.java | 4 +-
.../persistence/compaction/CompactionRound.java | 66 ++
.../persistence/compaction/Compactor.java | 232 ++--
.../compaction/DeltaFileForCompaction.java} | 46 +-
.../MeteredPageReplacementPolicyFactory.java | 77 ++
.../checkpoint/CheckpointReadWriteLockTest.java | 6 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 72 +-
.../persistence/compaction/CompactorTest.java | 58 +-
.../replacement/AbstractPageReplacementTest.java | 43 +-
.../checkpoint/CheckpointTestUtils.java | 8 +-
modules/partition-replicator/build.gradle | 1 +
.../ItWriteIntentSwitchRequestHandlerTest.java | 106 ++
.../partition/replicator/fixtures/Node.java | 16 +-
.../ItZonePartitionRaftListenerRecoveryTest.java | 7 +-
.../PartitionReplicaLifecycleManager.java | 329 +++++-
.../partition/replicator/ReplicaPrimacy.java | 7 +-
.../replicator/StartedReplicationGroups.java | 19 +
.../replicator/ZonePartitionReplicaListener.java | 26 +-
.../partition/replicator/ZoneResourcesManager.java | 23 +-
...xStateCommitPartitionReplicaRequestHandler.java | 84 +-
.../handlers/WriteIntentSwitchRequestHandler.java | 26 +-
.../network/PartitionReplicationMessageGroup.java | 22 +-
.../disaster/LocalPartitionStateMessage.java | 1 +
...va => LocalPartitionsEstimatedSizeMessage.java} | 3 +-
...va => LocalPartitionsEstimatedSizeRequest.java} | 3 +-
...a => LocalPartitionsEstimatedSizeResponse.java} | 7 +-
...Message.java => OperationCompletedMessage.java} | 19 +-
.../replicator/raft/ZonePartitionRaftListener.java | 35 +-
.../raft/snapshot/PartitionDataStorage.java | 17 +-
.../replicator/raft/snapshot/PartitionKey.java | 60 +-
.../raft/snapshot/PartitionSnapshotStorage.java | 17 +-
.../replicator/raft/snapshot/ZonePartitionKey.java | 82 --
.../snapshot/incoming/IncomingSnapshotCopier.java | 15 +-
.../incoming/ReplicationLogStorageKey.java | 8 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 15 +-
.../PartitionReplicaLifecycleManagerTest.java | 8 +-
.../raft/ZonePartitionRaftListenerTest.java | 214 +++-
.../PartitionSnapshotStorageFactoryTest.java | 2 +-
.../snapshot/PartitionSnapshotStorageTest.java | 2 +-
.../incoming/IncomingSnapshotCopierTest.java | 6 +-
.../outgoing/OutgoingSnapshotCommonTest.java | 3 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotReaderTest.java | 4 +-
.../outgoing/OutgoingSnapshotStatsTest.java | 4 +-
.../OutgoingSnapshotTxDataStreamingTest.java | 3 +-
.../outgoing/OutgoingSnapshotsManagerTest.java | 6 +-
.../SnapshotAwarePartitionDataStorageTest.java | 27 +-
.../placementdriver/LeasePlacementDriver.java | 1 -
.../placementdriver/BasePlacementDriverTest.java | 25 +-
.../MultiActorPlacementDriverTest.java | 5 +-
.../PlacementDriverManagerTest.java | 13 +-
.../placementdriver/AssignmentsTracker.java | 63 +-
.../placementdriver/PlacementDriverManager.java | 14 +-
.../ignite/internal/placementdriver/Utils.java | 25 +-
.../placementdriver/leases/LeaseTracker.java | 30 +-
.../internal/placementdriver/ActiveActorTest.java | 5 +-
.../placementdriver/AssignmentsTrackerTest.java | 5 +-
.../placementdriver/LeaseNegotiationTest.java | 38 +-
.../internal/placementdriver/LeaseTrackerTest.java | 52 +-
.../internal/placementdriver/LeaseUpdaterTest.java | 33 +-
.../placementdriver/PlacementDriverTest.java | 9 +-
modules/platforms/DEVNOTES.md | 3 +
modules/platforms/build.gradle | 4 +-
modules/platforms/cpp/ignite/common/error_codes.h | 2 +
modules/platforms/cpp/ignite/odbc/common_types.cpp | 2 +
.../Sql/ResultSetBenchmarks.cs | 24 +-
.../Compute/ComputeTests.cs | 25 +-
.../dotnet/Apache.Ignite.Tests.Aot/Sql/SqlTests.cs | 36 +
.../Table/{KeyPoco.cs => IntMapper.cs} | 18 +-
.../Table/PocoAllColumnsSqlNullableMapper.cs | 3 +-
.../CurrentClientWithOldServerCompatibilityTest.cs | 2 +-
.../Apache.Ignite.Tests/Compute/ComputeTests.cs | 5 +
.../Apache.Ignite.Tests/PartitionAwarenessTests.cs | 51 +-
.../Sql/SqlResultSetObjectMappingTests.cs | 80 +-
.../dotnet/Apache.Ignite.Tests/Sql/SqlTests.cs | 4 +-
.../Table/DataStreamerPlatformReceiverTests.cs | 1 +
.../Apache.Ignite.Tests/Table/DataStreamerTests.cs | 1 +
.../Table/PartitionManagerTests.cs | 7 +-
.../Table/RecordViewBinaryTests.cs | 4 +-
.../dotnet/Apache.Ignite.Tests/TestUtils.cs | 3 +
.../Apache.Ignite/ApiCompatibilitySuppressions.xml | 14 +
.../dotnet/Apache.Ignite/Compute/JobTarget.cs | 58 +-
.../platforms/dotnet/Apache.Ignite/ErrorCodes.g.cs | 6 +
.../Apache.Ignite/Internal/ClientFailoverSocket.cs | 7 +-
.../Apache.Ignite/Internal/Compute/Compute.cs | 19 +-
.../Internal/Linq/IgniteQueryExecutor.cs | 3 +-
.../Apache.Ignite/Internal/Linq/ResultSelector.cs | 18 +-
.../Apache.Ignite/Internal/Sql/ColumnMetadata.cs | 3 +-
.../dotnet/Apache.Ignite/Internal/Sql/ResultSet.cs | 35 +-
.../Internal/Sql/ResultSetMetadata.cs | 29 +-
.../dotnet/Apache.Ignite/Internal/Sql/RowReader.cs | 7 +-
.../Apache.Ignite/Internal/Sql/RowReaderFactory.cs | 7 +-
.../dotnet/Apache.Ignite/Internal/Sql/Sql.cs | 59 +-
.../dotnet/Apache.Ignite/Internal/Table/Column.cs | 3 +
.../Internal/Table/PartitionManager.cs | 6 +
.../Table/Serialization/MapperSerializerHandler.cs | 7 +-
modules/platforms/dotnet/Apache.Ignite/Sql/ISql.cs | 18 +
.../Apache.Ignite/Table/IPartitionManager.cs | 13 +-
.../Apache.Ignite/Table/Mapper/IMapperColumn.cs | 21 +
.../dotnet/Apache.Ignite/Table/Mapper/RowReader.cs | 14 +-
.../raft/ReplicationGroupUnavailableException.java | 81 ++
...Service.java => TimeAwareRaftGroupService.java} | 18 +-
...InterruptedRaftSnapshotStorageRecoveryTest.java | 2 +-
.../raftsnapshot/ItParallelRaftSnapshotsTest.java | 2 +-
.../raftsnapshot/ItTableRaftSnapshotsTest.java | 15 +-
.../ignite/raft/server/ItConnectionErrorTest.java | 2 +-
.../raft/server/ItSimpleCounterServerTest.java | 2 +-
.../ignite/raft/server/JraftAbstractTest.java | 2 +-
.../java/org/apache/ignite/internal/raft/Loza.java | 1 +
.../PhysicalTopologyAwareRaftGroupService.java | 80 +-
.../raft/{ => client}/RaftGroupServiceImpl.java | 13 +-
.../internal/raft/{ => client}/RetryContext.java | 4 +-
...ysicalTopologyAwareRaftGroupServiceRunTest.java | 686 +++++++++++
.../PhysicalTopologyAwareRaftGroupServiceTest.java | 1 -
.../raft/{ => client}/RaftGroupServiceTest.java | 6 +-
.../ChangePeersAndLearnersWithRetryTest.java | 2 +-
.../internal/raft/TestRaftGroupListener.java | 0
.../raft/client/TopologyAwareRaftGroupService.java | 1 -
.../ReplicatorRecoverableExceptions.java | 2 +
.../replicator/message/ReplicaMessageUtils.java | 20 +
.../internal/raft/TestRaftGroupListener.java | 1 +
.../rest/api/recovery/DisasterRecoveryApi.java | 79 --
.../api/recovery/GlobalPartitionStateResponse.java | 86 --
.../recovery/GlobalPartitionStatesResponse.java | 46 -
.../api/recovery/LocalPartitionStateResponse.java | 102 --
.../api/recovery/LocalPartitionStatesResponse.java | 46 -
.../rest/api/recovery/ResetPartitionsRequest.java | 79 --
.../api/recovery/RestartPartitionsRequest.java | 91 --
...terRecoveryControllerRestartPartitionsTest.java | 48 +-
...ControllerRestartPartitionsWithCleanupTest.java | 108 +-
.../recovery/ItDisasterRecoveryControllerTest.java | 229 +---
.../rest/recovery/DisasterRecoveryController.java | 178 +--
.../ItTruncateRaftLogAndRestartNodesTest.java | 7 +-
.../internal/benchmark/FutureTimeoutBenchmark.java | 2 +-
...SqlBenchmark.java => SystemViewsBenchmark.java} | 114 +-
.../client/ItClientDataConsistencyTest.java | 6 +
.../runner/app/ItIgniteNodeRestartTest.java | 10 +-
.../internal/runner/app/ItIndexNodeTest.java | 315 +++++
.../app/client/ItThinClientAuthenticationTest.java | 10 +-
.../runner/app/client/ItThinClientComputeTest.java | 8 +-
.../app/client/ItThinClientConnectionTest.java | 3 +-
.../client/ItThinClientDdlQueriesTrackerTest.java | 156 +++
.../schemasync/ItSchemaSyncAndReplicationTest.java | 4 +-
.../streamer/ItAbstractDataStreamerTest.java | 34 +-
.../internal/table/ItColumnNameMappingTest.java | 3 +-
.../table/ItRebalanceWithPartitionReturnTest.java | 14 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 40 +-
.../internal/app/LowWatermarkRectifier.java} | 51 +-
.../apache/ignite/internal/ConfigOverrideTest.java | 14 +-
.../compatibility/framework/ConfigNode.java | 2 +-
.../framework/ConfigurationTreeComparator.java | 2 +-
.../framework/ConfigurationTreeScanner.java | 2 +-
.../configuration/ignite-snapshot.bin | Bin 5679 -> 5653 bytes
.../java/org/apache/ignite/internal/Cluster.java | 12 +-
.../ignite/internal/ClusterConfiguration.java | 22 +-
.../internal/ClusterPerClassIntegrationTest.java | 16 +-
.../internal/ClusterPerTestIntegrationTest.java | 20 +-
.../org/apache/ignite/internal/ConfigOverride.java | 2 +
.../ignite/internal/schema/SchemaTestUtils.java | 32 +
.../engine/api/expressions/EvaluationContext.java} | 30 +-
.../api/expressions/EvaluationContextBuilder.java} | 25 +-
.../ExpressionEvaluationException.java} | 15 +-
.../engine/api/expressions/ExpressionFactory.java | 106 ++
.../expressions/ExpressionParsingException.java} | 12 +-
.../ExpressionValidationException.java} | 20 +-
.../engine/api/expressions/IgnitePredicate.java} | 28 +-
.../sql/engine/api/expressions}/RowAccessor.java | 2 +-
.../sql/engine/api/expressions}/RowFactory.java | 2 +-
.../engine/api/expressions}/RowFactoryFactory.java | 2 +-
.../ItSqlConcurrentSchemaModificationTest.java | 126 ++
.../engine/datatypes/ItDateTimeCastFormatTest.java | 2 +-
.../systemviews/ItTransactionsSystemViewTest.java | 37 +
.../aggregate/group/test_group_by_distinct.test | 16 +-
.../sql/group1/function/generic/test_coalesce.test | 15 +
.../function/generic/test_coalesce.test_ignore | 15 -
.../sql/group1/function/generic/test_decode.test | 8 +-
.../function/generic/test_decode.test_ignore | 20 -
.../sql/group1/set/test_basic_union.test | 12 +
.../internal/lang/SqlExceptionMapperUtil.java | 4 +
.../internal/sql/api/AsyncResultSetImpl.java | 53 +-
.../internal/sql/engine/SqlOperationContext.java | 37 +-
.../engine/SqlPlanToTxSchemaVersionValidator.java | 91 ++
.../internal/sql/engine/SqlQueryProcessor.java | 23 +-
.../sql/engine/exec/DynamicPartitionProvider.java | 6 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 28 +-
.../internal/sql/engine/exec/ExecutionContext.java | 15 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 132 ++-
.../sql/engine/exec/LogicalRelImplementor.java | 5 +-
.../exec/ProjectedTableRowConverterImpl.java | 1 +
.../internal/sql/engine/exec/RowHandler.java | 1 +
.../internal/sql/engine/exec/ScannableTable.java | 1 +
.../sql/engine/exec/ScannableTableImpl.java | 1 +
.../sql/engine/exec/SqlEvaluationContext.java | 3 +
.../sql/engine/exec/SqlPlanOutdatedException.java} | 23 +-
.../internal/sql/engine/exec/SqlRowHandler.java | 6 +-
.../sql/engine/exec/TableRowConverter.java | 1 +
.../sql/engine/exec/TableRowConverterImpl.java | 1 +
.../sql/engine/exec/UpdatableTableImpl.java | 1 +
.../internal/sql/engine/exec/exp/CodegenUtils.java | 52 +
.../sql/engine/exec/exp/ComparatorImplementor.java | 2 +-
.../engine/exec/exp/JoinPredicateImplementor.java | 16 +-
.../engine/exec/exp/JoinProjectionImplementor.java | 18 +-
.../sql/engine/exec/exp/PredicateImplementor.java | 16 +-
.../sql/engine/exec/exp/ProjectionImplementor.java | 18 +-
.../engine/exec/exp/RowProviderImplementor.java | 18 +-
.../sql/engine/exec/exp/ScalarImplementor.java | 14 +-
...ssionFactory.java => SqlExpressionFactory.java} | 2 +-
...toryImpl.java => SqlExpressionFactoryImpl.java} | 4 +-
.../engine/exec/exp/agg/AccumulatorsFactory.java | 2 +-
.../exec/exp/func/SystemRangeTableFunction.java | 4 +-
.../exec/exp/func/TableFunctionRegistryImpl.java | 6 +-
.../exec/fsm/CursorPublicationPhaseHandler.java | 10 +-
.../engine/exec/fsm/OptimizingPhaseHandler.java | 40 +-
.../internal/sql/engine/exec/fsm/Program.java | 6 +-
.../sql/engine/exec/fsm/QueryExecutionProgram.java | 45 +-
.../internal/sql/engine/exec/rel/AbstractNode.java | 9 +-
.../sql/engine/exec/rel/AbstractSetOpNode.java | 2 +-
.../exec/rel/CorrelatedNestedLoopJoinNode.java | 2 +-
.../sql/engine/exec/rel/DataSourceScanNode.java | 2 +-
.../sql/engine/exec/rel/HashAggregateNode.java | 2 +-
.../internal/sql/engine/exec/rel/HashJoinNode.java | 2 +-
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 2 +-
.../sql/engine/exec/rel/IndexScanNode.java | 2 +-
.../sql/engine/exec/rel/IntersectNode.java | 2 +-
.../sql/engine/exec/rel/MergeJoinNode.java | 2 +-
.../internal/sql/engine/exec/rel/MinusNode.java | 2 +-
.../internal/sql/engine/exec/rel/ModifyNode.java | 4 +-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 2 +-
.../sql/engine/exec/rel/SortAggregateNode.java | 2 +-
.../sql/engine/exec/rel/TableScanNode.java | 2 +-
.../sql/engine/expressions/RowBasedScope.java} | 18 +-
.../sql/engine/expressions/RowFieldNamespace.java | 136 +++
.../sql/engine/expressions/RowNamespace.java | 143 +++
.../expressions/SqlExpressionFactoryAdapter.java | 322 ++++++
.../expressions/ToInternalGenericAdapter.java | 84 ++
.../engine/prepare/IgniteSqlToRelConvertor.java | 25 +
.../sql/engine/prepare/KeyValueGetPlan.java | 9 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../internal/sql/engine/prepare/QueryPlan.java | 9 +-
.../sql/engine/prepare/SelectCountPlan.java | 2 +-
.../ddl/ClusterWideNodeFilterValidator.java | 2 +-
.../engine/prepare/ddl/NodeFilterValidator.java | 2 +-
.../prepare/pruning/PartitionPruningPredicate.java | 4 +-
.../rule/logical/IgniteSubQueryRemoveRule.java | 998 ----------------
.../internal/sql/engine/sql/IgniteSqlParser.java | 19 +-
.../engine/statistic/SqlStatisticManagerImpl.java | 2 +-
.../sql/engine/type/IgniteTypeFactory.java | 4 +-
.../internal/sql/engine/type/IgniteTypeSystem.java | 5 +
.../ignite/internal/sql/engine/util/Commons.java | 4 +-
.../internal/sql/engine/util/IgniteMethod.java | 4 +-
.../ignite/internal/sql/engine/util/TypeUtils.java | 29 +-
.../sql/engine/util/format/ParsedFields.java | 2 +-
.../apache/ignite/internal/sql/api/SqlRowTest.java | 100 ++
.../sql/engine/exec/DummyScannableTable.java | 1 +
.../sql/engine/exec/ExecutionServiceImplTest.java | 8 +-
.../exec/IdentityDistributionFunctionSelfTest.java | 3 +-
.../sql/engine/exec/PartitionsResolutionTest.java | 3 +-
.../exec/ProjectedTableRowConverterSelfTest.java | 3 +-
.../internal/sql/engine/exec/QueryTimeoutTest.java | 12 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../sql/engine/exec/SqlOutdatedPlanTest.java | 255 ++++
.../sql/engine/exec/TableRowConverterSelfTest.java | 7 +-
...Test.java => SqlExpressionFactoryImplTest.java} | 10 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 6 +-
.../engine/exec/rel/AbstractJoinExecutionTest.java | 2 +-
.../exec/rel/AbstractSetOpExecutionTest.java | 2 +-
.../sql/engine/exec/rel/AsyncRootNodeTest.java | 6 +-
.../sql/engine/exec/rel/BaseAggregateTest.java | 6 +-
.../rel/CorrelatedNestedLoopJoinExecutionTest.java | 2 +-
.../exec/rel/DataSourceScanNodeExecutionTest.java | 12 +-
.../sql/engine/exec/rel/ExchangeExecutionTest.java | 4 +-
.../sql/engine/exec/rel/ExecutionTest.java | 2 +-
.../sql/engine/exec/rel/FilterExecutionTest.java | 2 +-
.../exec/rel/HashAggregateExecutionTest.java | 2 +-
.../rel/HashAggregateSingleGroupExecutionTest.java | 4 +-
.../exec/rel/HashIndexSpoolExecutionTest.java | 2 +-
.../exec/rel/IndexScanNodeExecutionTest.java | 10 +-
.../engine/exec/rel/IntersectExecutionTest.java | 6 +-
.../sql/engine/exec/rel/LimitExecutionTest.java | 2 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 6 +-
.../sql/engine/exec/rel/MinusExecutionTest.java | 4 +-
.../engine/exec/rel/ModifyNodeExecutionTest.java | 20 +-
.../sql/engine/exec/rel/ScanNodeExecutionTest.java | 2 +-
.../engine/exec/rel/ScannableTableSelfTest.java | 2 +-
.../exec/rel/SortAggregateExecutionTest.java | 2 +-
.../exec/rel/SortedIndexSpoolExecutionTest.java | 2 +-
.../exec/rel/SystemRangeTableFunctionTest.java | 2 +-
.../exec/rel/TableScanNodeExecutionTest.java | 6 +-
.../engine/exec/rel/TableSpoolExecutionTest.java | 2 +-
.../sql/engine/exec/row/SqlRowHandlerTest.java | 16 +-
.../expressions/AbstractExpressionFactoryTest.java | 64 ++
.../engine/expressions/IgnitePredicateTest.java | 1214 ++++++++++++++++++++
.../sql/engine/framework/ArrayRowHandler.java | 6 +-
.../engine/framework/ClusterServiceFactory.java | 9 +-
.../sql/engine/framework/TestBuilders.java | 61 +-
.../sql/engine/framework/TestClusterTest.java | 2 +-
.../internal/sql/engine/framework/TestNode.java | 30 +-
.../planner/AbstractTpcQueryPlannerTest.java | 80 +-
.../sql/engine/planner/DynamicParametersTest.java | 1 -
.../sql/engine/planner/TpcdsQueryPlannerTest.java | 59 +-
.../sql/engine/planner/TpchQueryPlannerTest.java | 28 +-
.../planner/datatypes/BaseTypeCoercionTest.java | 2 +-
.../pruning/PartitionPruningPredicateSelfTest.java | 6 +-
.../sql/engine/type/IgniteTypeFactorySelfTest.java | 2 +-
.../internal/sql/engine/util/TypeUtilsTest.java | 6 +-
.../src/test/resources/tpcds/plan/q13.plan | 6 +-
.../src/test/resources/tpcds/plan/q14.plan | 441 +++----
.../src/test/resources/tpcds/plan/q34.plan | 2 +-
.../src/test/resources/tpcds/plan/q41.plan | 2 +-
.../src/test/resources/tpcds/plan/q5.plan | 99 +-
.../src/test/resources/tpcds/plan/q71.plan | 2 +-
.../src/test/resources/tpcds/plan/q73.plan | 2 +-
.../src/test/resources/tpcds/plan/q76.plan | 53 +-
.../src/test/resources/tpcds/plan/q77.plan | 117 +-
.../src/test/resources/tpcds/plan/q80.plan | 111 +-
.../src/test/resources/tpcds/plan/q85.plan | 6 +-
.../src/test/resources/tpch/plan/q12.plan | 2 +-
.../src/test/resources/tpch/plan/q7.plan | 4 +-
.../src/test/resources/tpch/plan/variant_q12.plan | 2 +-
.../internal/systemview/SystemViewManagerImpl.java | 261 ++++-
.../ItInternalTableReadWriteScanTest.java | 93 --
...xDistributedTestSingleNodeNoCleanupMessage.java | 18 +-
.../ItTxObservableTimePropagationTest.java | 18 +-
.../partition/ItPartitionDestructionTest.java | 291 ++++-
...bstractHighAvailablePartitionsRecoveryTest.java | 7 +-
.../internal/table/AbstractRowTupleAdapter.java | 85 +-
.../internal/table/distributed/TableManager.java | 125 +-
.../disaster/DisasterRecoveryManager.java | 884 +++-----------
.../disaster/DisasterRecoverySystemViews.java | 77 --
.../disaster/GlobalTablePartitionState.java | 61 -
.../distributed/disaster/GroupUpdateRequest.java | 29 +-
.../disaster/GroupUpdateRequestHandler.java | 321 ++----
.../disaster/GroupUpdateRequestSerializer.java | 15 +-
.../disaster/LocalTablePartitionState.java | 67 --
.../disaster/LocalTablePartitionStateByNode.java | 54 -
.../disaster/ManualGroupRestartRequest.java | 37 +-
.../ManualGroupRestartRequestSerializer.java | 26 +-
....java => MultiNodeDisasterRecoveryRequest.java} | 21 +-
.../distributed/disaster/MultiNodeOperations.java | 76 ++
...tFoundException.java => NodeLeftException.java} | 14 +-
...xception.java => RemoteOperationException.java} | 18 +-
.../distributed/raft/TablePartitionProcessor.java | 63 +-
.../raft/handlers/BuildIndexCommandHandler.java | 6 +
.../MinimumActiveTxTimeCommandHandler.java | 2 +
.../SnapshotAwarePartitionDataStorage.java | 24 +-
.../raft/snapshot/TablePartitionKey.java | 84 --
.../replicator/PartitionReplicaListener.java | 105 +-
.../distributed/storage/InternalTableImpl.java | 2 -
.../internal/table/MutableRowTupleAdapterTest.java | 121 ++
.../distributed/TableManagerRecoveryTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 6 -
.../DisasterRecoveryRequestSerializerTest.java | 74 +-
.../raft/PartitionCommandListenerTest.java | 188 ++-
.../PartitionReplicaListenerIndexLockingTest.java | 11 +-
...itionReplicaListenerSortedIndexLockingTest.java | 11 +-
.../replication/PartitionReplicaListenerTest.java | 148 ++-
.../ZonePartitionReplicaListenerTest.java | 34 +-
.../storage/InternalTableEstimatedSizeTest.java | 28 +-
.../distributed/storage/InternalTableImplTest.java | 440 ++++++-
.../apache/ignite/distributed/ItTxTestCluster.java | 23 +-
.../distributed/TestPartitionDataStorage.java | 10 -
.../ignite/internal/table/TxAbstractTest.java | 3 +-
.../internal/table/TxInfrastructureTest.java | 17 +-
.../disaster/TestDisasterRecoveryUtils.java | 66 +-
.../table/impl/DummyInternalTableImpl.java | 17 +-
.../disaster/ItDisasterRecoveryManagerTest.java | 132 +--
.../ItDisasterRecoveryReconfigurationTest.java | 88 +-
.../ItDisasterRecoveryResetPartitionsTest.java | 15 +-
.../disaster/ItDisasterRecoverySystemViewTest.java | 236 ----
...RecoveryZonePartitionsStatesSystemViewTest.java | 3 -
...riteIntentResolutionWhenPrimaryExpiredTest.java | 198 ++++
.../tx/distributed/ItTxResourcesVacuumTest.java | 5 -
.../org/apache/ignite/internal/tx/TxManager.java | 6 +
.../org/apache/ignite/internal/tx/TxStateMeta.java | 6 +-
.../ignite/internal/tx/TxStateMetaAbandoned.java | 12 +-
.../tx/impl}/TransactionStateResolver.java | 153 ++-
.../internal/tx/impl/TxCleanupRequestSender.java | 12 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 32 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 18 +-
.../tx/message/TxStateCommitPartitionRequest.java | 21 +
.../tx/message/TxStateCoordinatorRequest.java | 18 +
.../tx/message/TxStateMetaAbandonedMessage.java | 1 +
.../tx/views/TransactionsViewProvider.java | 12 +-
.../tx/impl}/TransactionStateResolverTest.java | 100 +-
.../ignite/tests/docker/ItDockerConfigTest.java | 2 +-
524 files changed, 13336 insertions(+), 7680 deletions(-)
create mode 100644 .claude/skills/ignite-cluster-setup/SKILL.md
create mode 100644 .justfile
create mode 100644 CLAUDE.md
delete mode 100644
migration-tools/modules/migration-tools-commons-tests/src/main/java/org/apache/ignite/migrationtools/handlers/SkipUnsupportedOperationsHandlers.java
create mode 100644
modules/catalog-compaction/src/integrationTest/java/org/apache/ignite/internal/catalog/compaction/ItNodeRecoveryAfterCatalogTruncatedAboveStoredLwmTest.java
create mode 100644
modules/cli/src/integrationTest/java/org/apache/ignite/internal/cli/commands/sql/ItSqlTimedOptionTest.java
create mode 100644
modules/client-handler/src/main/java/org/apache/ignite/client/handler/DdlBatchingSuggester.java
create mode 100644
modules/client-handler/src/test/java/org/apache/ignite/client/handler/DdlBatchingSuggesterTest.java
create mode 100644 modules/client/DEVNOTES.md
create mode 100644
modules/client/src/test/java/org/apache/ignite/internal/client/sql/ClientSqlRowTest.java
copy
modules/{rest/src/test/java/org/apache/ignite/internal/rest/configuration/TestSubSensitiveConfigurationSchema.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SequentialDdlExecutionConfigurationSchema.java}
(78%)
copy
modules/configuration-system/src/main/java/org/apache/ignite/internal/configuration/{SystemDistributedExtensionConfigurationSchema.java
=> SuggestionsClusterExtensionConfigurationSchema.java} (77%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/StatisticsConfigurationSchema.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SuggestionsConfigurationSchema.java}
(77%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/configuration/distributed/SqlClusterConfigurationModule.java
=>
configuration-system/src/main/java/org/apache/ignite/internal/configuration/SuggestionsDistributedConfigurationModule.java}
(81%)
delete mode 100644
modules/core/src/main/java/org/apache/ignite/internal/components/SystemPropertiesNodeProperties.java
copy
modules/core/src/main/java/org/apache/ignite/internal/util/{FilteringIterator.java
=> FlatteningIterator.java} (52%)
rename modules/{table/src/main/java/org/apache/ignite/internal/table =>
core/src/main/java/org/apache/ignite/internal/util}/LongPriorityQueue.java (95%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/FlatteningIteratorTest.java
rename modules/{table/src/test/java/org/apache/ignite/internal/table =>
core/src/test/java/org/apache/ignite/internal/util}/LongPriorityQueueSelfTest.java
(99%)
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/PendingComparableValuesTrackerTestBase.java
create mode 100644
modules/core/src/test/java/org/apache/ignite/internal/util/SafeTimeValuesTrackerTest.java
rename
modules/network-api/src/main/java/org/apache/ignite/internal/network/{JoinedNodes.java
=> LogicalTopologyEventsListener.java} (79%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/{InMemoryStaleIds.java
=> StaleNodeHandlingParametersImpl.java} (59%)
copy
modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/{InternalMessage.java
=> StaleNodeHandlingParameters.java} (76%)
copy
modules/{metrics/src/main/java/org/apache/ignite/internal/metrics/exporters/configuration/JmxExporterConfigurationSchema.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/PageCacheMetrics.java}
(70%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/checkpoint/CheckpointReadWriteLockMetrics.java
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction/CompactionRound.java
copy
modules/{cli/src/main/java/org/apache/ignite/internal/cli/core/call/CallOutput.java
=>
page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/compaction/DeltaFileForCompaction.java}
(51%)
create mode 100644
modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/replacement/MeteredPageReplacementPolicyFactory.java
create mode 100644
modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItWriteIntentSwitchRequestHandlerTest.java
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateMessage.java
=> LocalPartitionsEstimatedSizeMessage.java} (94%)
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateRequest.java
=> LocalPartitionsEstimatedSizeRequest.java} (94%)
rename
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{LocalTablePartitionStateResponse.java
=> LocalPartitionsEstimatedSizeResponse.java} (85%)
copy
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/network/disaster/{DisasterRecoveryResponseMessage.java
=> OperationCompletedMessage.java} (70%)
delete mode 100644
modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/raft/snapshot/ZonePartitionKey.java
create mode 100644 modules/platforms/DEVNOTES.md
copy modules/platforms/dotnet/Apache.Ignite.Tests.Common/Table/{KeyPoco.cs =>
IntMapper.cs} (74%)
create mode 100644
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/ReplicationGroupUnavailableException.java
copy
modules/raft-api/src/main/java/org/apache/ignite/internal/raft/service/{RaftGroupService.java
=> TimeAwareRaftGroupService.java} (93%)
rename modules/{replicator =>
raft}/src/main/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupService.java
(90%)
rename modules/raft/src/main/java/org/apache/ignite/internal/raft/{ =>
client}/RaftGroupServiceImpl.java (98%)
rename modules/raft/src/main/java/org/apache/ignite/internal/raft/{ =>
client}/RetryContext.java (98%)
create mode 100644
modules/raft/src/test/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupServiceRunTest.java
rename modules/{replicator =>
raft}/src/test/java/org/apache/ignite/internal/raft/client/PhysicalTopologyAwareRaftGroupServiceTest.java
(99%)
rename modules/raft/src/test/java/org/apache/ignite/internal/raft/{ =>
client}/RaftGroupServiceTest.java (99%)
copy modules/{replicator =>
raft}/src/testFixtures/java/org/apache/ignite/internal/raft/TestRaftGroupListener.java
(100%)
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStateResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/GlobalPartitionStatesResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/LocalPartitionStateResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/LocalPartitionStatesResponse.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/ResetPartitionsRequest.java
delete mode 100644
modules/rest-api/src/main/java/org/apache/ignite/internal/rest/api/recovery/RestartPartitionsRequest.java
copy
modules/runner/src/integrationTest/java/org/apache/ignite/internal/benchmark/{SqlBenchmark.java
=> SystemViewsBenchmark.java} (52%)
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/ItIndexNodeTest.java
create mode 100644
modules/runner/src/integrationTest/java/org/apache/ignite/internal/runner/app/client/ItThinClientDdlQueriesTrackerTest.java
copy
modules/{raft/src/main/java/org/apache/ignite/internal/raft/storage/impl/LocalLogStorageFactory.java
=>
runner/src/main/java/org/apache/ignite/internal/app/LowWatermarkRectifier.java}
(52%)
copy modules/{api/src/main/java/org/apache/ignite/table/criteria/Operator.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/EvaluationContext.java}
(69%)
copy
modules/{core/src/testFixtures/java/org/apache/ignite/internal/TestHybridClock.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/EvaluationContextBuilder.java}
(56%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/ColocationMappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionEvaluationException.java}
(65%)
create mode 100644
modules/sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionFactory.java
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/MappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionParsingException.java}
(70%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/mapping/ColocationMappingException.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/ExpressionValidationException.java}
(53%)
copy
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/SqlPredicate.java
=>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions/IgnitePredicate.java}
(60%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowAccessor.java
(95%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowFactory.java
(98%)
rename
modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec =>
sql-engine-api/src/main/java/org/apache/ignite/internal/sql/engine/api/expressions}/RowFactoryFactory.java
(96%)
create mode 100644
modules/sql-engine/src/integrationTest/java/org/apache/ignite/internal/sql/engine/ItSqlConcurrentSchemaModificationTest.java
delete mode 100644
modules/sql-engine/src/integrationTest/sql/group1/function/generic/test_coalesce.test_ignore
delete mode 100644
modules/sql-engine/src/integrationTest/sql/group1/function/generic/test_decode.test_ignore
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/SqlPlanToTxSchemaVersionValidator.java
copy
modules/sql-engine/src/{test/java/org/apache/ignite/internal/sql/engine/framework/NoOpTransactionalOperationTracker.java
=>
main/java/org/apache/ignite/internal/sql/engine/exec/SqlPlanOutdatedException.java}
(59%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/CodegenUtils.java
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactory.java
=> SqlExpressionFactory.java} (99%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactoryImpl.java
=> SqlExpressionFactoryImpl.java} (98%)
copy
modules/{raft/src/test/java/org/apache/ignite/raft/jraft/entity/codec/v1/LogEntryV1CodecFactoryTest.java
=>
sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowBasedScope.java}
(69%)
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowFieldNamespace.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/RowNamespace.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/SqlExpressionFactoryAdapter.java
create mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/expressions/ToInternalGenericAdapter.java
delete mode 100644
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/rule/logical/IgniteSubQueryRemoveRule.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/api/SqlRowTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/SqlOutdatedPlanTest.java
rename
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/exp/{ExpressionFactoryImplTest.java
=> SqlExpressionFactoryImplTest.java} (99%)
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/expressions/AbstractExpressionFactoryTest.java
create mode 100644
modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/expressions/IgnitePredicateTest.java
delete mode 100644
modules/table/src/integrationTest/java/org/apache/ignite/distributed/ItInternalTableReadWriteScanTest.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/GlobalTablePartitionState.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalTablePartitionState.java
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/LocalTablePartitionStateByNode.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/{GlobalPartitionStateEnum.java
=> MultiNodeDisasterRecoveryRequest.java} (58%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/MultiNodeOperations.java
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/{NodesNotFoundException.java
=> NodeLeftException.java} (73%)
copy
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/disaster/exceptions/{NodesNotFoundException.java
=> RemoteOperationException.java} (61%)
delete mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/snapshot/TablePartitionKey.java
delete mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/internal/disaster/ItDisasterRecoverySystemViewTest.java
create mode 100644
modules/transactions/src/integrationTest/java/org/apache/ignite/tx/distributed/ItTxAbortOnCoordinatorOnWriteIntentResolutionWhenPrimaryExpiredTest.java
rename
modules/{table/src/main/java/org/apache/ignite/internal/table/distributed/replicator
=>
transactions/src/main/java/org/apache/ignite/internal/tx/impl}/TransactionStateResolver.java
(71%)
rename
modules/{table/src/test/java/org/apache/ignite/internal/table/distributed/replicator
=>
transactions/src/test/java/org/apache/ignite/internal/tx/impl}/TransactionStateResolverTest.java
(76%)
