You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sk...@apache.org on 2025/03/11 07:59:34 UTC
(ignite-3) branch colocation updated (efcba879f3b -> f1d166ab9c2)
This is an automated email from the ASF dual-hosted git repository.
sk0x50 pushed a change to branch colocation
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from efcba879f3b Enable colocation feature by default
add 84d17e0c890 IGNITE-24307 Sql. Query plan does not use the most optimal table index (#5311)
add 9308819621f IGNITE-24547 Port speed-based throttling from Ignite 2 (#5365)
add 9685d9deff7 IGNITE-24743 Sql. Disable flaky test_natural_join (#5378)
add 171913a686a IGNITE-23960 Sql. Execution node should not hold thread for too long (#5368)
add a20d6eb81a0 Implement TxCleanupRecoveryRequest processing for zone replica (#5371)
add 5d7148d7bac IGNITE-24400 Implement multicast node finder (#5345)
add f1d166ab9c2 Merge remote-tracking branch 'origin/main' into colocation
No new revisions were added by this update.
Summary of changes:
.../apache/ignite/client/fakes/FakeTxManager.java | 2 +-
.../internal/index/ItBuildIndexOneNodeTest.java | 17 +-
.../index/ItDropIndexMultipleNodesTest.java | 6 +-
.../ItIndexAndIndexStorageDestructionTest.java | 4 +-
.../apache/ignite/internal/network/NodeFinder.java | 15 +-
...rtsTest.java => ItMulticastNodeFinderTest.java} | 113 +++--
.../internal/network/MulticastNodeFinder.java | 303 +++++++++++++
.../ignite/internal/network/NodeFinderFactory.java | 16 +-
.../ignite/internal/network/StaticNodeFinder.java | 8 +-
.../network/configuration/MulticastAddress.java} | 9 +-
.../configuration/MulticastAddressValidator.java} | 34 +-
...hema.java => MulticastConfigurationSchema.java} | 36 +-
.../configuration/NetworkConfigurationModule.java | 2 +-
.../NodeFinderConfigurationSchema.java | 5 +
.../network/configuration/NodeFinderType.java | 4 +-
.../scalecube/ScaleCubeClusterServiceFactory.java | 12 +-
.../internal/network/StaticNodeFinderMain.java | 3 +-
.../MulticastAddressValidatorTest.java} | 34 +-
.../network/utils/ClusterServiceTestUtils.java | 3 -
.../persistence/PersistentPageMemory.java | 21 +
.../persistence/checkpoint/CheckpointProgress.java | 11 +
.../checkpoint/CheckpointProgressImpl.java | 8 +-
.../throttling/IntervalBasedMeasurement.java | 313 +++++++++++++
.../throttling/PagesWriteSpeedBasedThrottle.java | 307 +++++++++++++
.../throttling/ProgressSpeedCalculation.java | 68 +++
...edBasedMemoryConsumptionThrottlingStrategy.java | 482 +++++++++++++++++++++
.../PageMemoryThrottlingTest.java | 57 ++-
.../throttling/ProgressSpeedCalculationTest.java | 70 +++
.../persistence/throttling/ThrottlingTest.java | 421 ++++++++++++++++++
.../ItColocationTxCleanupRecoveryTest.java | 141 ++++++
.../replicator/ItColocationTxRecoveryTest.java | 23 +-
.../partition/replicator/fixtures/Node.java | 36 ++
.../replicator/ZonePartitionReplicaListener.java | 11 +-
.../handlers/TxCleanupRecoveryRequestHandler.java | 107 +++++
.../internal/benchmark/SqlIndexScanBenchmark.java | 2 +-
.../internal/sql/engine/ItSecondaryIndexTest.java | 46 +-
.../datatypes/tests/BaseIndexDataTypeTest.java | 25 +-
.../datatypes/varbinary/ItVarBinaryIndexTest.java | 2 +-
.../sql/group1/join/natural/test_natural_join.test | 4 +
.../rel/AbstractRightMaterializedJoinNode.java | 4 +-
.../internal/sql/engine/exec/rel/FilterNode.java | 8 +
.../internal/sql/engine/exec/rel/HashJoinNode.java | 187 +++++---
.../ignite/internal/sql/engine/exec/rel/Inbox.java | 16 +
.../sql/engine/exec/rel/MergeJoinNode.java | 51 ++-
.../sql/engine/exec/rel/NestedLoopJoinNode.java | 337 ++++++++------
.../sql/engine/exec/rel/SortAggregateNode.java | 51 ++-
.../internal/sql/engine/exec/rel/SortNode.java | 12 +-
.../sql/engine/exec/rel/StorageScanNode.java | 8 +
.../metadata/IgniteMdPercentageOriginalRows.java | 19 +
.../internal/sql/engine/rel/AbstractIndexScan.java | 8 +-
.../engine/schema/AbstractIgniteDataSource.java | 20 +-
.../engine/statistic/SqlStatisticManagerImpl.java | 2 +-
.../sql/engine/exec/rel/AbstractExecutionTest.java | 8 +-
.../engine/exec/rel/AbstractJoinExecutionTest.java | 294 +++++++++++--
.../sql/engine/exec/rel/BaseAggregateTest.java | 76 +++-
...t.java => DataSourceScanNodeExecutionTest.java} | 44 +-
.../sql/engine/exec/rel/FilterExecutionTest.java | 93 ++++
.../sql/engine/exec/rel/HashJoinExecutionTest.java | 357 ++-------------
.../exec/rel/IndexScanNodeExecutionTest.java | 78 +++-
.../engine/exec/rel/MergeJoinExecutionTest.java | 199 ++++++++-
.../exec/rel/TableScanNodeExecutionTest.java | 55 ++-
.../planner/SelectRowCountEstimationTest.java | 2 -
.../pagememory/PersistentPageMemoryDataRegion.java | 18 +-
.../replicator/PartitionReplicaListener.java | 60 +--
.../org/apache/ignite/internal/tx/TxManager.java | 3 +-
.../internal/tx/impl/TransactionInflights.java | 5 +-
.../ignite/internal/tx/impl/TxManagerImpl.java | 12 +-
.../ignite/internal/tx/impl/TxMessageSender.java | 8 +-
68 files changed, 3932 insertions(+), 884 deletions(-)
copy modules/network/src/integrationTest/java/org/apache/ignite/internal/network/scalecube/{ItNodeRestartsTest.java => ItMulticastNodeFinderTest.java} (55%)
create mode 100644 modules/network/src/main/java/org/apache/ignite/internal/network/MulticastNodeFinder.java
copy modules/{configuration-api/src/main/java/org/apache/ignite/configuration/annotation/Secret.java => network/src/main/java/org/apache/ignite/internal/network/configuration/MulticastAddress.java} (81%)
copy modules/{configuration/src/main/java/org/apache/ignite/internal/configuration/validation/ExceptKeysValidator.java => network/src/main/java/org/apache/ignite/internal/network/configuration/MulticastAddressValidator.java} (56%)
copy modules/network/src/main/java/org/apache/ignite/internal/network/configuration/{InboundConfigurationSchema.java => MulticastConfigurationSchema.java} (62%)
copy modules/{configuration/src/test/java/org/apache/ignite/internal/configuration/validation/NotBlankValidatorTest.java => network/src/test/java/org/apache/ignite/internal/network/configuration/MulticastAddressValidatorTest.java} (54%)
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/IntervalBasedMeasurement.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/PagesWriteSpeedBasedThrottle.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/ProgressSpeedCalculation.java
create mode 100644 modules/page-memory/src/main/java/org/apache/ignite/internal/pagememory/persistence/throttling/SpeedBasedMemoryConsumptionThrottlingStrategy.java
rename modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/{checkpoint => throttling}/PageMemoryThrottlingTest.java (88%)
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ProgressSpeedCalculationTest.java
create mode 100644 modules/page-memory/src/test/java/org/apache/ignite/internal/pagememory/persistence/throttling/ThrottlingTest.java
create mode 100644 modules/partition-replicator/src/integrationTest/java/org/apache/ignite/internal/partition/replicator/ItColocationTxCleanupRecoveryTest.java
create mode 100644 modules/partition-replicator/src/main/java/org/apache/ignite/internal/partition/replicator/handlers/TxCleanupRecoveryRequestHandler.java
rename modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/{DataSourceScanNodeSelfTest.java => DataSourceScanNodeExecutionTest.java} (86%)
create mode 100644 modules/sql-engine/src/test/java/org/apache/ignite/internal/sql/engine/exec/rel/FilterExecutionTest.java