This is an automated email from the ASF dual-hosted git repository.
sdanilov pushed a change to branch ignite-14734
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
discard 7b9fe75858 IGNITE-14734 Initial
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 7bdfba086a IGNITE-18925 Avoid BinaryTuple conversion from client to
storage (#2004)
add 4da2b8ec59 IGNITE-19316 Fix ItIgnitePicocliCommandsTest (#2008)
add aaf13dbccd IGNITE-18624 Data nodes from DistributionZoneManager
instead of BaselineManager#nodes on table creation. (#1968)
add 1f1000d074 IGNITE-19272 Sql. Log query exception on remote node and
pass traceId back (#1994)
add eb63d8602e IGNITE-14734 Initial
add 36c69fb219 IGNITE-14734 Initial
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 (7b9fe75858)
\
N -- N -- N refs/heads/ignite-14734 (36c69fb219)
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:
.../cli/commands/unit/ItDeploymentUnitTest.java | 26 +-
.../repl/executor/ItIgnitePicocliCommandsTest.java | 2 -
.../commands/sql/SqlReplTopLevelCliCommand.java | 2 -
.../cli/commands/version/VersionCommand.java | 2 -
.../registry/impl/ClusterConfigRegistryImpl.java | 28 +-
.../repl/registry/impl/JdbcUrlRegistryImpl.java | 4 +-
.../cli/core/repl/registry/impl/LazyObjectRef.java | 69 ++++
.../repl/registry/impl/MetricRegistryImpl.java | 33 +-
.../repl/registry/impl/NodeConfigRegistryImpl.java | 29 +-
.../repl/registry/impl/NodeNameRegistryImpl.java | 4 +-
.../core/repl/registry/impl/UnitsRegistryImpl.java | 37 ++-
.../internal/cli/commands/CliCommandTestBase.java | 14 +-
.../{PicocliBugTest.java => ReuseCommandTest.java} | 22 +-
.../core/repl/registry/impl/LazyObjectRefTest.java | 61 ++++
.../table/MutableTupleBinaryTupleAdapter.java | 10 +
.../client/handler/JdbcQueryEventHandlerImpl.java | 10 +-
.../client/handler/requests/table/ClientTuple.java | 7 +-
.../handler/JdbcQueryEventHandlerImplTest.java | 9 +
.../apache/ignite/internal/hlc/HybridClock.java | 7 +
.../ignite/internal/hlc/HybridClockImpl.java | 63 ++--
.../ignite/internal/hlc/HybridTimestamp.java | 120 ++++---
.../org/apache/ignite/lang/RemoteException.java} | 38 +--
.../apache/ignite/internal/TestHybridClock.java | 61 ++--
.../internal/testframework/IgniteTestUtils.java | 8 +-
.../distributionzones/DistributionZoneManager.java | 135 ++++++++
.../distributionzones/DistributionZonesUtil.java | 17 +
.../DistributionZoneConfigurationSchema.java | 3 +-
.../DistributionZoneAwaitDataNodesTest.java | 22 +-
...ibutionZoneManagerConfigurationChangesTest.java | 6 +-
.../DistributionZoneManagerScaleUpTest.java | 45 ++-
.../DistributionZoneManagerWatchListenerTest.java | 23 +-
.../DistributionZoneMockTest.java} | 45 +--
.../util/DistributionZonesTestUtil.java | 37 +++
.../DistributionZonesTestUtil.java | 10 +-
.../apache/ignite/jdbc/ItJdbcTransactionTest.java | 27 ++
.../command/HybridTimestampMessage.java | 41 ---
.../command/MetaStorageWriteCommand.java | 26 +-
.../metastorage/command/SyncTimeCommand.java | 10 +-
.../metastorage/impl/MetaStorageServiceImpl.java | 27 +-
.../server/persistence/RocksDbKeyValueStorage.java | 19 +-
.../server/raft/MetaStorageWriteHandler.java | 15 +-
.../metastorage/server/time/ClusterTime.java | 5 +
.../metastorage/server/time/ClusterTimeImpl.java | 5 +
...mpleInMemoryCompactionKeyValueStorageTest.java} | 6 +-
.../server/SimpleInMemoryKeyValueStorage.java | 76 +++--
.../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 +-
.../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 +-
.../internal/compute/ItLogicalTopologyTest.java | 20 ++
.../storage/ItRebalanceDistributedTest.java | 53 ++--
.../inmemory/ItRaftStorageVolatilityTest.java | 3 +-
.../runner/app/ItIgniteNodeRestartTest.java | 13 +-
.../runner/app/ItTableApiContractTest.java | 5 +-
.../internal/runner/app/ItTablesApiTest.java | 3 +
.../runner/app/PlatformTestNodeRunner.java | 50 ++-
.../ignite/internal/sql/api/ItCommonApiTest.java | 3 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 3 +-
.../ignite/internal/sql/engine/ItDmlTest.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/ItRoReadsTest.java | 2 +-
.../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 +-
.../ignite/internal/schema/SchemaDescriptor.java | 24 +-
.../ignite/internal/schema/row/RowAssembler.java | 18 +-
modules/sql-engine/src/main/codegen/config.fmpp | 1 +
.../src/main/codegen/includes/parserImpls.ftl | 32 ++
.../internal/sql/engine/AsyncSqlCursorImpl.java | 52 +--
.../sql/engine/exec/ExchangeServiceImpl.java | 36 ++-
.../sql/engine/exec/ExecutionServiceImpl.java | 13 +-
.../sql/engine/exec/ddl/DdlCommandHandler.java | 18 +-
.../sql/engine/exec/exp/IgniteSqlFunctions.java | 50 +++
.../internal/sql/engine/exec/exp/RexImpTable.java | 29 +-
.../sql/engine/exec/exp/RexToLixTranslator.java | 3 +-
.../internal/sql/engine/message/ErrorMessage.java | 16 +-
....java => RemoteFragmentExecutionException.java} | 31 +-
.../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/ExecutionServiceImplTest.java | 7 +-
.../sql/engine/exec/MockedStructuresTest.java | 119 +++++--
.../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 +-
modules/table/build.gradle | 1 +
.../ignite/distributed/ItTablePersistenceTest.java | 22 +-
.../distributed/ItTxDistributedTestSingleNode.java | 15 +-
.../schema/marshaller/TupleMarshallerImpl.java | 27 +-
.../internal/table/distributed/LowWatermark.java | 2 +-
.../table/distributed/SortedIndexLocker.java | 53 ++--
.../table/distributed/StorageUpdateHandler.java | 120 +++----
.../internal/table/distributed/TableManager.java | 207 +++++++++---
.../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 | 11 +-
.../table/distributed/TableManagerTest.java | 69 ++--
.../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 | 6 +-
.../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 +-
208 files changed, 4148 insertions(+), 2855 deletions(-)
create mode 100644
modules/cli/src/main/java/org/apache/ignite/internal/cli/core/repl/registry/impl/LazyObjectRef.java
rename
modules/cli/src/test/java/org/apache/ignite/internal/cli/commands/{PicocliBugTest.java
=> ReuseCommandTest.java} (81%)
create mode 100644
modules/cli/src/test/java/org/apache/ignite/internal/cli/core/repl/registry/impl/LazyObjectRefTest.java
copy
modules/{client/src/main/java/org/apache/ignite/client/IgniteClientAuthenticationException.java
=> core/src/main/java/org/apache/ignite/lang/RemoteException.java} (54%)
copy
modules/{storage-api/src/test/java/org/apache/ignite/internal/storage/index/TestSortedIndexStorageTest.java
=>
distribution-zones/src/test/java/org/apache/ignite/internal/distributionzones/DistributionZoneMockTest.java}
(52%)
delete mode 100644
modules/metastorage/src/main/java/org/apache/ignite/internal/metastorage/command/HybridTimestampMessage.java
copy
modules/metastorage/src/test/java/org/apache/ignite/internal/metastorage/server/{SimpleInMemoryKeyValueStorageTest.java
=> SimpleInMemoryCompactionKeyValueStorageTest.java} (84%)
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%)
rename
modules/sql-engine/src/main/java/org/apache/ignite/internal/sql/engine/metadata/{RemoteException.java
=> RemoteFragmentExecutionException.java} (60%)
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
