You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@cassandra.apache.org by if...@apache.org on 2021/09/06 14:54:21 UTC

[cassandra-harry] branch trunk updated: Fix MetricReporter serialization; Update example yaml configs for required props.

This is an automated email from the ASF dual-hosted git repository.

ifesdjeen pushed a commit to branch trunk
in repository https://gitbox.apache.org/repos/asf/cassandra-harry.git


The following commit(s) were added to refs/heads/trunk by this push:
     new ddd643e  Fix MetricReporter serialization; Update example yaml configs for required props.
ddd643e is described below

commit ddd643ecc904258abe5e2f73d9b612793b0ac0e6
Author: Gianluca Righetto <gi...@menttis.com>
AuthorDate: Wed Aug 25 09:04:03 2021 -0300

    Fix MetricReporter serialization; Update example yaml configs for required props.
---
 conf/example.yaml                            | 17 ++++++-----------
 conf/external.yaml                           | 19 +++++++------------
 harry-core/src/harry/core/Configuration.java |  2 ++
 3 files changed, 15 insertions(+), 23 deletions(-)

diff --git a/conf/example.yaml b/conf/example.yaml
index 3a3c5ab..d28185d 100644
--- a/conf/example.yaml
+++ b/conf/example.yaml
@@ -39,9 +39,11 @@ clock:
 # and model state.
 runner:
   concurrent:
-    writer_threads: 2
-    round_robin_validator_threads: 1
-    recent_partition_validator_threads: 1
+    concurrency: 2
+    partition_visitors:
+      - mutating:
+          row_visitor:
+            mutating: {}
 
 run_time: 2
 run_time_unit: "HOURS"
@@ -54,12 +56,6 @@ system_under_test:
     worker_threads: 10
     root: "/tmp/harry/"
 
-# Model is responsible for tracking logical timestamps that
-model:
-  exhaustive_checker:
-    max_seen_lts: 19
-    max_complete_lts: 16
-
 # Partition descriptor selector controls how partitions is selected based on the current logical
 # timestamp. Default implementation is a sliding window of partition descriptors that will visit
 # one partition after the other in the window `slide_after_repeats` times. After that will
@@ -89,6 +85,5 @@ clustering_descriptor_selector:
     column_mask_bitsets: null
     max_partition_size: 100
 
-# Default Row Visitor
-row_visitor:
+metric_reporter:
   default: {}
\ No newline at end of file
diff --git a/conf/external.yaml b/conf/external.yaml
index 770dda9..b4d8217 100644
--- a/conf/external.yaml
+++ b/conf/external.yaml
@@ -39,9 +39,11 @@ clock:
 # and model state.
 runner:
   concurrent:
-    writer_threads: 2
-    round_robin_validator_threads: 1
-    recent_partition_validator_threads: 1
+    concurrency: 2
+    partition_visitors:
+      - mutating:
+          row_visitor:
+            mutating: {}
 
 run_time: 2
 run_time_unit: "HOURS"
@@ -55,12 +57,6 @@ system_under_test:
     username: null
     password: null
 
-# Model is responsible for tracking logical timestamps that
-model:
-  exhaustive_checker:
-    max_seen_lts: 19
-    max_complete_lts: 16
-
 # Partition descriptor selector controls how partitions is selected based on the current logical
 # timestamp. Default implementation is a sliding window of partition descriptors that will visit
 # one partition after the other in the window `slide_after_repeats` times. After that will
@@ -90,6 +86,5 @@ clustering_descriptor_selector:
     column_mask_bitsets: null
     max_partition_size: 100
 
-# Default Row Visitor
-row_visitor:
-  default: {}
\ No newline at end of file
+metric_reporter:
+  default: {}
diff --git a/harry-core/src/harry/core/Configuration.java b/harry-core/src/harry/core/Configuration.java
index bd011c2..f843e94 100644
--- a/harry-core/src/harry/core/Configuration.java
+++ b/harry-core/src/harry/core/Configuration.java
@@ -92,6 +92,8 @@ public class Configuration
         mapper.registerSubtypes(CorruptingPartitionVisitorConfiguration.class);
         mapper.registerSubtypes(RecentPartitionsValidatorConfiguration.class);
         mapper.registerSubtypes(FixedSchemaProviderConfiguration.class);
+
+        mapper.registerSubtypes(NoOpMetricReporterConfiguration.class);
     }
 
     public final long seed;

---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@cassandra.apache.org
For additional commands, e-mail: commits-help@cassandra.apache.org