More tweaking CommitLogSegmentManager logs

Author: ines potier

src/java/org/apache/cassandra/db/commitlog/CommitLogReplayer.java

@@ -409,7 +409,7 @@ public void recover(File file, boolean tolerateTruncation) throws IOException
             {
                 int replayPos = replayEnd + CommitLogSegment.SYNC_MARKER_SIZE;
 
-                logger.debug("Replaying {} between {} and {}",
+                logger.trace("Replaying {} between {} and {}",
                              SafeArg.of("file", file.getName()),
                              SafeArg.of("start", reader.getFilePointer()),
                              SafeArg.of("end", end));

src/java/org/apache/cassandra/db/commitlog/CommitLogSegmentManager.java

@@ -33,6 +33,7 @@
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicLong;
+import java.util.stream.Collectors;
 
 import com.palantir.logsafe.SafeArg;
 import com.google.common.annotations.VisibleForTesting;
@@ -450,6 +451,11 @@ void enableReserveSegmentCreation()
      */
     private Future<?> flushDataFrom(List<CommitLogSegment> segments, boolean force, String reason)
     {
+        logger.debug("Flushing data from segments {} with reason {}",
+                     SafeArg.of("segments", segments.stream().map(segment -> segment.id).collect(Collectors.toSet())),
+                     SafeArg.of("reason", reason),
+                     SafeArg.of("force", force));
+
         if (segments.isEmpty())
             return Futures.immediateFuture(null);
         final ReplayPosition maxReplayPosition = segments.get(segments.size() - 1).getContext();