Skip to content

Commit

Permalink
Fix typo
Browse files Browse the repository at this point in the history
  • Loading branch information
aymkhalil committed Oct 15, 2024
1 parent ee9566e commit 8bf72a9
Show file tree
Hide file tree
Showing 3 changed files with 4 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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)
{
Expand Down
4 changes: 2 additions & 2 deletions src/java/org/apache/cassandra/service/StorageProxy.java
Original file line number Diff line number Diff line change
Expand Up @@ -1072,7 +1072,7 @@ public static void mutate(List<? extends IMutation> 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);
Expand Down Expand Up @@ -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);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

1 comment on commit 8bf72a9

@cassci-bot
Copy link

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Build rejected: 10 NEW test failure(s) in 4 builds., Build ds-cassandra-pr-gate > cndb-8501 > #4: ran 18071 tests with 27 failures and 133 skipped.
Butler analysis done on ds-cassandra-pr-gate/cndb-8501 vs last 16 runs of ds-cassandra-build-nightly/main.
org.apache.cassandra.distributed.test.NodeToolEnableDisableBinaryTest.testMaybeChangeDocs: test failed in the recent build. No failures on upstream;
branch story: [F+++] vs upstream: [++++++++++++++]; [NEW]
org.apache.cassandra.index.sai.cql.TinySegmentQueryRowDeletionsTest.testRowDeletions[aa_CompositePartitionKeyDataModel{primaryKey=p1, p2}]: test looks flaky. No failures on upstream;
branch story: [+F++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.index.sai.cql.TinySegmentQueryWriteLifecycleTest.testWriteLifecycle[aa_BaseDataModel{primaryKey=p}]: test is constantly failing. No failures on upstream;
branch story: [FF] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.index.sai.cql.QueryWriteLifecycleTest.testWriteLifecycle[ca_CompositePartitionKeyDataModel{primaryKey=p1, p2}]: test is constantly failing. No failures on upstream;
branch story: [F] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.db.CounterMutationCallbackTest.testCounterMutationCallback[(2,2)]: test failed in the recent build. No failures on upstream;
branch story: [FF++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.db.CounterMutationCallbackTest.testCounterMutationCallback[(0,1)]: test failed in the recent build. No failures on upstream;
branch story: [FF++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.db.CounterMutationCallbackTest.testCounterMutationCallback[(3,3)]: test failed in the recent build. No failures on upstream;
branch story: [FF++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.index.sai.disk.vector.VectorCompressionTest.testAda002: test looks flaky. No failures on upstream;
branch story: [+F++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.db.CounterMutationCallbackTest.testCounterMutationCallback[(1,1)]: test failed in the recent build. No failures on upstream;
branch story: [FF++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
org.apache.cassandra.index.sai.cql.types.collections.sets.SetFrozenCollectionTest.test[version=db,dataset=set<frozen<set>>,wide=false,scenario=COMPACTED_QUERY]: test failed in the recent build. No failures on upstream;
branch story: [F+++] vs upstream: [++++++++++++++++++++++++++++++++++++++++++++++++++++++++]; [NEW]
butler comparison

Please sign in to comment.