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

Do not spam the logs with MigrationCoordinator not being able to pull schemas 

patch by Stefan Miklosovic; reviewed by Brandon Williams for CASSANDRA-18096
This commit is contained in:
Stefan Miklosovic 2022-12-06 15:49:09 +01:00
parent 473656c1d5
commit f55b2fb1b3
2 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
CHANGES.txt
View File

@ -1,4 +1,5 @@
3.0.29 3.0.29
* Do not spam the logs with MigrationCoordinator not being able to pull schemas (CASSANDRA-18096)
* Fix incorrect resource name in LIST PERMISSION output (CASSANDRA-17848) * Fix incorrect resource name in LIST PERMISSION output (CASSANDRA-17848)
* Suppress CVE-2022-41854 and similar (CASSANDRA-18083) * Suppress CVE-2022-41854 and similar (CASSANDRA-18083)
* Fix running Ant rat targets without git (CASSANDRA-17974) * Fix running Ant rat targets without git (CASSANDRA-17974)

4
src/java/org/apache/cassandra/service/MigrationCoordinator.java
View File

@ -62,11 +62,13 @@ import org.apache.cassandra.net.MessageOut;
import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.net.MessagingService;
import org.apache.cassandra.schema.SchemaKeyspace; import org.apache.cassandra.schema.SchemaKeyspace;
import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.FBUtilities;
import org.apache.cassandra.utils.NoSpamLogger;
import org.apache.cassandra.utils.concurrent.WaitQueue; import org.apache.cassandra.utils.concurrent.WaitQueue;
public class MigrationCoordinator public class MigrationCoordinator
{ {
private static final Logger logger = LoggerFactory.getLogger(MigrationCoordinator.class); private static final Logger logger = LoggerFactory.getLogger(MigrationCoordinator.class);
private static final NoSpamLogger noSpamLogger = NoSpamLogger.getLogger(MigrationCoordinator.logger, 1, TimeUnit.MINUTES);
private static final RuntimeMXBean runtimeMXBean = ManagementFactory.getRuntimeMXBean(); private static final RuntimeMXBean runtimeMXBean = ManagementFactory.getRuntimeMXBean();
private static final Future<Void> FINISHED_FUTURE = Futures.immediateFuture(null); private static final Future<Void> FINISHED_FUTURE = Futures.immediateFuture(null);
@ -498,7 +500,7 @@ public class MigrationCoordinator
{ {
if (!isAlive(callback.endpoint)) if (!isAlive(callback.endpoint))
{ {
logger.warn("Can't send schema pull request: node {} is down.", callback.endpoint); noSpamLogger.warn("Can't send schema pull request: node {} is down.", callback.endpoint);
callback.fail(); callback.fail();
return; return;
} }