This is an automated email from the ASF dual-hosted git repository.
bdeggleston pushed a change to branch cep-58-satellite-datacenters
in repository https://gitbox.apache.org/repos/asf/cassandra.git
from ffdd6c07b6 Ninja: fix MultiNodeTableWalkWithoutReadRepairTest
add 5bff4a7bec CEP-45: Add feature flag for Mutation Tracking
No new revisions were added by this update.
Summary of changes:
.../config/CassandraRelevantProperties.java | 1 +
src/java/org/apache/cassandra/config/Config.java | 2 +-
.../cassandra/config/DatabaseDescriptor.java | 22 ++-
...RepairConfig.java => MutationTrackingSpec.java} | 5 +-
.../cql3/statements/ModificationStatement.java | 2 +-
.../statements/schema/AlterKeyspaceStatement.java | 34 +++-
.../statements/schema/CreateKeyspaceStatement.java | 40 +++--
.../org/apache/cassandra/db/ColumnFamilyStore.java | 10 +-
src/java/org/apache/cassandra/db/Keyspace.java | 5 +-
.../cassandra/db/PartitionRangeReadCommand.java | 2 +-
.../org/apache/cassandra/db/SSTableImporter.java | 2 +-
.../cassandra/db/SinglePartitionReadCommand.java | 2 +-
.../org/apache/cassandra/db/SystemKeyspace.java | 60 +++----
.../cassandra/db/compaction/CompactionTask.java | 2 +-
.../db/streaming/CassandraStreamReceiver.java | 2 +-
.../db/tracked/TrackedKeyspaceWriteHandler.java | 2 +-
.../cassandra/db/virtual/MutationJournalTable.java | 80 ---------
.../db/virtual/MutationTrackingShardsTable.java | 110 ------------
.../db/virtual/MutationTrackingTables.java | 186 +++++++++++++++++++++
.../cassandra/db/virtual/SystemViewsKeyspace.java | 3 +-
.../cassandra/io/sstable/format/SSTableWriter.java | 2 +-
.../metrics/CassandraMetricsRegistry.java | 98 +++++------
.../cassandra/metrics/MutationTrackingMetrics.java | 16 +-
.../org/apache/cassandra/repair/SyncTasks.java | 2 +-
.../cassandra/replication/ActivationRequest.java | 2 +-
.../cassandra/replication/ActiveLogReconciler.java | 12 +-
.../cassandra/replication/BroadcastLogOffsets.java | 3 +-
.../cassandra/replication/CoordinatedTransfer.java | 2 +-
.../cassandra/replication/CoordinatorLog.java | 4 +-
.../cassandra/replication/ForwardedWrite.java | 7 +-
.../cassandra/replication/MutationJournal.java | 33 +++-
.../replication/MutationTrackingService.java | 76 +++++++--
.../replication/PullMutationsRequest.java | 3 +-
.../cassandra/replication/PushMutationRequest.java | 5 +-
.../cassandra/replication/TrackedWriteRequest.java | 4 +-
.../replication/UnreconciledMutations.java | 2 +-
.../apache/cassandra/service/CassandraDaemon.java | 6 +-
.../org/apache/cassandra/service/StorageProxy.java | 4 +-
.../apache/cassandra/service/StorageService.java | 4 +-
.../service/TrackedWriteResponseHandler.java | 4 +-
.../cassandra/service/paxos/PaxosCommit.java | 12 +-
.../service/paxos/PaxosPrepareRefresh.java | 2 +-
.../apache/cassandra/service/paxos/PaxosState.java | 4 +-
.../paxos/PrepareRefreshForwardHandler.java | 2 +-
.../service/reads/tracked/PartialTrackedRead.java | 2 +-
.../service/reads/tracked/ReadReconcileAck.java | 2 +
.../service/reads/tracked/ReadReconciliations.java | 8 +-
.../service/reads/tracked/TrackedRead.java | 7 +-
.../reads/tracked/TrackedSummaryResponse.java | 2 +
.../apache/cassandra/streaming/StreamSession.java | 6 +-
.../messages/IncomingMutationLogStreamMessage.java | 2 +-
src/java/org/apache/cassandra/tcm/Startup.java | 24 ++-
test/conf/cassandra-jmx-disabled-sslconfig.yaml | 6 +-
test/conf/cassandra-jmx-pem-sslconfig.yaml | 6 +-
.../cassandra-jmx-sslconfig-with-passwordfile.yaml | 6 +-
test/conf/cassandra-jmx-sslconfig.yaml | 6 +-
test/conf/cassandra-mtls.yaml | 2 +
test/conf/cassandra-murmur.yaml | 2 +
test/conf/cassandra-old.yaml | 4 +-
test/conf/cassandra-pem-jks-sslcontextfactory.yaml | 2 +
...pem-sslcontextfactory-invalidconfiguration.yaml | 2 +
test/conf/cassandra-pem-sslcontextfactory.yaml | 2 +
test/conf/cassandra-seeds.yaml | 2 +
...dra-sslcontextfactory-invalidconfiguration.yaml | 2 +
test/conf/cassandra-sslcontextfactory.yaml | 2 +
test/conf/cassandra.yaml | 4 +
.../cassandra/distributed/impl/Instance.java | 10 +-
.../cassandra/distributed/impl/InstanceConfig.java | 9 +
.../test/MutationTrackingMigrationTest.java | 2 +-
.../distributed/test/TrackedBatchTest.java | 6 +-
.../test/TransientRangeMovement2Test.java | 3 -
.../test/TransientRangeMovementTest.java | 3 -
.../test/WitnessAlwaysReadsFullReplicaTest.java | 1 -
...MultiNodeTableWalkWithMutationTrackingTest.java | 1 -
.../TrackedHostReplacementTest.java | 4 +-
.../test/log/MetadataChangeSimulationTest.java | 1 -
.../distributed/test/log/NTSSimulationTest.java | 1 -
.../test/log/OperationalEquivalenceTest.java | 1 -
.../test/log/SimpleStrategySimulationTest.java | 1 -
.../replication/MutationTrackingServiceTest.java | 2 +-
.../test/tracking/MutationTrackingBounceTest.java | 2 +-
.../MutationTrackingBounce_ValidateRunnable.java | 4 +-
.../MutationTrackingCasForwardingTest.java | 9 +-
.../MutationTrackingCommitAndPrepareTest.java | 8 +-
.../tracking/MutationTrackingFeatureFlagTest.java | 116 +++++++++++++
.../tracking/MutationTrackingLogPersisterTest.java | 13 +-
.../test/tracking/MutationTrackingMetricsTest.java | 50 +++---
.../MutationTrackingPartitionReadTest.java | 1 -
.../tracking/MutationTrackingPendingReadTest.java | 12 +-
.../tracking/MutationTrackingRangeReadTest.java | 4 +-
.../MutationTrackingReadReconciliationTest.java | 20 +--
.../test/tracking/MutationTrackingTest.java | 52 +++---
.../test/tracking/MutationTrackingUtils.java | 6 +-
.../MutationTrackingWriteForwardingTest.java | 9 +-
.../test/tracking/OffsetBroadcastTest.java | 8 +-
.../test/tracking/TrackedTransferTestBase.java | 7 +-
.../db/commitlog/CommitLogStressTest.java | 2 +-
.../cassandra/simulator/ClusterSimulation.java | 2 +-
.../unit/org/apache/cassandra/ServerTestUtils.java | 2 +-
.../config/DatabaseDescriptorRefTest.java | 1 +
.../apache/cassandra/db/CleanupTransientTest.java | 5 +-
.../db/CoordinatorLogOffsetsLifecycleTest.java | 6 +-
...onTrackingMutationVerbHandlerMigrationTest.java | 3 +-
.../db/MutationVerbHandlerOutOfRangeTest.java | 3 +-
.../db/ReadCommandVerbHandlerOutOfRangeTest.java | 2 +-
.../cassandra/db/ReadCommandVerbHandlerTest.java | 2 +-
.../db/virtual/MutationJournalTableTest.java | 4 +-
.../virtual/MutationTrackingShardsTableTest.java | 8 +-
.../org/apache/cassandra/dht/BootStrapperTest.java | 2 +-
.../cassandra/locator/SimpleStrategyTest.java | 1 -
.../RepairMessageVerbHandlerOutOfRangeTest.java | 2 +-
.../replication/CoordinatorLogOffsetsTest.java | 58 +++----
.../cassandra/replication/CoordinatorLogTest.java | 6 +-
.../cassandra/replication/MutationJournalTest.java | 2 +-
.../apache/cassandra/replication/ShardTest.java | 2 +-
.../replication/UnreconciledMutationsTest.java | 6 +-
.../cassandra/service/BootstrapTransientTest.java | 1 -
.../cassandra/service/JoinTokenRingTest.java | 2 +-
.../apache/cassandra/service/PaxosStateTest.java | 2 +-
.../cassandra/service/StorageServiceTest.java | 2 +-
.../service/WriteResponseHandlerTransientTest.java | 3 +-
.../cassandra/service/paxos/PaxosStateTest.java | 2 +-
.../paxos/PaxosVerbHandlerOutOfRangeTest.java | 2 +-
.../reads/repair/RepairedDataVerifierTest.java | 2 +-
.../cassandra/streaming/StreamReaderTest.java | 2 +-
.../streaming/StreamSessionOwnedRangesTest.java | 2 +-
.../AlterSchemaMutationTrackingTest.java | 2 +-
127 files changed, 890 insertions(+), 599 deletions(-)
copy src/java/org/apache/cassandra/config/{RepairConfig.java =>
MutationTrackingSpec.java} (88%)
delete mode 100644
src/java/org/apache/cassandra/db/virtual/MutationJournalTable.java
delete mode 100644
src/java/org/apache/cassandra/db/virtual/MutationTrackingShardsTable.java
create mode 100644
src/java/org/apache/cassandra/db/virtual/MutationTrackingTables.java
create mode 100644
test/distributed/org/apache/cassandra/distributed/test/tracking/MutationTrackingFeatureFlagTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
