diff --git a/CHANGES.txt b/CHANGES.txt index 4e5f27ed1..e0924e163 100644 --- a/CHANGES.txt +++ b/CHANGES.txt @@ -1,5 +1,6 @@ 0.5.0 ----- + * Downgrade noisy TokenPartitioner partition/range maps to DEBUG (CASSANALYTICS-52) * Make BulkWriterConfig extensible (CASSANALYTICS-168) 0.4.0 diff --git a/cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/TokenPartitioner.java b/cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/TokenPartitioner.java index 6f63c357a..11aa26c5a 100644 --- a/cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/TokenPartitioner.java +++ b/cassandra-analytics-common/src/main/java/org/apache/cassandra/spark/data/partitioner/TokenPartitioner.java @@ -116,9 +116,9 @@ private void calculateTokenRangeMap() validateCompleteRangeCoverage(); validateRangesDoNotOverlap(); - LOGGER.info("Number of partitions {}", reversePartitionMap.size()); - LOGGER.info("Partition map " + partitionMap); - LOGGER.info("Reverse partition map " + reversePartitionMap); + LOGGER.debug("Number of partitions {}", reversePartitionMap.size()); + LOGGER.debug("Partition map {}", partitionMap); + LOGGER.debug("Reverse partition map {}", reversePartitionMap); } private static int calculateSplits(CassandraRing ring, int defaultParallelism, Integer cores) @@ -126,7 +126,7 @@ private static int calculateSplits(CassandraRing ring, int defaultParallelism, I int tasksToRun = Math.max(cores, defaultParallelism); LOGGER.info("Tasks to run: {}", tasksToRun); Map, List> rangeListMap = ring.rangeMap().asMapOfRanges(); - LOGGER.info("Initial ranges: {}", rangeListMap); + LOGGER.debug("Initial ranges: {}", rangeListMap); int ranges = rangeListMap.size(); LOGGER.info("Number of ranges: {}", ranges); int calculatedSplits = TokenPartitioner.divCeil(tasksToRun, ranges); diff --git a/cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TokenPartitioner.java b/cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TokenPartitioner.java index 479ddcae0..c0b049eda 100644 --- a/cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TokenPartitioner.java +++ b/cassandra-analytics-core/src/main/java/org/apache/cassandra/spark/bulkwriter/TokenPartitioner.java @@ -104,9 +104,9 @@ public TokenPartitioner(TokenRangeMapping tokenRangeMapping, private void logPartitionInfo() { - LOGGER.info("Number of partitions: {}", nrPartitions); - LOGGER.info("Partition map: {}", partitionMap); - LOGGER.info("Reverse partition map: {}", reversePartitionMap); + LOGGER.debug("Number of partitions: {}", nrPartitions); + LOGGER.debug("Partition map: {}", partitionMap); + LOGGER.debug("Reverse partition map: {}", reversePartitionMap); } /** @@ -278,7 +278,7 @@ public int calculateSplits(TokenRangeMapping tokenRangeMapping, } int tasksToRun = Math.max(cores, defaultParallelism); Map, List> rangeListMap = tokenRangeMapping.getRangeMap().asMapOfRanges(); - LOGGER.info("Initial ranges: {}", rangeListMap); + LOGGER.debug("Initial ranges: {}", rangeListMap); int ranges = rangeListMap.size(); LOGGER.info("Number of ranges: {}", ranges); int calculatedSplits = divCeil(tasksToRun, ranges);