natas_hw
/
cassandra
mirror of https://github.com/apache/cassandra
0
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ninja fix: ensure defaultReadThresholds is cleared for CASSANDRA-21467

This commit is contained in:
Francisco Guerrero 2026-07-27 09:19:40 -05:00
parent c4c3048b13
commit 3cae8aa6f6
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/java/org/apache/cassandra/config/DatabaseDescriptor.java
View File

@ -334,6 +334,7 @@ public class DatabaseDescriptor
private static void clear() private static void clear()
{ {
sstableFormats = null; sstableFormats = null;
defaultReadThresholds = null;
clearMBean("org.apache.cassandra.db:type=DynamicEndpointSnitch"); clearMBean("org.apache.cassandra.db:type=DynamicEndpointSnitch");
clearMBean("org.apache.cassandra.db:type=EndpointSnitchInfo"); clearMBean("org.apache.cassandra.db:type=EndpointSnitchInfo");
clearMBean("org.apache.cassandra.db:type=LocationInfo"); clearMBean("org.apache.cassandra.db:type=LocationInfo");
@ -5590,7 +5591,7 @@ public class DatabaseDescriptor
{ {
logger.info("updating coordinator_read_size_warn_threshold to {}", value); logger.info("updating coordinator_read_size_warn_threshold to {}", value);
conf.coordinator_read_size_warn_threshold = value; conf.coordinator_read_size_warn_threshold = value;
defaultReadThresholds = new QueryOptions.DefaultReadThresholds(value, getCoordinatorReadSizeFailThreshold()); defaultReadThresholds = null;
} }
@Nullable @Nullable
@ -5603,7 +5604,7 @@ public class DatabaseDescriptor
{ {
logger.info("updating coordinator_read_size_fail_threshold to {}", value); logger.info("updating coordinator_read_size_fail_threshold to {}", value);
conf.coordinator_read_size_fail_threshold = value; conf.coordinator_read_size_fail_threshold = value;
defaultReadThresholds = new QueryOptions.DefaultReadThresholds(getCoordinatorReadSizeWarnThreshold(), value); defaultReadThresholds = null;
} }
@Nullable @Nullable