From 0f29153d106437c601c78a61dcf82d21276bdad1 Mon Sep 17 00:00:00 2001 From: jkonisa Date: Thu, 9 Apr 2026 12:52:58 -0700 Subject: [PATCH 1/3] CASSANALYTICS-149 Change log level for logs in CassandraSchema to debug level to avoid log spamming --- .../org/apache/cassandra/bridge/CassandraSchema.java | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java index b2895a65f..bda4b2d63 100644 --- a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java +++ b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java @@ -288,10 +288,14 @@ public static void updateCdcSchema(@NotNull Schema schema, @NotNull Partitioner partitioner, @NotNull TableIdLookup tableIdLookup) { - LOGGER.info("Updating CDC schema tables='{}'", + if (LOGGER.isDebugEnabled()) + { + LOGGER.debug("Updating CDC schema tables='{}'", cdcTables.stream() - .map(t -> String.format("%s.%s", t.keyspace(), t.table())) - .collect(Collectors.joining(","))); + .map(t -> String.format("%s.%s", t.keyspace(), t.table())) + .collect(Collectors.joining(","))); + } + Map> cdcEnabledTables = CassandraSchema.cdcEnabledTables(schema); for (CqlTable table : cdcTables) { @@ -301,7 +305,7 @@ public static void updateCdcSchema(@NotNull Schema schema, if (cdcEnabledTables.containsKey(table.keyspace()) && cdcEnabledTables.get(table.keyspace()).contains(table.table())) { // table has cdc enabled already, update schema if it has changed - LOGGER.info("CDC already enabled keyspace={} table={}", table.keyspace(), table.table()); + LOGGER.debug("CDC already enabled keyspace={} table={}", table.keyspace(), table.table()); cdcEnabledTables.get(table.keyspace()).remove(table.table()); CassandraSchema.maybeUpdateSchema(schema, partitioner, table, tableId, true); Preconditions.checkArgument(CassandraSchema.isCdcEnabled(schema, table), From b8ba8b5a83ea870b1d12f0d397ed0988e2ce1af1 Mon Sep 17 00:00:00 2001 From: jkonisa Date: Thu, 9 Apr 2026 15:36:39 -0700 Subject: [PATCH 2/3] Addressing comments --- .../java/org/apache/cassandra/bridge/CassandraSchema.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java index bda4b2d63..bd4f2c78c 100644 --- a/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java +++ b/cassandra-four-zero-types/src/main/java/org/apache/cassandra/bridge/CassandraSchema.java @@ -292,8 +292,8 @@ public static void updateCdcSchema(@NotNull Schema schema, { LOGGER.debug("Updating CDC schema tables='{}'", cdcTables.stream() - .map(t -> String.format("%s.%s", t.keyspace(), t.table())) - .collect(Collectors.joining(","))); + .map(t -> String.format("%s.%s", t.keyspace(), t.table())) + .collect(Collectors.joining(","))); } Map> cdcEnabledTables = CassandraSchema.cdcEnabledTables(schema); From bb772c7a0e3095bc03743ac842202eb61318a1f7 Mon Sep 17 00:00:00 2001 From: jkonisa Date: Thu, 9 Apr 2026 16:42:18 -0700 Subject: [PATCH 3/3] changes.txt --- CHANGES.txt | 1 + 1 file changed, 1 insertion(+) diff --git a/CHANGES.txt b/CHANGES.txt index ce89887db..4ea17cb18 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,5 +1,6 @@ 0.4.0 ----- + * Change log level for logs in CassandraSchema to debug level to avoid log spamming (CASSANALYTICS-149) * Pass SidecarCdcClient as a constructor parameter to avoid thread/resource leaks (CASSANALYTICS-142) * Support extended deletion time in CDC for Cassandra 5.0 * Flush event consumer before persisting CDC state to prevent data loss on failure (CASSANALYTICS-126)