You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by cl...@apache.org on 2025/04/23 16:07:26 UTC
(cassandra) branch trunk updated (8fcf309dad -> 6753fb49dc)
This is an automated email from the ASF dual-hosted git repository.
clohfink pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from 8fcf309dad Implement appender of slow queries to system_views.slow_queries table
add 6753fb49dc Automated Repair Inside Cassandra for CEP-37
No new revisions were added by this update.
Summary of changes:
CHANGES.txt | 4 +-
NEWS.txt | 5 +
conf/cassandra.yaml | 166 +++
conf/cassandra_latest.yaml | 164 +++
doc/modules/cassandra/nav.adoc | 3 +-
.../pages/managing/operating/auto_repair.adoc | 456 ++++++++
.../cassandra/pages/managing/operating/index.adoc | 3 +-
.../pages/managing/operating/metrics.adoc | 72 +-
.../cassandra/pages/managing/operating/repair.adoc | 19 +-
src/java/org/apache/cassandra/config/Config.java | 11 +
.../cassandra/config/DatabaseDescriptor.java | 37 +
.../apache/cassandra/cql3/UntypedResultSet.java | 8 +
.../cql3/statements/ModificationStatement.java | 2 +-
.../cql3/statements/schema/TableAttributes.java | 4 +
.../cassandra/db/compaction/CompactionManager.java | 4 +-
.../db/streaming/CassandraStreamReceiver.java | 9 +-
.../cassandra/locator/InetAddressAndPort.java | 54 +
.../cassandra/metrics/AutoRepairMetrics.java | 223 ++++
.../AutoRepairMetricsManager.java} | 32 +-
.../metrics/CassandraMetricsRegistry.java | 53 +-
.../apache/cassandra/metrics/KeyspaceMetrics.java | 10 +
.../org/apache/cassandra/metrics/TableMetrics.java | 39 +-
.../apache/cassandra/repair/PreviewRepairTask.java | 18 +-
.../cassandra/repair/RepairMessageVerbHandler.java | 7 +
.../apache/cassandra/repair/ValidationManager.java | 5 +
.../cassandra/repair/autorepair/AutoRepair.java | 568 ++++++++++
.../repair/autorepair/AutoRepairConfig.java | 599 ++++++++++
.../repair/autorepair/AutoRepairState.java | 326 ++++++
.../repair/autorepair/AutoRepairUtils.java | 1189 ++++++++++++++++++++
.../autorepair/FixedSplitTokenRangeSplitter.java | 156 +++
.../autorepair/IAutoRepairTokenRangeSplitter.java | 71 ++
.../autorepair/KeyspaceRepairAssignments.java} | 45 +-
.../autorepair/KeyspaceRepairPlan.java} | 53 +-
.../repair/autorepair/PrioritizedRepairPlan.java | 160 +++
.../repair/autorepair/RepairAssignment.java | 84 ++
.../autorepair/RepairAssignmentIterator.java | 84 ++
.../autorepair/RepairTokenRangeSplitter.java | 949 ++++++++++++++++
.../repair/consistent/SyncStatSummary.java | 22 +-
.../apache/cassandra/schema/AutoRepairParams.java | 189 ++++
.../apache/cassandra/schema/SchemaKeyspace.java | 18 +-
.../schema/SystemDistributedKeyspace.java | 34 +-
.../org/apache/cassandra/schema/TableParams.java | 34 +-
.../cassandra/service/ActiveRepairService.java | 32 +
.../service/ActiveRepairServiceMBean.java | 4 +
.../cassandra/service/AutoRepairService.java | 326 ++++++
.../cassandra/service/AutoRepairServiceMBean.java | 77 ++
.../apache/cassandra/service/CassandraDaemon.java | 2 +
.../apache/cassandra/service/StorageService.java | 79 +-
.../cassandra/service/StorageServiceMBean.java | 5 +
.../cassandra/tcm/sequences/BootstrapAndJoin.java | 4 +
.../tcm/sequences/BootstrapAndReplace.java | 4 +
.../tcm/sequences/ReplaceSameAddress.java | 4 +
src/java/org/apache/cassandra/tools/NodeProbe.java | 141 +++
src/java/org/apache/cassandra/tools/NodeTool.java | 4 +
.../cassandra/tools/nodetool/AutoRepairStatus.java | 79 ++
.../{GetSeeds.java => GetAutoRepairConfig.java} | 27 +-
.../tools/nodetool/SSTableRepairedSet.java | 108 ++
.../tools/nodetool/SetAutoRepairConfig.java | 178 +++
...owParallelReplicaRepairAcrossSchedulesTest.java | 129 +++
.../test/repair/AutoRepairSchedulerTest.java | 196 ++++
test/unit/org/apache/cassandra/Util.java | 13 +
.../config/DatabaseDescriptorRefTest.java | 11 +
.../config/YamlConfigurationLoaderTest.java | 28 +-
test/unit/org/apache/cassandra/cql3/CQLTester.java | 6 +-
.../cql3/statements/DescribeStatementTest.java | 149 ++-
.../db/streaming/CassandraStreamReceiverTest.java | 153 +++
.../autorepair/AutoRepairConfigRepairTypeTest.java | 60 +
.../repair/autorepair/AutoRepairConfigTest.java | 509 +++++++++
.../repair/autorepair/AutoRepairKeyspaceTest.java | 59 +
.../repair/autorepair/AutoRepairMetricsTest.java | 92 ++
.../autorepair/AutoRepairParameterizedTest.java | 903 +++++++++++++++
.../autorepair/AutoRepairStateFactoryTest.java | 65 ++
.../repair/autorepair/AutoRepairStateTest.java | 319 ++++++
.../autorepair/AutoRepairTablePropertyTest.java | 85 ++
.../repair/autorepair/AutoRepairTest.java | 164 +++
.../repair/autorepair/AutoRepairUtilsTest.java | 491 ++++++++
.../FixedSplitTokenRangeSplitterHelper.java | 201 ++++
.../FixedSplitTokenRangeSplitterNoVNodesTest.java | 82 ++
.../FixedSplitTokenRangeSplitterVNodesTest.java | 82 ++
.../autorepair/PrioritizedRepairPlanTest.java | 164 +++
.../autorepair/RepairTokenRangeSplitterTest.java | 465 ++++++++
.../repair/autorepair/SSTableRepairedAtTest.java | 175 +++
.../cassandra/service/ActiveRepairServiceTest.java | 110 +-
.../service/AutoRepairServiceBasicTest.java | 151 +++
.../service/AutoRepairServiceRepairTypeTest.java | 88 ++
.../service/AutoRepairServiceSetterTest.java | 153 +++
.../apache/cassandra/tools/JMXStandardsTest.java | 7 +
.../tools/nodetool/AutoRepairStatusTest.java | 108 ++
.../tools/nodetool/SSTableRepairedSetTest.java | 132 +++
.../tools/nodetool/SetAutoRepairConfigTest.java | 318 ++++++
90 files changed, 12500 insertions(+), 231 deletions(-)
create mode 100644 doc/modules/cassandra/pages/managing/operating/auto_repair.adoc
create mode 100644 src/java/org/apache/cassandra/metrics/AutoRepairMetrics.java
copy src/java/org/apache/cassandra/{audit/NoOpAuditLogger.java => metrics/AutoRepairMetricsManager.java} (61%)
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/AutoRepair.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/AutoRepairConfig.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/AutoRepairState.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/AutoRepairUtils.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/FixedSplitTokenRangeSplitter.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/IAutoRepairTokenRangeSplitter.java
copy src/java/org/apache/cassandra/{cql3/conditions/AbstractConditions.java => repair/autorepair/KeyspaceRepairAssignments.java} (53%)
copy src/java/org/apache/cassandra/{index/accord/Group.java => repair/autorepair/KeyspaceRepairPlan.java} (54%)
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/PrioritizedRepairPlan.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/RepairAssignment.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/RepairAssignmentIterator.java
create mode 100644 src/java/org/apache/cassandra/repair/autorepair/RepairTokenRangeSplitter.java
create mode 100644 src/java/org/apache/cassandra/schema/AutoRepairParams.java
create mode 100644 src/java/org/apache/cassandra/service/AutoRepairService.java
create mode 100644 src/java/org/apache/cassandra/service/AutoRepairServiceMBean.java
create mode 100644 src/java/org/apache/cassandra/tools/nodetool/AutoRepairStatus.java
copy src/java/org/apache/cassandra/tools/nodetool/{GetSeeds.java => GetAutoRepairConfig.java} (67%)
create mode 100644 src/java/org/apache/cassandra/tools/nodetool/SSTableRepairedSet.java
create mode 100644 src/java/org/apache/cassandra/tools/nodetool/SetAutoRepairConfig.java
create mode 100644 test/distributed/org/apache/cassandra/distributed/test/repair/AutoRepairSchedulerDisallowParallelReplicaRepairAcrossSchedulesTest.java
create mode 100644 test/distributed/org/apache/cassandra/distributed/test/repair/AutoRepairSchedulerTest.java
create mode 100644 test/unit/org/apache/cassandra/db/streaming/CassandraStreamReceiverTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairConfigRepairTypeTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairConfigTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairKeyspaceTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairMetricsTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairParameterizedTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairStateFactoryTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairStateTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairTablePropertyTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/AutoRepairUtilsTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/FixedSplitTokenRangeSplitterHelper.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/FixedSplitTokenRangeSplitterNoVNodesTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/FixedSplitTokenRangeSplitterVNodesTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/PrioritizedRepairPlanTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/RepairTokenRangeSplitterTest.java
create mode 100644 test/unit/org/apache/cassandra/repair/autorepair/SSTableRepairedAtTest.java
create mode 100644 test/unit/org/apache/cassandra/service/AutoRepairServiceBasicTest.java
create mode 100644 test/unit/org/apache/cassandra/service/AutoRepairServiceRepairTypeTest.java
create mode 100644 test/unit/org/apache/cassandra/service/AutoRepairServiceSetterTest.java
create mode 100644 test/unit/org/apache/cassandra/tools/nodetool/AutoRepairStatusTest.java
create mode 100644 test/unit/org/apache/cassandra/tools/nodetool/SSTableRepairedSetTest.java
create mode 100644 test/unit/org/apache/cassandra/tools/nodetool/SetAutoRepairConfigTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org