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