From 0769af2c2efa312cfec0eadcdd502bbddd288f06 Mon Sep 17 00:00:00 2001 From: David Capwell Date: Thu, 10 Oct 2024 22:51:31 -0700 Subject: [PATCH] Ninja: fast path now updates after 60s rather than 5s. Added toString to ReconfigureAccordFastPath so the TCM logs/table gives the debug info needed --- src/java/org/apache/cassandra/config/AccordSpec.java | 2 +- .../transformations/ReconfigureAccordFastPath.java | 11 +++++++++++ 2 files changed, 12 insertions(+), 1 deletion(-) diff --git a/src/java/org/apache/cassandra/config/AccordSpec.java b/src/java/org/apache/cassandra/config/AccordSpec.java index 383af67d92..832e844ac7 100644 --- a/src/java/org/apache/cassandra/config/AccordSpec.java +++ b/src/java/org/apache/cassandra/config/AccordSpec.java @@ -65,7 +65,7 @@ public class AccordSpec public DurationSpec.IntMillisecondsBound range_barrier_timeout = new DurationSpec.IntMillisecondsBound("2m"); - public volatile DurationSpec.IntSecondsBound fast_path_update_delay = new DurationSpec.IntSecondsBound(5); + public volatile DurationSpec.IntSecondsBound fast_path_update_delay = new DurationSpec.IntSecondsBound("60s"); public volatile DurationSpec.IntSecondsBound gc_delay = new DurationSpec.IntSecondsBound(300); public volatile DurationSpec.IntSecondsBound schedule_durability_frequency = new DurationSpec.IntSecondsBound(120); diff --git a/src/java/org/apache/cassandra/tcm/transformations/ReconfigureAccordFastPath.java b/src/java/org/apache/cassandra/tcm/transformations/ReconfigureAccordFastPath.java index 628f4482f1..32478c0d76 100644 --- a/src/java/org/apache/cassandra/tcm/transformations/ReconfigureAccordFastPath.java +++ b/src/java/org/apache/cassandra/tcm/transformations/ReconfigureAccordFastPath.java @@ -66,6 +66,17 @@ public class ReconfigureAccordFastPath implements Transformation } } + @Override + public String toString() + { + return "ReconfigureAccordFastPath{" + + "node=" + node + + ", status=" + status + + ", updateTimeMillis=" + updateTimeMillis + + ", updateDelayMillis=" + updateDelayMillis + + '}'; + } + public static final AsymmetricMetadataSerializer serializer = new AsymmetricMetadataSerializer() { public void serialize(Transformation t, DataOutputPlus out, Version version) throws IOException