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 2022/10/28 09:04:43 UTC
[ignite-3] branch ignite-17771 updated (84ad2b5fd0 -> 9a1866dfff)
This is an automated email from the ASF dual-hosted git repository.
amashenkov pushed a change to branch ignite-17771
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 84ad2b5fd0 WIP.
add c65c3062a7 IGNITE-17968 Fix write-intents being filtered out in case if it's a tombstone (#1252)
add edc9a75742 IGNITE-17955 Reduce memory consumption during OrderingFuture completion (#1239)
add 820a14b1c9 IGNITE-17980 ./gradlew clean build -x test fails (#1254)
add ecc88efd5b IGNITE-17994 Use toByteArray for colocation hash of BigDecimal and BigInteger (#1259)
add 93914175c5 IGNITE-17894 Implement RAFT snapshot streaming receiver (#1233)
add 6f6c3f48f8 IGNITE-17859 Update indexes on data modifications (#1191)
add d1405efac2 IGNITE-17330 Support read only transactions from sql side - Fixes #1232.
add fe54738e4d IGNITE-17263 Leader to replica safe time propagation implemented (#1177)
add 4b5db8ddf4 IGNITE-18004 Compilation fixed, test disabled. (#1268)
add 8277b1ad4c IGNITE-18002 Revert accident changes to project files (#1264)
add 9a1866dfff Merge branch 'main' into ignite-17771
No new revisions were added by this update.
Summary of changes:
.idea/codeStyles/Project.xml | 2 +-
.../internal/binarytuple/BinaryTupleBuilder.java | 7 +-
.../client/table/ClientTupleSerializer.java | 4 +-
.../ignite/client/fakes/FakeIgniteTables.java | 4 +-
.../internal/cluster/management/MockNode.java | 4 +-
.../management/raft/ItCmgRaftServiceTest.java | 4 +-
.../ignite/internal/future/OrderingFuture.java | 103 ++-
.../apache/ignite/internal/hlc/HybridClock.java | 72 +-
.../hlc/{HybridClock.java => HybridClockImpl.java} | 14 +-
.../org/apache/ignite/internal/util/Cursor.java | 11 +
.../ignite/internal/util/HashCalculator.java | 11 +-
.../java/org/apache/ignite/internal/util/Lazy.java | 68 ++
.../util/PendingComparableValuesTracker.java | 132 +++
.../apache/ignite/internal/HybridClockTest.java | 9 +-
.../apache/ignite/internal/TestHybridClock.java} | 58 +-
.../future/OrderingFutureConcurrencyTest.java | 7 +-
.../util/{CursorUtilsTest.java => LazyTest.java} | 41 +-
.../util/PendingComparableValuesTrackerTest.java | 134 +++
.../internal/testframework/IgniteTestUtils.java | 2 +-
modules/index/build.gradle | 1 +
modules/index/pom.xml | 5 +
.../apache/ignite/internal/index/IndexManager.java | 178 +++-
.../configuration/IndexConfigurationModule.java | 43 -
...nite.internal.configuration.ConfigurationModule | 17 -
.../ignite/internal/index/IndexManagerTest.java | 13 +-
.../checkpoint/CheckpointTimeoutLockTest.java | 4 +-
modules/raft/build.gradle | 2 +
modules/raft/pom.xml | 6 +
.../ignite/internal/raft/ItLearnersTest.java | 33 +-
.../apache/ignite/internal/raft/ItLozaTest.java | 4 +-
.../internal/raft/ItRaftGroupServiceTest.java | 4 +-
.../apache/ignite/raft/jraft/core/ItNodeTest.java | 7 +-
.../raft/server/ItJraftCounterServerTest.java | 166 +---
.../apache/ignite/raft/server/ItSafeTimeTest.java | 142 +++
...ftHlcServerTest.java => JraftAbstractTest.java} | 137 +--
.../java/org/apache/ignite/internal/raft/Loza.java | 24 +
.../internal/raft/server/RaftGroupOptions.java | 19 +
.../raft/server/ReplicationGroupOptions.java} | 33 +-
.../internal/raft/server/impl/JraftServerImpl.java | 4 +
.../ignite/raft/jraft/core/FSMCallerImpl.java | 6 +
.../apache/ignite/raft/jraft/core/NodeImpl.java | 14 +
.../apache/ignite/raft/jraft/core/Replicator.java | 6 +-
.../ignite/raft/jraft/option/FSMCallerOptions.java | 10 +
.../ignite/raft/jraft/option/NodeOptions.java | 17 +-
.../raft/jraft/util/SafeTimeCandidateManager.java | 90 ++
.../org/apache/ignite/internal/raft/LozaTest.java | 4 +-
.../org/apache/ignite/raft/TestWriteCommand.java} | 12 +-
.../ignite/raft/jraft/core/FSMCallerTest.java | 9 +
.../jraft/util/SafeTimeCandidatesManagerTest.java | 51 ++
.../apache/ignite/internal/replicator/Replica.java | 8 +
.../ignite/internal/replicator/ReplicaManager.java | 43 +-
.../replicator/command/SafeTimeSyncCommand.java} | 6 +-
.../replicator/message/ReplicaMessageGroup.java | 3 +
...sponse.java => ReplicaSafeTimeSyncRequest.java} | 6 +-
.../ItDistributedConfigurationPropertiesTest.java | 4 +-
.../ItDistributedConfigurationStorageTest.java | 4 +-
.../storage/ItRebalanceDistributedTest.java | 9 +-
.../ignite/internal/index/ItIndexManagerTest.java | 69 +-
.../internal/runner/app/ItDataSchemaSyncTest.java | 81 +-
.../runner/app/ItIgniteNodeRestartTest.java | 3 +-
.../internal/runner/app/ItTablesApiTest.java | 1 +
.../app/jdbc/ItJdbcInsertStatementSelfTest.java | 2 +-
.../runner/app/jdbc/ItJdbcStatementSelfTest.java | 2 +-
.../internal/sql/api/ItSqlAsynchronousApiTest.java | 57 ++
.../internal/sql/engine/ItDataTypesTest.java | 2 +
.../ignite/internal/sql/engine/ItDmlTest.java | 28 +
.../ignite/internal/sqllogic/ItSqlLogicTest.java | 2 +
.../org/apache/ignite/internal/app/IgniteImpl.java | 8 +-
.../ignite/internal/schema/BinaryConverter.java | 30 +-
.../ignite/internal/schema/BinaryTupleSchema.java | 3 +-
.../SchemaDistributedConfigurationModule.java | 6 +-
.../org/apache/ignite/internal/schema/row/Row.java | 2 +-
.../ignite/internal/util/ColocationUtils.java | 13 +-
.../internal/sql/api/AsyncResultSetImpl.java | 6 -
.../internal/sql/engine/SqlQueryProcessor.java | 37 +-
.../sql/engine/exec/ExchangeServiceImpl.java | 9 +-
.../internal/sql/engine/exec/ExecutionContext.java | 19 +-
.../sql/engine/exec/ExecutionServiceImpl.java | 27 +-
.../sql/engine/exec/LogicalRelImplementor.java | 8 +-
.../sql/engine/exec/rel/TableScanNode.java | 8 +-
.../sql/engine/message/QueryStartRequest.java | 8 +
.../sql/engine/metadata/FragmentDescription.java | 2 +-
.../internal/sql/engine/prepare/PlannerPhase.java | 4 +-
.../sql/engine/prepare/PrepareServiceImpl.java | 5 +-
.../internal/sql/engine/trait/TraitUtils.java | 16 +
.../internal/sql/engine/util/BaseQueryContext.java | 21 +-
.../internal/sql/engine/StopCalciteModuleTest.java | 12 +-
.../sql/engine/exec/ExecutionServiceImplTest.java | 6 +-
.../sql/engine/exec/MockedStructuresTest.java | 19 +-
.../sql/engine/exec/RuntimeSortedIndexTest.java | 4 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 9 +-
.../engine/exec/rel/TableScanExecutionTest.java | 3 +-
.../planner/AggregateDistinctPlannerTest.java | 28 +-
.../sql/engine/planner/AggregatePlannerTest.java | 44 +-
.../CorrelatedNestedLoopJoinPlannerTest.java | 2 +
.../sql/engine/planner/HashIndexPlannerTest.java | 3 +
.../engine/planner/JoinColocationPlannerTest.java | 2 +
.../sql/engine/planner/LimitOffsetPlannerTest.java | 2 +
.../sql/engine/planner/MergeJoinPlannerTest.java | 2 +
.../planner/ProjectFilterScanMergePlannerTest.java | 3 +
.../engine/planner/SortAggregatePlannerTest.java | 4 +
.../planner/SortedIndexSpoolPlannerTest.java | 2 +
modules/storage-api/build.gradle | 1 -
modules/storage-api/pom.xml | 6 -
.../internal/storage/MvPartitionStorage.java | 3 +-
.../apache/ignite/internal/storage/ReadResult.java | 3 +-
.../org/apache/ignite/internal/storage/RowId.java | 30 +-
.../internal/storage/engine/MvTableStorage.java | 2 +-
.../storage/AbstractMvPartitionStorageTest.java | 35 +-
.../storage/impl/TestMvPartitionStorage.java | 11 +-
.../internal/storage/impl/TestMvTableStorage.java | 4 +-
modules/storage-page-memory/build.gradle | 2 +-
modules/storage-page-memory/pom.xml | 6 -
.../pagememory/AbstractPageMemoryTableStorage.java | 5 +-
.../mv/AbstractPageMemoryMvPartitionStorage.java | 13 +-
modules/storage-rocksdb/build.gradle | 1 -
modules/storage-rocksdb/pom.xml | 6 -
.../storage/rocksdb/RocksDbMvPartitionStorage.java | 49 +-
.../storage/rocksdb/RocksDbTableStorage.java | 36 +-
.../storage/rocksdb/RocksDbMvTableStorageTest.java | 6 +-
modules/table/build.gradle | 8 +-
modules/table/pom.xml | 6 -
.../ItAbstractInternalTableScanTest.java | 34 +-
.../ItInternalTableReadOnlyOperationsTest.java | 97 +-
.../ItInternalTableReadOnlyScanTest.java | 3 +-
.../ignite/distributed/ItTablePersistenceTest.java | 14 +-
.../distributed/ItTxDistributedTestSingleNode.java | 74 +-
.../ignite/internal/table/ItColocationTest.java | 5 +-
.../apache/ignite/internal/table/TableImpl.java | 210 ++++-
.../table/distributed/HashIndexLocker.java | 85 ++
.../internal/table/distributed/IndexLocker.java | 62 ++
.../table/distributed/SortedIndexLocker.java | 113 +++
.../internal/table/distributed/TableManager.java | 355 +++++---
.../distributed/TableSchemaAwareIndexStorage.java | 90 ++
.../table/distributed/raft/PartitionListener.java | 123 +--
.../distributed/raft/snapshot/PartitionAccess.java | 35 +-
.../raft/snapshot/PartitionAccessImpl.java | 82 +-
.../distributed/raft/snapshot/PartitionKey.java | 5 +-
.../raft/snapshot/PartitionSnapshotStorage.java | 26 +-
.../snapshot/PartitionSnapshotStorageFactory.java | 19 +-
.../distributed/raft/snapshot/SnapshotUri.java | 4 +-
.../snapshot/incoming/IncomingSnapshotCopier.java | 391 +++++++--
.../raft/snapshot/outgoing/OutgoingSnapshot.java | 12 +-
.../snapshot/outgoing/OutgoingSnapshotReader.java | 2 +-
.../replicator/PartitionReplicaListener.java | 971 ++++++++++-----------
.../distributed/storage/InternalTableImpl.java | 36 +-
.../table/ColocationHashCalculationTest.java | 4 +-
.../org/apache/ignite/internal/table/Example.java | 4 +-
.../internal/table/InteropOperationsTest.java | 3 +-
.../table/KeyValueBinaryViewOperationsTest.java | 3 +-
.../KeyValueViewOperationsSimpleSchemaTest.java | 3 +-
.../table/RecordBinaryViewOperationsTest.java | 3 +-
.../internal/table/SchemaValidationTest.java | 3 +-
.../apache/ignite/internal/table/TxLocalTest.java | 8 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../PartitionRaftCommandsSerializationTest.java | 5 +-
.../raft/PartitionCommandListenerTest.java | 193 ++--
.../raft/snapshot/PartitionAccessImplTest.java | 86 --
.../incoming/IncomingSnapshotCopierTest.java | 383 ++++++++
.../snapshot/outgoing/OutgoingSnapshotTest.java | 72 +-
.../SnapshotAwarePartitionDataStorageTest.java | 6 +-
.../PartitionReplicaListenerIndexLockingTest.java | 392 +++++++++
.../replication/PartitionReplicaListenerTest.java | 65 +-
.../table/impl/DummyInternalTableImpl.java | 53 +-
.../distributed/TestPartitionDataStorage.java | 0
.../java/org/apache/ignite/internal/tx/Lock.java | 6 +
.../org/apache/ignite/internal/tx/LockKey.java | 6 +
.../internal/tx/storage/state/TxStateStorage.java | 5 +
.../tx/storage/state/TxStateTableStorage.java | 4 +-
.../state/rocksdb/TxStateRocksDbStorage.java | 30 +-
.../state/rocksdb/TxStateRocksDbTableStorage.java | 52 +-
.../apache/ignite/internal/tx/TxManagerTest.java | 4 +-
.../test/TestConcurrentHashMapTxStateStorage.java | 21 +-
.../TestConcurrentHashMapTxStateTableStorage.java | 36 +-
174 files changed, 4846 insertions(+), 2144 deletions(-)
copy modules/core/src/main/java/org/apache/ignite/internal/hlc/{HybridClock.java => HybridClockImpl.java} (88%)
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/Lazy.java
create mode 100644 modules/core/src/main/java/org/apache/ignite/internal/util/PendingComparableValuesTracker.java
copy modules/core/src/{main/java/org/apache/ignite/internal/hlc/HybridClock.java => test/java/org/apache/ignite/internal/TestHybridClock.java} (64%)
copy modules/core/src/test/java/org/apache/ignite/internal/util/{CursorUtilsTest.java => LazyTest.java} (50%)
create mode 100644 modules/core/src/test/java/org/apache/ignite/internal/util/PendingComparableValuesTrackerTest.java
delete mode 100644 modules/index/src/main/java/org/apache/ignite/internal/index/configuration/IndexConfigurationModule.java
delete mode 100644 modules/index/src/main/resources/META-INF/services/org.apache.ignite.internal.configuration.ConfigurationModule
create mode 100644 modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/ItSafeTimeTest.java
copy modules/raft/src/integrationTest/java/org/apache/ignite/raft/server/{ItJraftHlcServerTest.java => JraftAbstractTest.java} (57%)
copy modules/{replicator/src/main/java/org/apache/ignite/internal/replicator/message/TimestampAware.java => raft/src/main/java/org/apache/ignite/internal/raft/server/ReplicationGroupOptions.java} (55%)
create mode 100644 modules/raft/src/main/java/org/apache/ignite/raft/jraft/util/SafeTimeCandidateManager.java
copy modules/{network/src/test/java/org/apache/ignite/internal/network/messages/EmptyMessage.java => raft/src/test/java/org/apache/ignite/raft/TestWriteCommand.java} (80%)
create mode 100644 modules/raft/src/test/java/org/apache/ignite/raft/jraft/util/SafeTimeCandidatesManagerTest.java
copy modules/{raft/src/integrationTest/java/org/apache/ignite/raft/server/snasphot/TestWriteCommand.java => replicator/src/main/java/org/apache/ignite/internal/replicator/command/SafeTimeSyncCommand.java} (83%)
copy modules/replicator/src/main/java/org/apache/ignite/internal/replicator/message/{TimestampAwareReplicaResponse.java => ReplicaSafeTimeSyncRequest.java} (79%)
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/HashIndexLocker.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/IndexLocker.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/SortedIndexLocker.java
create mode 100644 modules/table/src/main/java/org/apache/ignite/internal/table/distributed/TableSchemaAwareIndexStorage.java
delete mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/PartitionAccessImplTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/raft/snapshot/incoming/IncomingSnapshotCopierTest.java
create mode 100644 modules/table/src/test/java/org/apache/ignite/internal/table/distributed/replication/PartitionReplicaListenerIndexLockingTest.java
rename modules/table/src/{integrationTest/java/org/apache/ignite => testFixtures/java}/distributed/TestPartitionDataStorage.java (100%)