This is an automated email from the ASF dual-hosted git repository.
belliottsmith pushed a change to branch cassandra-6.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 51a58ef22e Merge branch 'cassandra-5.0' into cassandra-6.0
add 8ad8e56378 Artificial Latency Injection
add 41cf61402c Improve Tail Latency - TransactionStatement token aware
routing - Mitigate convoy effect: - ExecuteTxnBacklog v1 can execute single
key transaction backlogs and disseminate the result - Direct local
execution possible for single key transactions - Use shardAppliedBefore
instead of gcBefore to cleanup CFK faster Also Improve: - Introduce
distributed tracing - Combine RejectBefore and MaxConflicts - Self-addressed
messages are delivered directly - Disabl [...]
No new revisions were added by this update.
Summary of changes:
.build/checkstyle.xml | 12 +-
CHANGES.txt | 3 +
modules/accord | 2 +-
.../cassandra/concurrent/ExecutorLocals.java | 15 +-
.../config/{AccordSpec.java => AccordConfig.java} | 117 ++-
.../config/CassandraRelevantProperties.java | 5 +
src/java/org/apache/cassandra/config/Config.java | 4 +-
.../cassandra/config/DatabaseDescriptor.java | 25 +-
src/java/org/apache/cassandra/cql3/Attributes.java | 4 +-
.../apache/cassandra/cql3/ColumnsExpression.java | 4 +-
.../apache/cassandra/cql3/ElementExpression.java | 4 +-
src/java/org/apache/cassandra/cql3/Json.java | 4 +-
src/java/org/apache/cassandra/cql3/Operation.java | 7 +-
src/java/org/apache/cassandra/cql3/Ordering.java | 12 +-
.../org/apache/cassandra/cql3/QueryOptions.java | 23 +-
src/java/org/apache/cassandra/cql3/Relation.java | 6 +-
.../cassandra/cql3/VariableSpecifications.java | 19 +-
.../cassandra/cql3/conditions/ColumnCondition.java | 6 +-
.../cassandra/cql3/functions/FunctionCall.java | 4 +-
.../cql3/restrictions/CustomIndexExpression.java | 4 +-
.../cql3/restrictions/StatementRestrictions.java | 12 +-
.../cassandra/cql3/selection/Selectable.java | 8 +-
.../cassandra/cql3/statements/BatchStatement.java | 2 +-
.../cassandra/cql3/statements/DeleteStatement.java | 4 +-
.../cql3/statements/ModificationStatement.java | 9 +-
.../cassandra/cql3/statements/SelectStatement.java | 7 +-
.../cql3/statements/TransactionStatement.java | 20 +
.../cassandra/cql3/statements/UpdateStatement.java | 11 +-
.../statements/schema/CreateViewStatement.java | 1 +
.../org/apache/cassandra/cql3/terms/InMarker.java | 4 +-
.../org/apache/cassandra/cql3/terms/Lists.java | 6 +-
src/java/org/apache/cassandra/cql3/terms/Maps.java | 6 +-
.../org/apache/cassandra/cql3/terms/Marker.java | 4 +-
.../apache/cassandra/cql3/terms/MultiElements.java | 4 +-
src/java/org/apache/cassandra/cql3/terms/Term.java | 7 +-
.../org/apache/cassandra/cql3/terms/Terms.java | 15 +-
.../cql3/transactions/ConditionStatement.java | 6 +-
.../cql3/transactions/RowDataReference.java | 4 +-
.../org/apache/cassandra/db/ConsistencyLevel.java | 35 +-
src/java/org/apache/cassandra/db/ReadCommand.java | 8 +-
.../cassandra/db/virtual/AccordDebugKeyspace.java | 58 +-
src/java/org/apache/cassandra/journal/Segment.java | 9 +-
.../org/apache/cassandra/locator/ReplicaPlans.java | 4 +-
.../metrics/AccordCoordinatorMetrics.java | 5 +
.../cassandra/metrics/AccordExecutorMetrics.java | 1 +
.../metrics/LogLinearDecayingHistograms.java | 7 +
.../cassandra/metrics/LogLinearHistogram.java | 6 +
.../metrics/ShardedDecayingHistograms.java | 48 ++
.../apache/cassandra/metrics/ShardedHistogram.java | 16 +
.../apache/cassandra/net/ArtificialLatency.java | 402 +++++++++++
.../cassandra/net/InboundMessageHandler.java | 2 +
src/java/org/apache/cassandra/net/Message.java | 71 +-
src/java/org/apache/cassandra/net/MessageFlag.java | 13 +-
.../apache/cassandra/net/OutboundConnection.java | 2 +
.../org/apache/cassandra/net/OutboundSink.java | 104 ++-
src/java/org/apache/cassandra/net/ParamType.java | 5 +-
.../org/apache/cassandra/net/ResponseContext.java | 23 +
.../apache/cassandra/net/ResponseVerbHandler.java | 6 +-
src/java/org/apache/cassandra/net/Verb.java | 16 +-
.../org/apache/cassandra/service/ClientWarn.java | 2 +-
.../org/apache/cassandra/service/StorageProxy.java | 36 +-
.../cassandra/service/StorageProxyMBean.java | 9 +
.../cassandra/service/accord/AccordCache.java | 13 +-
.../service/accord/AccordCommandStore.java | 43 +-
.../service/accord/AccordCommandStores.java | 4 +-
.../cassandra/service/accord/AccordExecutor.java | 430 ++++++++---
.../accord/AccordExecutorAbstractLockLoop.java | 101 +--
.../AccordExecutorAbstractSemiSyncSubmit.java | 15 +-
.../accord/AccordExecutorSemiSyncSubmit.java | 38 +-
.../service/accord/AccordExecutorSimple.java | 11 +-
.../service/accord/AccordExecutorSyncSubmit.java | 12 +-
.../cassandra/service/accord/AccordKeyspace.java | 4 +-
.../service/accord/AccordMessageSink.java | 51 +-
.../service/accord/AccordObjectSizes.java | 55 +-
.../service/accord/AccordSafeCommandStore.java | 4 +-
.../service/accord/AccordSafeCommandsForKey.java | 25 +
.../cassandra/service/accord/AccordService.java | 84 ++-
.../cassandra/service/accord/AccordTask.java | 111 +--
.../service/accord/AccordVerbHandler.java | 13 +
.../cassandra/service/accord/RangeIndex.java | 6 +-
.../cassandra/service/accord/TokenRange.java | 5 +-
.../cassandra/service/accord/api/AccordAgent.java | 77 +-
.../service/accord/api/AccordScheduler.java | 9 +-
.../service/accord/api/AccordTimeService.java | 13 +-
.../service/accord/api/AccordWaitStrategies.java | 4 +-
.../service/accord/debug/AccordRemoteTracing.java | 385 ++++++++++
.../service/accord/debug/AccordTracing.java | 516 ++++++++++++--
.../service/accord/debug/DebugExecution.java | 242 +++++++
.../service/accord/interop/AccordInteropApply.java | 6 +-
.../accord/interop/AccordInteropExecution.java | 12 +-
.../accord/interop/AccordInteropPersist.java | 132 +---
.../service/accord/interop/AccordInteropRead.java | 2 +
.../service/accord/journal/AccordJournal.java | 16 +-
.../cassandra/service/accord/journal/Replay.java | 2 +-
.../serializers/CommandStoreSerializers.java | 70 +-
.../serializers/RemoteSuccessSerializers.java | 56 ++
.../accord/topology/AccordTopologyService.java | 37 +-
.../service/accord/topology/FastPathStrategy.java | 20 +-
.../accord/topology/SimpleFastPathStrategy.java | 25 +-
...stPathStrategy.java => UpFastPathStrategy.java} | 15 +-
.../accord/topology/WatermarkCollector.java | 18 +-
.../cassandra/service/accord/txn/TxnData.java | 8 +-
.../cassandra/service/accord/txn/TxnUpdate.java | 2 +-
.../cassandra/service/accord/txn/TxnWrite.java | 8 +-
.../service/reads/AbstractReadExecutor.java | 1 -
.../cassandra/tcm/transformations/AlterSchema.java | 4 +-
.../cassandra/tools/StandaloneJournalUtil.java | 6 +-
src/java/org/apache/cassandra/tracing/Tracing.java | 11 +-
.../transport/messages/ExecuteMessage.java | 4 +
src/java/org/apache/cassandra/utils/Clock.java | 30 +
.../org/apache/cassandra/utils/MonotonicClock.java | 34 +-
.../cassandra/utils/MonotonicClockTranslation.java | 3 +-
.../utils/concurrent/ConcurrentLinkedStack.java | 4 +-
.../utils/concurrent/LockWithAsyncSignal.java | 1 +
test/conf/cassandra.yaml | 7 +-
.../{logback-dtest-quiet.xml => logback-error.xml} | 6 +-
.../distributed/impl/CoordinatorHelper.java | 1 +
.../cassandra/distributed/impl/Instance.java | 8 +-
.../cassandra/distributed/impl/InstanceConfig.java | 16 +-
.../test/accord/AccordDropTableBase.java | 2 +-
.../test/accord/AccordInteroperabilityTest.java | 9 +-
.../distributed/test/accord/AccordLoadTest.java | 787 +++++++++++++++++----
.../distributed/test/accord/AccordMetricsTest.java | 10 +-
.../distributed/test/accord/AccordTestBase.java | 6 +-
.../accord/AccordWriteInteroperabilityTest.java | 1 +
.../accord/MigrationFromAccordReadRaceTest.java | 3 +
.../accord/MigrationFromAccordWriteRaceTest.java | 3 +
.../accord/MigrationToAccordWriteRaceTest.java | 3 +
.../FullAccordInteropMultiNodeTableWalkTest.java | 3 +
...edReadsAccordInteropMultiNodeTableWalkTest.java | 3 +
.../test/log/ClusterMetadataTestHelper.java | 3 +-
.../accord/journal/AccordJournalBurnTest.java | 2 +-
.../cassandra/simulator/ClusterSimulation.java | 1 +
.../simulator/systems/SimulatedAction.java | 4 +-
.../cassandra/simulator/systems/SimulatedTime.java | 6 +-
.../test/AccordJournalSimulationTest.java | 4 +-
.../concurrent/LocalAwareExecutorPlusTest.java | 2 +-
.../config/DatabaseDescriptorRefTest.java | 29 +-
.../config/YamlConfigurationLoaderTest.java | 2 +-
.../db/ReadCommandVerbHandlerOutOfRangeTest.java | 2 +-
.../cassandra/db/ReadCommandVerbHandlerTest.java | 2 +-
.../db/compaction/AbstractPendingRepairTest.java | 2 +-
.../compaction/CompactionAccordIteratorsTest.java | 2 +
.../db/compaction/CompactionIteratorTest.java | 2 +-
.../CompressionDictionaryEventHandlerTest.java | 4 +-
.../db/transform/DuplicateRowCheckerTest.java | 2 +-
.../db/virtual/AccordDebugKeyspaceTest.java | 19 +-
.../cassandra/index/accord/RouteIndexTest.java | 8 +-
.../index/internal/CassandraIndexTest.java | 2 +-
.../org/apache/cassandra/net/MatcherResponse.java | 10 +-
.../unit/org/apache/cassandra/net/MessageTest.java | 4 +-
.../cassandra/net/SimulatedMessageDelivery.java | 2 +-
.../net/StartupClusterConnectivityCheckerTest.java | 5 +-
.../org/apache/cassandra/repair/RepairJobTest.java | 4 +-
.../org/apache/cassandra/repair/ValidatorTest.java | 2 +-
.../service/accord/AccordCommandTest.java | 10 +-
.../service/accord/AccordMessageSinkTest.java | 5 +-
.../service/accord/AccordReadRepairTest.java | 5 +-
.../cassandra/service/accord/AccordTestUtils.java | 13 +-
.../service/accord/AccordTopologyTest.java | 2 +-
.../service/accord/CommandChangeTest.java | 9 +-
.../cassandra/service/accord/EpochSyncTest.java | 4 +-
.../accord/SimulatedAccordCommandStore.java | 16 +-
.../SimulatedAccordCommandStoreTestBase.java | 11 +-
.../service/accord/SimulatedAccordTaskTest.java | 2 +-
.../serializers/CommandsForKeySerializerTest.java | 146 ++--
...rategyTest.java => UpFastPathStrategyTest.java} | 4 +-
.../cassandra/tcm/DiscoverySimulationTest.java | 2 +-
.../apache/cassandra/utils/AccordGenerators.java | 71 +-
.../cassandra/utils/CassandraGenerators.java | 3 +
.../cassandra/utils/FixedMonotonicClock.java | 4 +-
.../apache/cassandra/utils/FreeRunningClock.java | 4 +-
172 files changed, 4085 insertions(+), 1315 deletions(-)
rename src/java/org/apache/cassandra/config/{AccordSpec.java =>
AccordConfig.java} (75%)
create mode 100644 src/java/org/apache/cassandra/net/ArtificialLatency.java
create mode 100644
src/java/org/apache/cassandra/service/accord/debug/AccordRemoteTracing.java
create mode 100644
src/java/org/apache/cassandra/service/accord/debug/DebugExecution.java
create mode 100644
src/java/org/apache/cassandra/service/accord/serializers/RemoteSuccessSerializers.java
copy
src/java/org/apache/cassandra/service/accord/topology/{SimpleFastPathStrategy.java
=> UpFastPathStrategy.java} (87%)
copy test/conf/{logback-dtest-quiet.xml => logback-error.xml} (96%)
rename
test/unit/org/apache/cassandra/service/accord/topology/{SimpleFastPathStrategyTest.java
=> UpFastPathStrategyTest.java} (93%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
