This is an automated email from the ASF dual-hosted git repository.
ppa pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/ignite-3.git
from 6fc263e3ec IGNITE-23092 Compute: allow nested tuples in arguments and
results (#4456)
add 9c159207fe IGNITE-22637 Catalog compaction. Implement remote node part
of compaction flow (#4256)
No new revisions were added by this update.
Summary of changes:
.../compaction/ItCatalogCompactionTest.java | 224 +++----
.../compaction/CatalogCompactionRunner.java | 374 +++++++++---
.../compaction/CatalogManagerCompactionFacade.java | 24 +-
...equest.java => AvailablePartitionsMessage.java} | 16 +-
.../message/CatalogCompactionMessageGroup.java | 3 +
.../CatalogCompactionMinimumTimesResponse.java | 5 +
.../compaction/AbstractCatalogCompactionTest.java | 3 +-
.../CatalogCompactionRunnerSelfTest.java | 651 ++++++++++++++++++++-
.../CatalogManagerCompactionFacadeTest.java | 13 +-
.../internal/catalog/storage/UpdateLogImpl.java | 10 +-
.../catalog/storage/UpdateLogImplTest.java | 30 +
.../replicator/ItReplicaLifecycleTest.java | 7 +-
.../runner/app/ItIgniteNodeRestartTest.java | 9 +-
.../org/apache/ignite/internal/app/IgniteImpl.java | 9 +-
.../ReplicasSafeTimePropagationTest.java | 4 +-
.../rebalance/ItRebalanceDistributedTest.java | 7 +-
.../internal/table/distributed/TableManager.java | 17 +-
.../raft/MinimumRequiredTimeCollectorService.java} | 37 +-
.../MinimumRequiredTimeCollectorServiceImpl.java | 61 ++
.../table/distributed/raft/PartitionListener.java | 43 +-
...inimumRequiredTimeCollectorServiceSelfTest.java | 124 ++++
.../distributed/TableManagerRecoveryTest.java | 6 +-
.../table/distributed/TableManagerTest.java | 4 +-
.../raft/PartitionCommandListenerTest.java | 6 +-
.../apache/ignite/distributed/ItTxTestCluster.java | 4 +-
.../table/impl/DummyInternalTableImpl.java | 4 +-
26 files changed, 1385 insertions(+), 310 deletions(-)
copy
modules/catalog-compaction/src/main/java/org/apache/ignite/internal/catalog/compaction/message/{CatalogCompactionMinimumTimesRequest.java
=> AvailablePartitionsMessage.java} (74%)
copy
modules/{transactions/src/main/java/org/apache/ignite/internal/tx/message/CleanupReplicatedInfo.java
=>
table/src/main/java/org/apache/ignite/internal/table/distributed/raft/MinimumRequiredTimeCollectorService.java}
(54%)
create mode 100644
modules/table/src/main/java/org/apache/ignite/internal/table/distributed/raft/MinimumRequiredTimeCollectorServiceImpl.java
create mode 100644
modules/table/src/test/java/org/apache/ignite/internal/table/MinimumRequiredTimeCollectorServiceSelfTest.java
