From 8bf72a940f41af572a8240e8187d2efd0a834e2f Mon Sep 17 00:00:00 2001 From: Ayman Khalil <13960949+aymkhalil@users.noreply.github.com> Date: Tue, 15 Oct 2024 13:37:53 -0700 Subject: [PATCH] Fix typo --- .../apache/cassandra/config/CassandraRelevantProperties.java | 2 +- src/java/org/apache/cassandra/service/StorageProxy.java | 4 ++-- .../cassandra/distributed/test/sensors/SensorsTest.java | 2 +- 3 files changed, 4 insertions(+), 4 deletions(-) diff --git a/src/java/org/apache/cassandra/config/CassandraRelevantProperties.java b/src/java/org/apache/cassandra/config/CassandraRelevantProperties.java index a23bee0356fe..efae4a6fb1c9 100644 --- a/src/java/org/apache/cassandra/config/CassandraRelevantProperties.java +++ b/src/java/org/apache/cassandra/config/CassandraRelevantProperties.java @@ -509,7 +509,7 @@ public enum CassandraRelevantProperties /** * If true, the coordinator will propagate request sensors via the native protocol custom payload flag. */ - PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCAL("cassandra.propagate_request_sensors_via_native_protocal", "false");; + PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCOL("cassandra.propagate_request_sensors_via_native_protocol", "false");; CassandraRelevantProperties(String key, String defaultVal) { diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index 0a5537aa99f7..149c8483c797 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -1072,7 +1072,7 @@ public static void mutate(List mutations, QueryInfoTracker.WriteTracker writeTracker = queryTracker().onWrite(state, false, mutations, consistencyLevel); // Request sensors are utilized to track usages from replicas serving a write request - RequestSensors requestSensors = CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCAL.getBoolean() ? + RequestSensors requestSensors = CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCOL.getBoolean() ? new ActiveRequestSensors() : NoOpRequestSensors.instance; ExecutorLocals locals = ExecutorLocals.create(requestSensors); ExecutorLocals.set(locals); @@ -1970,7 +1970,7 @@ public static PartitionIterator read(SinglePartitionReadCommand.Group group, group.queries, consistencyLevel); // Request sensors are utilized to track usages from replicas serving a read request - RequestSensors requestSensors = CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCAL.getBoolean() ? + RequestSensors requestSensors = CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCOL.getBoolean() ? new ActiveRequestSensors() : NoOpRequestSensors.instance; Context context = Context.from(group.metadata()); requestSensors.registerSensor(context, Type.READ_BYTES); diff --git a/test/distributed/org/apache/cassandra/distributed/test/sensors/SensorsTest.java b/test/distributed/org/apache/cassandra/distributed/test/sensors/SensorsTest.java index 845151b41194..57d51a3270c8 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/sensors/SensorsTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/sensors/SensorsTest.java @@ -61,7 +61,7 @@ public static void setup() @Test public void testSensorsInResultMessage() throws Throwable { - CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCAL.setBoolean(true); + CassandraRelevantProperties.PROPAGATE_REQUEST_SENSORS_VIA_NATIVE_PROTOCOL.setBoolean(true); try (Cluster cluster = builder().withNodes(1).start()) { // resister a noop sensor listener before init(cluster) which creates the test keyspace to ensure that the registry singleton instance is subscribed to schema notifications