This is an automated email from the ASF dual-hosted git repository.
benedict pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 0db9d4d926 Merge branch 'cassandra-5.0' into trunk
add c9e31f297c Introduce "hardRemoved" concept for marking nodes
permanently offline, to permit recovery from availability loss Also fix: -
Paxos should not update minHlc if AccordService is not setup - Remove
EndpointMapper methods that require non-null, to ensure call-sites handle null
case explicitly - AccordRepair should specify the Node Ids that must
participate, but these should not affect the durability requirements for GC -
Avoid erroneously marking UniversalOrInvalidated [...]
No new revisions were added by this update.
Summary of changes:
modules/accord | 2 +-
.../org/apache/cassandra/config/AccordSpec.java | 11 +-
.../cassandra/db/virtual/AccordDebugKeyspace.java | 521 +++++++++++++++++++--
.../db/virtual/AccordDebugRemoteKeyspace.java | 2 +-
.../db/virtual/VirtualKeyspaceRegistry.java | 2 +-
.../cassandra/locator/InetAddressAndPort.java | 8 +-
.../org/apache/cassandra/repair/RepairJob.java | 2 +-
.../apache/cassandra/service/RetryStrategy.java | 7 +
.../apache/cassandra/service/TimeoutStrategy.java | 2 +-
.../service/accord/AccordCommandStore.java | 2 +-
.../service/accord/AccordCommandStores.java | 2 +-
.../service/accord/AccordConfigurationService.java | 155 +++---
.../cassandra/service/accord/AccordDataStore.java | 3 +-
.../service/accord/AccordEndpointMapper.java | 25 +-
.../cassandra/service/accord/AccordFastPath.java | 16 +-
.../service/accord/AccordFastPathCoordinator.java | 6 +-
.../service/accord/AccordFetchCoordinator.java | 30 +-
.../cassandra/service/accord/AccordJournal.java | 6 +-
.../service/accord/AccordMessageSink.java | 41 +-
.../cassandra/service/accord/AccordOperations.java | 39 +-
.../service/accord/AccordOperationsMBean.java | 4 +
.../service/accord/AccordResponseVerbHandler.java | 8 +-
.../cassandra/service/accord/AccordResult.java | 4 +
.../cassandra/service/accord/AccordService.java | 128 ++---
.../service/accord/AccordStaleReplicas.java | 89 ++--
.../service/accord/AccordSyncPropagator.java | 148 +++---
.../cassandra/service/accord/AccordTopology.java | 46 +-
.../cassandra/service/accord/AccordTracing.java | 46 +-
.../service/accord/AccordVerbHandler.java | 8 +-
.../cassandra/service/accord/EndpointMapping.java | 105 ++++-
.../service/accord/WatermarkCollector.java | 2 +-
.../cassandra/service/accord/api/AccordAgent.java | 47 +-
.../service/accord/api/AccordTopologySorter.java | 62 +--
.../service/accord/api/AccordWaitStrategies.java | 8 +-
.../accord/interop/AccordInteropExecution.java | 26 +-
.../accord/interop/AccordInteropReadCallback.java | 4 +-
.../service/accord/repair/AccordRepair.java | 24 +-
.../accord/serializers/RecoverySerializers.java | 20 +-
.../accord/serializers/ResultSerializers.java | 10 +-
.../accord/serializers/TopologySerializers.java | 155 +++---
.../paxos/uncommitted/PaxosBallotTracker.java | 3 +-
.../org/apache/cassandra/tcm/ClusterMetadata.java | 24 +-
src/java/org/apache/cassandra/tcm/Startup.java | 8 +
.../org/apache/cassandra/tcm/Transformation.java | 2 +
.../cassandra/tcm/sequences/BootstrapAndJoin.java | 32 +-
...rdMarkStale.java => AccordMarkHardRemoved.java} | 93 ++--
.../tcm/transformations/AccordMarkRejoining.java | 6 +-
.../tcm/transformations/AccordMarkStale.java | 28 +-
.../cassandra/utils/LargeBitSetSerializer.java | 80 ----
.../org/apache/cassandra/utils/MerkleTree.java | 2 +-
.../cassandra/utils/SimpleBitSetSerializers.java | 193 ++++++++
.../cassandra/distributed/shared/ClusterUtils.java | 19 +-
.../test/accord/AccordBootstrapTest.java | 281 +++--------
.../test/accord/AccordBootstrapTestBase.java | 165 +++++++
.../AccordCommandStoreTryExecuteListeningTest.java | 145 ++++++
.../distributed/test/accord/AccordMoveTest.java | 139 ++++++
.../test/accord/AccordNodetoolTest.java | 10 +-
.../AccordRecoverFromAvailabilityLossTest.java | 215 +++++++++
.../accord/journal/AccordJournalReplayTest.java | 153 ++++++
...AsHibernatingNodeWithoutReplaceAddressTest.java | 2 +
.../distributed/test/log/CoordinatorPathTest.java | 10 +-
.../test/log/CoordinatorPathTestBase.java | 2 +-
.../fuzz/topology/AccordTopologyMixupTest.java | 4 +-
.../db/virtual/AccordDebugKeyspaceTest.java | 76 +--
.../accord/AccordConfigurationServiceTest.java | 14 +-
.../service/accord/AccordMessageSinkTest.java | 4 +-
.../service/accord/AccordStaleReplicasTest.java | 5 +-
.../service/accord/AccordSyncPropagatorTest.java | 148 +++---
.../cassandra/service/accord/AccordTestUtils.java | 5 +-
.../service/accord/EndpointMappingTest.java | 2 +-
.../cassandra/service/accord/EpochSyncTest.java | 54 +--
.../service/accord/SimpleAccordEndpointMapper.java | 17 +-
.../accord/SimulatedAccordCommandStore.java | 10 +-
.../SimulatedAccordCommandStoreTestBase.java | 2 +-
.../serializers/CommandsForKeySerializerTest.java | 3 +-
.../tcm/sequences/DropAccordTableTest.java | 6 +-
.../apache/cassandra/utils/AccordGenerators.java | 14 +-
.../cassandra/utils/CassandraGenerators.java | 3 +-
.../cassandra/utils/LargeBitSetSerializerTest.java | 2 +-
79 files changed, 2688 insertions(+), 1119 deletions(-)
copy src/java/org/apache/cassandra/tcm/transformations/{AccordMarkStale.java
=> AccordMarkHardRemoved.java} (52%)
delete mode 100644
src/java/org/apache/cassandra/utils/LargeBitSetSerializer.java
create mode 100644
src/java/org/apache/cassandra/utils/SimpleBitSetSerializers.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/AccordBootstrapTestBase.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/AccordCommandStoreTryExecuteListeningTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/AccordMoveTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/AccordRecoverFromAvailabilityLossTest.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/accord/journal/AccordJournalReplayTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
