You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by am...@apache.org on 2023/05/03 12:01:37 UTC
[ignite-3] branch ignite-19272 updated (761e0d4a35 -> 9906307920)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-19272
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
omit 761e0d4a35 Styles.
omit 3e135b9e35 minor.
omit 09e4354796 minor.
omit 75adfea08e minor.
omit 524a2e0e77 fix tests.
omit 7737f9d21d wip.
omit dfe2aa44b9 wip.
add 213e70d2be IGNITE-19139 Fix flaky ItDeployUndeployCallsTest (#1987)
add d873ebabc6 IGNITE-18712 Do not allow a node excluded from Physical Topology to enter the topology again (#1978)
add d5bafb5570 IGNITE-19387 Fix deployment tests (#2002)
add f4a18168d5 IGNITE-19375 Sql. Jdbc tests for commit/rollback with autocommit flag = true (#1999)
add aa1cf84221 IGNITE-19320 NPE on JDBC connection close. (#1996)
add 4007b06bfe IGNITE-19298 .NET: Fix MetricsTests.TestRequestsActive flakiness (#2005)
add a31b701bb7 IGNITE-19302 Phantom reads fixed (#1992)
add 9b1bba3e14 IGNITE-18839 HybridTimestamp and its usages refactored to use 8-bytes representation (#1693)
add 4252002fb5 IGNITE-18711 Leave logical topology gracefully when stopping Ignite node (#2001)
add c454736a3b IGNITE-19290 Removing garbage from the partition, taking into account the safe time (#1952)
add 116c95b74e IGNITE-19269 Implemented methods to explicitly lock rows in MV storage. (#1976)
add 096ce4db2a IGNITE-18917 SQL tests with UUID (#2010)
add d11c50bc48 IGNITE-19371 Sql. Prevent the user from using the TIME(STAMP)_WITH_LOCAL_TIME_ZONE types (#1990)
add b5cba2ab5b IGNITE-15580: Calcite. Correlated ANY/ALL subqueries fails. (#2012)
add d1a175389e IGNITE-18872 Sql. Make IgniteTypeFactory a singletone (#2009)
add 6c8aaf1c0d IGNITE-15623 Sql. Reject erroneous datetime literal (#1997)
add 9a0241a8e5 IGNITE-19390 Handling lease deny message in placement driver side (#2003)
add 1442280dac IGNITE-19128 Sql. IgniteIndexScan should use correct searchBounds for custom data types (#1981)
add 482be6f528 IGNITE-18761 Sql. TypeOf can short-circuit only when its argument is a constant expression (#2000)
add 58acf15bee IGNITE-19296 Unmute PicocliBugTest (#2007)
add 4195bf80f7 Improve logging.
add 1407934293 Forbid sending exception to the remote node.
add 9906307920 Minor after review.
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 (761e0d4a35)
\
N -- N -- N refs/heads/ignite-19272 (9906307920)
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:
build.gradle | 5 +
gradle/libs.versions.toml | 6 +-
.../org/apache/ignite/network/ClusterNode.java | 5 +-
.../cli/call/unit/ItDeployUndeployCallsTest.java | 35 ++-
.../cli/commands/unit/ItDeploymentUnitTest.java | 48 ++-
.../internal/rest/ItGeneratedRestClientTest.java | 3 +-
.../commands/sql/SqlReplTopLevelCliCommand.java | 2 -
.../cli/commands/version/VersionCommand.java | 2 -
.../internal/cli/commands/CliCommandTestBase.java | 14 +-
.../{PicocliBugTest.java => ReuseCommandTest.java} | 22 +-
.../client/handler/JdbcQueryEventHandlerImpl.java | 4 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 9 +
.../management/ClusterManagementGroupManager.java | 30 +-
.../apache/ignite/internal/hlc/HybridClock.java | 7 +
.../ignite/internal/hlc/HybridClockImpl.java | 63 ++--
.../ignite/internal/hlc/HybridTimestamp.java | 120 ++++---
.../apache/ignite/internal/TestHybridClock.java | 61 ++--
.../internal/testframework/IgniteTestUtils.java | 8 +-
.../apache/ignite/jdbc/ItJdbcTransactionTest.java | 27 ++
.../impl/ItMetaStorageMultipleNodesTest.java | 33 --
.../command/HybridTimestampMessage.java | 41 ---
.../command/MetaStorageWriteCommand.java | 26 +-
.../metastorage/command/SyncTimeCommand.java | 10 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 27 +-
.../server/raft/MetaStorageWriteHandler.java | 16 +-
.../metastorage/server/time/ClusterTime.java | 5 +
.../metastorage/server/time/ClusterTimeImpl.java | 5 +
modules/network/build.gradle | 1 +
.../network/netty/ItConnectionManagerTest.java | 4 +-
.../scalecube/ItScaleCubeNetworkMessagingTest.java | 100 +++++-
.../internal/network/NetworkMessageTypes.java | 14 +-
.../internal/network/netty/ConnectionManager.java | 24 +-
.../netty/DefaultRecoveryDescriptorProvider.java | 2 +-
.../internal/network/netty/HandshakeHandler.java | 8 +-
.../internal/network/recovery/FailureHandler.java} | 25 +-
.../network/recovery/InMemoryStaleIds.java} | 22 +-
.../recovery/RecoveryClientHandshakeManager.java | 56 +++-
.../recovery/RecoveryServerHandshakeManager.java | 60 +++-
.../network/recovery/StaleIdDetector.java} | 24 +-
.../internal/network/recovery/StaleIds.java} | 14 +-
.../internal/network/recovery/VaultStateIds.java | 104 ++++++
...hMessage.java => HandshakeRejectedMessage.java} | 18 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 23 +-
.../network/netty/RecoveryHandshakeTest.java | 98 +++++-
.../network/recovery/VaultStateIdsTest.java | 124 ++++++++
.../network/DefaultMessagingServiceTest.java | 25 +-
.../internal/network/recovery/AllIdsAreFresh.java} | 11 +-
.../internal/network/recovery/AllIdsAreStale.java} | 11 +-
.../TestScaleCubeClusterServiceFactory.java | 1 -
.../ignite/utils/ClusterServiceTestUtils.java | 34 +-
.../message/PlacementDriverActorMessage.java} | 9 +-
...icaMessage.java => PlacementDriverMessage.java} | 4 +-
.../message/PlacementDriverMessageGroup.java | 2 +
.../message/PlacementDriverReplicaMessage.java | 15 +-
...onse.java => StopLeaseProlongationMessage.java} | 9 +-
.../MultiActorPlacementDriverTest.java | 89 +++++-
.../internal/placementdriver/LeaseUpdater.java | 106 ++++++-
.../internal/placementdriver/leases/Lease.java | 51 ++-
.../cpp/tests/client-test/ignite_runner_suite.h | 1 +
.../platforms/cpp/tests/client-test/sql_test.cpp | 87 +++++-
.../dotnet/Apache.Ignite.Tests/MetricsTests.cs | 29 +-
.../dotnet/Apache.Ignite/Internal/ClientSocket.cs | 7 +-
.../raft/ItTruncateSuffixAndRestartTest.java | 4 +-
.../apache/ignite/raft/jraft/core/NodeImpl.java | 8 +-
.../apache/ignite/raft/jraft/core/Replicator.java | 5 +-
.../apache/ignite/raft/jraft/rpc/RpcRequests.java | 16 +-
.../ignite/internal/replicator/ReplicaManager.java | 28 +-
.../replicator/command/HybridTimestampMessage.java | 38 ---
.../command/SafeTimePropagatingCommand.java | 12 +-
.../replicator/message/ReplicaMessageGroup.java | 17 +-
.../replicator/message/TimestampAware.java | 19 +-
.../rest/api/deployment/DeploymentCodeApi.java | 3 +
.../internal/compute/ItLogicalTopologyTest.java | 25 +-
.../runner/app/ItIgniteNodeRestartTest.java | 4 +-
.../internal/sql/engine/ItFunctionsTest.java | 27 +-
.../internal/sql/engine/ItImplicitCastsTest.java | 3 +-
.../ignite/internal/sql/engine/ItMetadataTest.java | 21 +-
.../datatypes/tests/BaseCustomDataTypeTest.java | 5 +-
.../tests/BaseIndexCustomDataTypeTest.java | 2 -
.../datatypes/tests/TestTypeArgumentsTest.java | 4 +-
.../sql/engine/datatypes/uuid/ItUuidIndexTest.java | 2 -
.../internal/table/ItPublicApiColocationTest.java | 10 +-
.../ignite/internal/table/ItTableScanTest.java | 348 ++++++++++-----------
...ll.test_ignore => test_correlated_any_all.test} | 130 ++++----
...p.test_ignore => test_incorrect_timestamp.test} | 0
.../org/apache/ignite/internal/app/IgniteImpl.java | 4 +-
modules/sql-engine/src/main/codegen/config.fmpp | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 32 ++
.../sql/engine/exec/ExchangeServiceImpl.java | 12 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 50 +++
.../internal/sql/engine/exec/exp/RexImpTable.java | 29 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 3 +-
.../sql/engine/prepare/IgniteTypeCoercion.java | 76 ++++-
.../sql/engine/prepare/PlanningContext.java | 7 +
.../sql/engine/schema/IgniteTableImpl.java | 6 +-
.../sql/engine/type/IgniteTypeFactory.java | 8 -
.../internal/sql/engine/util/BaseQueryContext.java | 25 +-
.../internal/sql/engine/util/IgniteMethod.java | 7 +-
.../ignite/internal/sql/engine/util/RexUtils.java | 98 +++---
.../ignite/internal/sql/engine/util/TypeUtils.java | 44 ---
.../sql/engine/exec/RuntimeSortedIndexTest.java | 3 +-
.../engine/exec/exp/ExpressionFactoryImplTest.java | 8 +-
.../engine/exec/rel/MergeJoinExecutionTest.java | 8 +-
.../sql/engine/planner/AbstractPlannerTest.java | 4 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 6 +-
.../engine/planner/HashIndexSpoolPlannerTest.java | 8 +-
.../planner/IndexSearchBoundsPlannerTest.java | 14 +-
.../sql/engine/planner/LimitOffsetPlannerTest.java | 4 +-
.../internal/sql/engine/planner/PlannerTest.java | 24 +-
.../planner/ProjectFilterScanMergePlannerTest.java | 4 +-
.../sql/engine/planner/SetOpPlannerTest.java | 4 +-
.../planner/SortedIndexSpoolPlannerTest.java | 6 +-
.../engine/planner/TableFunctionPlannerTest.java | 4 +-
.../sql/engine/planner/TableSpoolPlannerTest.java | 4 +-
.../sql/engine/planner/UnionPlannerTest.java | 4 +-
.../engine/prepare/LeastRestrictiveTypesTest.java | 3 +-
.../engine/sql/IgniteSqlDecimalLiteralTest.java | 4 +-
.../internal/sql/engine/sql/SqlDdlParserTest.java | 16 +
.../internal/storage/MvPartitionStorage.java | 80 ++++-
.../ignite/internal/storage/gc/GcEntry.java} | 21 +-
.../ignite/internal/storage/util/LocalLocker.java | 106 +++++++
.../ignite/internal/storage/util/LockByRowId.java | 114 +++++++
.../ignite/internal/storage/util/LockHolder.java | 15 +-
.../storage/util/ReentrantLockByRowId.java | 177 -----------
.../internal/storage/util/LockByRowIdTest.java | 103 ++++++
.../storage/util/ReentrantLockByRowIdTest.java | 159 ----------
.../AbstractMvPartitionStorageConcurrencyTest.java | 16 +-
.../storage/AbstractMvPartitionStorageTest.java | 106 ++++---
.../storage/AbstractMvTableStorageTest.java | 76 +++--
.../storage/BaseMvPartitionStorageTest.java | 34 +-
.../storage/impl/TestMvPartitionStorage.java | 69 +++-
.../index/AbstractHashIndexStorageTest.java | 4 +-
.../index/AbstractSortedIndexStorageTest.java | 8 +-
.../pagememory/AbstractPageMemoryTableStorage.java | 6 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 215 ++++++-------
.../storage/pagememory/mv/HybridTimestamps.java | 37 +--
.../mv/PersistentPageMemoryMvPartitionStorage.java | 38 ++-
.../storage/pagememory/mv/ScanVersionsCursor.java | 75 +++--
.../mv/VolatilePageMemoryMvPartitionStorage.java | 29 +-
.../storage/pagememory/mv/gc/GcRowVersion.java | 11 +-
.../VolatilePageMemoryMvTableStorageTest.java | 8 +-
...PersistentPageMemoryMvPartitionStorageTest.java | 8 +-
.../internal/storage/rocksdb/GarbageCollector.java | 88 +++---
.../internal/storage/rocksdb/GcRowVersion.java | 9 +-
.../ignite/internal/storage/rocksdb/HashIndex.java | 2 +-
.../storage/rocksdb/PartitionDataHelper.java | 71 ++++-
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 158 +++++-----
.../internal/storage/rocksdb/SortedIndex.java | 2 +-
.../storage/rocksdb/ThreadLocalState.java} | 30 +-
.../rocksdb/index/AbstractRocksDbIndexStorage.java | 16 +-
.../rocksdb/index/RocksDbHashIndexStorage.java | 16 +-
.../rocksdb/index/RocksDbSortedIndexStorage.java | 28 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 18 +-
.../ignite/distributed/ItTablePersistenceTest.java | 22 +-
.../distributed/ItTxDistributedTestSingleNode.java | 15 +-
...ItTxDistributedTestThreeNodesThreeReplicas.java | 11 +-
.../internal/table/distributed/LowWatermark.java | 2 +-
.../table/distributed/SortedIndexLocker.java | 53 ++--
.../table/distributed/StorageUpdateHandler.java | 120 +++----
.../internal/table/distributed/TableManager.java | 8 +-
.../table/distributed/command/FinishTxCommand.java | 14 +-
.../distributed/command/TxCleanupCommand.java | 14 +-
.../ignite/internal/table/distributed/gc/MvGc.java | 73 +++--
.../table/distributed/raft/PartitionListener.java | 48 ++-
.../distributed/raft/snapshot/PartitionAccess.java | 5 +-
.../raft/snapshot/PartitionAccessImpl.java | 23 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 8 +-
.../snapshot/message/SnapshotMvDataResponse.java | 5 +-
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 25 +-
.../request/ScanRetrieveBatchReplicaRequest.java | 1 -
.../replicator/PartitionReplicaListener.java | 35 +--
.../distributed/storage/InternalTableImpl.java | 32 +-
.../AbstractMvStorageUpdateHandlerTest.java | 10 +-
.../internal/table/distributed/IndexBaseTest.java | 8 +-
.../PartitionGcOnWriteConcurrentTest.java | 167 ----------
.../table/distributed/PartitionGcOnWriteTest.java | 197 ------------
.../distributed/StorageUpdateHandlerTest.java | 128 +++++++-
.../TableManagerDistributionZonesTest.java | 7 +-
.../PartitionRaftCommandsSerializationTest.java | 17 +-
.../internal/table/distributed/gc/MvGcTest.java | 50 ++-
.../raft/PartitionCommandListenerTest.java | 77 ++---
.../raft/snapshot/PartitionAccessImplTest.java | 8 +-
.../incoming/IncomingSnapshotCopierTest.java | 8 +-
.../OutgoingSnapshotMvDataStreamingTest.java | 70 ++---
.../SnapshotAwarePartitionDataStorageTest.java | 4 +-
.../PartitionReplicaListenerIndexLockingTest.java | 9 +-
.../replication/PartitionReplicaListenerTest.java | 27 +-
.../utils/RebalanceUtilUpdateAssignmentsTest.java | 7 +-
.../table/impl/DummyInternalTableImpl.java | 10 +-
.../apache/ignite/internal/tx/TransactionIds.java | 6 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 5 +-
.../tx/message/TxCleanupReplicaRequest.java | 16 +-
.../tx/message/TxFinishReplicaRequest.java | 14 +-
.../internal/tx/message/TxStateReplicaRequest.java | 11 +-
.../storage/state/AbstractTxStateStorageTest.java | 11 +-
195 files changed, 3812 insertions(+), 2629 deletions(-)
rename modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/{PicocliBugTest.java => ReuseCommandTest.java} (81%)
delete mode 100644 modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/HybridTimestampMessage.java
copy modules/{catalog/src/main/java/org/apache/ignite/internal/catalog/commands/DropTableParams.java => network/src/main/java/org/apache/ignite/internal/network/recovery/FailureHandler.java} (61%)
copy modules/{transactions/src/test/java/org/apache/ignite/internal/tx/storage/state/test/TestTxStateStorageTest.java => network/src/main/java/org/apache/ignite/internal/network/recovery/InMemoryStaleIds.java} (63%)
copy modules/{sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/AsyncSqlCursor.java => network/src/main/java/org/apache/ignite/internal/network/recovery/StaleIdDetector.java} (65%)
copy modules/{marshaller-common/src/main/java/org/apache/ignite/internal/util/Factory.java => network/src/main/java/org/apache/ignite/internal/network/recovery/StaleIds.java} (74%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/recovery/VaultStateIds.java
copy modules/network/src/main/java/org/apache/ignite/internal/network/recovery/message/{HandshakeFinishMessage.java => HandshakeRejectedMessage.java} (67%)
create mode 100644 modules/network/src/test/java/org/apache/ignite/internal/network/recovery/VaultStateIdsTest.java
copy modules/{schema/src/testFixtures/java/org/apache/ignite/internal/schema/testutils/definition/index/HashIndexDefinition.java => network/src/testFixtures/java/org/apache/ignite/internal/network/recovery/AllIdsAreFresh.java} (76%)
copy modules/{schema/src/testFixtures/java/org/apache/ignite/internal/schema/testutils/definition/index/HashIndexDefinition.java => network/src/testFixtures/java/org/apache/ignite/internal/network/recovery/AllIdsAreStale.java} (77%)
copy modules/{api/src/main/java/org/apache/ignite/compute/JobExecutionContext.java => placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/PlacementDriverActorMessage.java} (76%)
copy modules/placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/{PlacementDriverReplicaMessage.java => PlacementDriverMessage.java} (90%)
copy modules/placement-driver-api/src/main/java/org/apache/ignite/internal/placementdriver/message/{LeaseGrantedMessageResponse.java => StopLeaseProlongationMessage.java} (78%)
delete mode 100644 modules/replicator/src/main/java/org/apache/ignite/internal/replicator/command/HybridTimestampMessage.java
rename modules/runner/src/integrationTest/sql/subquery/any_all/{test_correlated_any_all.test_ignore => test_correlated_any_all.test} (72%)
rename modules/runner/src/integrationTest/sql/types/timestamp/{test_incorrect_timestamp.test_ignore => test_incorrect_timestamp.test} (100%)
copy modules/{security/src/main/java/org/apache/ignite/internal/security/authentication/AuthenticationRequest.java => storage-api/src/main/java/org/apache/ignite/internal/storage/gc/GcEntry.java} (71%)
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/util/LocalLocker.java
create mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/util/LockByRowId.java
delete mode 100644 modules/storage-api/src/main/java/org/apache/ignite/internal/storage/util/ReentrantLockByRowId.java
create mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/util/LockByRowIdTest.java
delete mode 100644 modules/storage-api/src/test/java/org/apache/ignite/internal/storage/util/ReentrantLockByRowIdTest.java
copy modules/{arch-test/src/test/java/org/apache/ignite/lang/LocationProvider.java => storage-rocksdb/src/main/java/org/apache/ignite/internal/storage/rocksdb/ThreadLocalState.java} (50%)
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/PartitionGcOnWriteConcurrentTest.java
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/PartitionGcOnWriteTest.java