diff --git a/build.xml b/build.xml index 62048192d3..1800c09dc2 100644 --- a/build.xml +++ b/build.xml @@ -2257,7 +2257,7 @@ - + @@ -2267,7 +2267,7 @@ classpathref="checkstyle.lib.path"/> - + @@ -2283,7 +2283,7 @@ - + diff --git a/checkstyle.xml b/checkstyle.xml index 8e2f90ee22..06e0cddd90 100644 --- a/checkstyle.xml +++ b/checkstyle.xml @@ -105,6 +105,9 @@ + + + diff --git a/checkstyle_test.xml b/checkstyle_test.xml index 68e5e87c12..d237827f44 100644 --- a/checkstyle_test.xml +++ b/checkstyle_test.xml @@ -56,6 +56,9 @@ + + + diff --git a/src/java/org/apache/cassandra/batchlog/BatchlogManager.java b/src/java/org/apache/cassandra/batchlog/BatchlogManager.java index ba0f3a6091..6ff5aee0cf 100644 --- a/src/java/org/apache/cassandra/batchlog/BatchlogManager.java +++ b/src/java/org/apache/cassandra/batchlog/BatchlogManager.java @@ -36,7 +36,6 @@ import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.Iterables; import com.google.common.util.concurrent.RateLimiter; import org.apache.cassandra.concurrent.ScheduledExecutorPlus; -import org.apache.cassandra.db.marshal.TimeUUIDType; import org.apache.cassandra.utils.TimeUUID; import org.apache.cassandra.utils.concurrent.Future; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/cache/CaffeineCache.java b/src/java/org/apache/cassandra/cache/CaffeineCache.java index 124e681385..717fb78f6a 100644 --- a/src/java/org/apache/cassandra/cache/CaffeineCache.java +++ b/src/java/org/apache/cassandra/cache/CaffeineCache.java @@ -21,8 +21,6 @@ import static com.google.common.base.Preconditions.checkState; import java.util.Iterator; -import com.google.common.util.concurrent.MoreExecutors; - import com.github.benmanes.caffeine.cache.Cache; import com.github.benmanes.caffeine.cache.Caffeine; import com.github.benmanes.caffeine.cache.Policy.Eviction; diff --git a/src/java/org/apache/cassandra/cache/SerializingCache.java b/src/java/org/apache/cassandra/cache/SerializingCache.java index be7c4f52f2..8ee8e024e8 100644 --- a/src/java/org/apache/cassandra/cache/SerializingCache.java +++ b/src/java/org/apache/cassandra/cache/SerializingCache.java @@ -33,8 +33,6 @@ import org.slf4j.LoggerFactory; import java.io.IOException; import java.util.Iterator; -import com.google.common.util.concurrent.MoreExecutors; - /** * Serializes cache values off-heap. */ diff --git a/src/java/org/apache/cassandra/config/EncryptionOptions.java b/src/java/org/apache/cassandra/config/EncryptionOptions.java index eb6724f96d..1758eb0f85 100644 --- a/src/java/org/apache/cassandra/config/EncryptionOptions.java +++ b/src/java/org/apache/cassandra/config/EncryptionOptions.java @@ -25,10 +25,6 @@ import java.util.Map; import java.util.Objects; import java.util.Set; -import javax.net.ssl.KeyManagerFactory; -import javax.net.ssl.SSLException; -import javax.net.ssl.TrustManagerFactory; - import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.ImmutableList; @@ -38,7 +34,6 @@ import org.slf4j.LoggerFactory; import com.fasterxml.jackson.annotation.JsonIgnore; import org.apache.cassandra.locator.IEndpointSnitch; import org.apache.cassandra.locator.InetAddressAndPort; -import org.apache.cassandra.security.AbstractSslContextFactory; import org.apache.cassandra.security.DisableSslContextFactory; import org.apache.cassandra.security.ISslContextFactory; import org.apache.cassandra.utils.FBUtilities; diff --git a/src/java/org/apache/cassandra/cql3/WhereClause.java b/src/java/org/apache/cassandra/cql3/WhereClause.java index 9f59c5efbc..dc1a7cfde0 100644 --- a/src/java/org/apache/cassandra/cql3/WhereClause.java +++ b/src/java/org/apache/cassandra/cql3/WhereClause.java @@ -24,7 +24,6 @@ import com.google.common.collect.ImmutableList; import org.antlr.runtime.RecognitionException; import org.apache.cassandra.cql3.restrictions.CustomIndexExpression; -import org.apache.cassandra.exceptions.InvalidRequestException; import static java.lang.String.join; diff --git a/src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java b/src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java index a50a0f36ba..e5b2465ace 100644 --- a/src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java +++ b/src/java/org/apache/cassandra/cql3/restrictions/SingleColumnRestriction.java @@ -23,7 +23,6 @@ import java.util.Collections; import java.util.List; import org.apache.cassandra.schema.ColumnMetadata; -import org.apache.cassandra.serializers.CollectionSerializer; import org.apache.cassandra.serializers.ListSerializer; import org.apache.cassandra.transport.ProtocolVersion; import org.apache.cassandra.cql3.*; diff --git a/src/java/org/apache/cassandra/cql3/selection/MapSelector.java b/src/java/org/apache/cassandra/cql3/selection/MapSelector.java index a43d7bfccb..dc811c02a3 100644 --- a/src/java/org/apache/cassandra/cql3/selection/MapSelector.java +++ b/src/java/org/apache/cassandra/cql3/selection/MapSelector.java @@ -35,7 +35,6 @@ import org.apache.cassandra.db.TypeSizes; import org.apache.cassandra.db.filter.ColumnFilter.Builder; import org.apache.cassandra.db.marshal.AbstractType; import org.apache.cassandra.db.marshal.MapType; -import org.apache.cassandra.exceptions.InvalidRequestException; import org.apache.cassandra.io.util.DataInputPlus; import org.apache.cassandra.io.util.DataOutputPlus; import org.apache.cassandra.schema.ColumnMetadata; diff --git a/src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java b/src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java index 2736252688..08c5f04123 100644 --- a/src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java +++ b/src/java/org/apache/cassandra/cql3/statements/schema/AlterTableStatement.java @@ -17,7 +17,6 @@ */ package org.apache.cassandra.cql3.statements.schema; -import java.net.UnknownHostException; import java.util.ArrayList; import java.util.Collection; import java.util.HashMap; diff --git a/src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java b/src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java index fd31e43ec0..829a53a911 100644 --- a/src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java +++ b/src/java/org/apache/cassandra/cql3/statements/schema/TableAttributes.java @@ -20,7 +20,6 @@ package org.apache.cassandra.cql3.statements.schema; import java.util.Map; import java.util.Set; -import com.google.common.collect.ImmutableMap; import com.google.common.collect.ImmutableSet; import com.google.common.collect.Sets; diff --git a/src/java/org/apache/cassandra/db/ReadResponse.java b/src/java/org/apache/cassandra/db/ReadResponse.java index 4d34326c8d..9ef9128a36 100644 --- a/src/java/org/apache/cassandra/db/ReadResponse.java +++ b/src/java/org/apache/cassandra/db/ReadResponse.java @@ -34,8 +34,6 @@ import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.utils.ByteBufferUtil; -import static org.apache.cassandra.db.RepairedDataInfo.NO_OP_REPAIRED_DATA_INFO; - public abstract class ReadResponse { // Serializer for single partition read response diff --git a/src/java/org/apache/cassandra/db/SystemKeyspaceMigrator41.java b/src/java/org/apache/cassandra/db/SystemKeyspaceMigrator41.java index 5ee1eba42f..bfce78019d 100644 --- a/src/java/org/apache/cassandra/db/SystemKeyspaceMigrator41.java +++ b/src/java/org/apache/cassandra/db/SystemKeyspaceMigrator41.java @@ -35,7 +35,6 @@ import org.apache.cassandra.db.marshal.BytesType; import org.apache.cassandra.db.marshal.Int32Type; import org.apache.cassandra.db.marshal.TimeUUIDType; import org.apache.cassandra.db.marshal.UTF8Type; -import org.apache.cassandra.db.marshal.UUIDType; import org.apache.cassandra.io.sstable.SequenceBasedSSTableId; import org.apache.cassandra.schema.SchemaConstants; import org.apache.cassandra.utils.CassandraVersion; diff --git a/src/java/org/apache/cassandra/db/compaction/writers/CompactionAwareWriter.java b/src/java/org/apache/cassandra/db/compaction/writers/CompactionAwareWriter.java index 02c7b6ce44..0f4fe2dcfe 100644 --- a/src/java/org/apache/cassandra/db/compaction/writers/CompactionAwareWriter.java +++ b/src/java/org/apache/cassandra/db/compaction/writers/CompactionAwareWriter.java @@ -39,8 +39,6 @@ import org.apache.cassandra.io.sstable.format.SSTableReader; import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.TimeUUID; import org.apache.cassandra.utils.concurrent.Transactional; -import org.apache.cassandra.db.compaction.OperationType; - /** * Class that abstracts away the actual writing of files to make it possible to use CompactionTask for more diff --git a/src/java/org/apache/cassandra/db/filter/ClusteringIndexFilter.java b/src/java/org/apache/cassandra/db/filter/ClusteringIndexFilter.java index 08e9eb5db3..924ff21ec5 100644 --- a/src/java/org/apache/cassandra/db/filter/ClusteringIndexFilter.java +++ b/src/java/org/apache/cassandra/db/filter/ClusteringIndexFilter.java @@ -23,7 +23,6 @@ import org.apache.cassandra.db.*; import org.apache.cassandra.db.partitions.CachedPartition; import org.apache.cassandra.db.partitions.Partition; import org.apache.cassandra.db.rows.*; -import org.apache.cassandra.index.Index; import org.apache.cassandra.io.sstable.format.SSTableReader; import org.apache.cassandra.io.util.DataInputPlus; import org.apache.cassandra.io.util.DataOutputPlus; diff --git a/src/java/org/apache/cassandra/db/filter/ClusteringIndexSliceFilter.java b/src/java/org/apache/cassandra/db/filter/ClusteringIndexSliceFilter.java index b96888dfbe..178c96b453 100644 --- a/src/java/org/apache/cassandra/db/filter/ClusteringIndexSliceFilter.java +++ b/src/java/org/apache/cassandra/db/filter/ClusteringIndexSliceFilter.java @@ -30,7 +30,6 @@ import org.apache.cassandra.db.transform.Transformation; import org.apache.cassandra.io.sstable.format.SSTableReader; import org.apache.cassandra.io.util.DataInputPlus; import org.apache.cassandra.io.util.DataOutputPlus; -import org.stringtemplate.v4.ST; /** * A filter over a single partition. diff --git a/src/java/org/apache/cassandra/db/marshal/AbstractTimeUUIDType.java b/src/java/org/apache/cassandra/db/marshal/AbstractTimeUUIDType.java index b6b10d582d..91a5b273a9 100644 --- a/src/java/org/apache/cassandra/db/marshal/AbstractTimeUUIDType.java +++ b/src/java/org/apache/cassandra/db/marshal/AbstractTimeUUIDType.java @@ -24,7 +24,6 @@ import org.apache.cassandra.cql3.CQL3Type; import org.apache.cassandra.cql3.Constants; import org.apache.cassandra.cql3.Term; import org.apache.cassandra.serializers.MarshalException; -import org.apache.cassandra.serializers.TypeSerializer; import org.apache.cassandra.serializers.UUIDSerializer; import org.apache.cassandra.utils.TimeUUID; diff --git a/src/java/org/apache/cassandra/db/memtable/SkipListMemtableFactory.java b/src/java/org/apache/cassandra/db/memtable/SkipListMemtableFactory.java index ce8c321f84..76dee02be1 100644 --- a/src/java/org/apache/cassandra/db/memtable/SkipListMemtableFactory.java +++ b/src/java/org/apache/cassandra/db/memtable/SkipListMemtableFactory.java @@ -18,13 +18,11 @@ package org.apache.cassandra.db.memtable; -import java.util.Map; import java.util.concurrent.atomic.AtomicReference; import com.google.common.collect.ImmutableMap; import org.apache.cassandra.config.InheritingClass; -import org.apache.cassandra.config.ParameterizedClass; import org.apache.cassandra.db.commitlog.CommitLogPosition; import org.apache.cassandra.schema.TableMetadataRef; diff --git a/src/java/org/apache/cassandra/db/repair/CassandraKeyspaceRepairManager.java b/src/java/org/apache/cassandra/db/repair/CassandraKeyspaceRepairManager.java index b870cfe7b2..6e70666e39 100644 --- a/src/java/org/apache/cassandra/db/repair/CassandraKeyspaceRepairManager.java +++ b/src/java/org/apache/cassandra/db/repair/CassandraKeyspaceRepairManager.java @@ -20,7 +20,6 @@ package org.apache.cassandra.db.repair; import java.util.Collection; import java.util.List; -import java.util.UUID; import java.util.concurrent.ExecutorService; import java.util.function.BooleanSupplier; diff --git a/src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java b/src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java index 98e683e264..53ef657bb3 100644 --- a/src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java +++ b/src/java/org/apache/cassandra/db/repair/CassandraValidationIterator.java @@ -40,7 +40,6 @@ import org.apache.cassandra.db.DecoratedKey; import org.apache.cassandra.db.compaction.AbstractCompactionStrategy; import org.apache.cassandra.db.compaction.ActiveCompactionsTracker; import org.apache.cassandra.db.compaction.CompactionController; -import org.apache.cassandra.db.compaction.CompactionInfo; import org.apache.cassandra.db.compaction.CompactionIterator; import org.apache.cassandra.db.compaction.CompactionManager; import org.apache.cassandra.db.compaction.OperationType; diff --git a/src/java/org/apache/cassandra/db/rows/ComplexColumnData.java b/src/java/org/apache/cassandra/db/rows/ComplexColumnData.java index bfd7f125f7..f2b4bb6476 100644 --- a/src/java/org/apache/cassandra/db/rows/ComplexColumnData.java +++ b/src/java/org/apache/cassandra/db/rows/ComplexColumnData.java @@ -28,11 +28,8 @@ import org.apache.cassandra.db.DeletionPurger; import org.apache.cassandra.db.DeletionTime; import org.apache.cassandra.db.Digest; import org.apache.cassandra.db.LivenessInfo; -import org.apache.cassandra.db.context.CounterContext; import org.apache.cassandra.db.filter.ColumnFilter; -import org.apache.cassandra.db.marshal.AbstractType; import org.apache.cassandra.db.marshal.ByteType; -import org.apache.cassandra.db.marshal.CollectionType; import org.apache.cassandra.db.marshal.SetType; import org.apache.cassandra.schema.ColumnMetadata; import org.apache.cassandra.schema.DroppedColumn; diff --git a/src/java/org/apache/cassandra/db/virtual/StreamingVirtualTable.java b/src/java/org/apache/cassandra/db/virtual/StreamingVirtualTable.java index f9fe0ef54d..f01e79956d 100644 --- a/src/java/org/apache/cassandra/db/virtual/StreamingVirtualTable.java +++ b/src/java/org/apache/cassandra/db/virtual/StreamingVirtualTable.java @@ -19,12 +19,10 @@ package org.apache.cassandra.db.virtual; import java.util.Date; import java.util.Map; -import java.util.UUID; import java.util.stream.Collectors; import org.apache.cassandra.db.DecoratedKey; import org.apache.cassandra.db.marshal.TimeUUIDType; -import org.apache.cassandra.db.marshal.UUIDType; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.streaming.StreamManager; import org.apache.cassandra.streaming.StreamingState; diff --git a/src/java/org/apache/cassandra/hints/HintsStore.java b/src/java/org/apache/cassandra/hints/HintsStore.java index a042cc3bb5..b7850ee2b4 100644 --- a/src/java/org/apache/cassandra/hints/HintsStore.java +++ b/src/java/org/apache/cassandra/hints/HintsStore.java @@ -23,7 +23,6 @@ import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedDeque; import java.util.concurrent.ConcurrentLinkedQueue; import java.util.function.Predicate; -import java.util.stream.Stream; import javax.annotation.Nullable; diff --git a/src/java/org/apache/cassandra/hints/PendingHintsInfo.java b/src/java/org/apache/cassandra/hints/PendingHintsInfo.java index 9fbae1669f..b4f21cd7dc 100644 --- a/src/java/org/apache/cassandra/hints/PendingHintsInfo.java +++ b/src/java/org/apache/cassandra/hints/PendingHintsInfo.java @@ -18,7 +18,6 @@ package org.apache.cassandra.hints; -import java.io.Serializable; import java.util.HashMap; import java.util.Map; import java.util.Objects; diff --git a/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StemmerFactory.java b/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StemmerFactory.java index 17f151211e..457876ab24 100644 --- a/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StemmerFactory.java +++ b/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StemmerFactory.java @@ -22,8 +22,6 @@ import java.util.HashMap; import java.util.Locale; import java.util.Map; -import com.google.common.util.concurrent.MoreExecutors; - import org.apache.cassandra.concurrent.ImmediateExecutor; import org.tartarus.snowball.SnowballStemmer; import org.tartarus.snowball.ext.*; diff --git a/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StopWordFactory.java b/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StopWordFactory.java index 434fbda0a6..b85a36fe93 100644 --- a/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StopWordFactory.java +++ b/src/java/org/apache/cassandra/index/sasi/analyzer/filter/StopWordFactory.java @@ -27,8 +27,6 @@ import java.util.Locale; import java.util.Set; import java.util.concurrent.CompletionException; -import com.google.common.util.concurrent.MoreExecutors; - import com.github.benmanes.caffeine.cache.Caffeine; import com.github.benmanes.caffeine.cache.LoadingCache; diff --git a/src/java/org/apache/cassandra/io/sstable/CQLSSTableWriter.java b/src/java/org/apache/cassandra/io/sstable/CQLSSTableWriter.java index a0bf6644d9..40abe2c36d 100644 --- a/src/java/org/apache/cassandra/io/sstable/CQLSSTableWriter.java +++ b/src/java/org/apache/cassandra/io/sstable/CQLSSTableWriter.java @@ -46,7 +46,6 @@ import org.apache.cassandra.cql3.statements.ModificationStatement; import org.apache.cassandra.db.Clustering; import org.apache.cassandra.db.Slice; import org.apache.cassandra.db.Slices; -import org.apache.cassandra.db.SystemKeyspace; import org.apache.cassandra.db.marshal.AbstractType; import org.apache.cassandra.dht.IPartitioner; import org.apache.cassandra.dht.Murmur3Partitioner; diff --git a/src/java/org/apache/cassandra/io/util/DataIntegrityMetadata.java b/src/java/org/apache/cassandra/io/util/DataIntegrityMetadata.java index f611f91bcb..65d4e58f0f 100644 --- a/src/java/org/apache/cassandra/io/util/DataIntegrityMetadata.java +++ b/src/java/org/apache/cassandra/io/util/DataIntegrityMetadata.java @@ -27,7 +27,6 @@ import com.google.common.annotations.VisibleForTesting; import org.apache.cassandra.io.sstable.Component; import org.apache.cassandra.io.sstable.Descriptor; -import org.apache.cassandra.io.util.File; import org.apache.cassandra.utils.ChecksumType; import org.apache.cassandra.utils.Throwables; diff --git a/src/java/org/apache/cassandra/io/util/RandomAccessReader.java b/src/java/org/apache/cassandra/io/util/RandomAccessReader.java index 4118bb3afd..1a18813e89 100644 --- a/src/java/org/apache/cassandra/io/util/RandomAccessReader.java +++ b/src/java/org/apache/cassandra/io/util/RandomAccessReader.java @@ -25,7 +25,6 @@ import javax.annotation.concurrent.NotThreadSafe; import com.google.common.primitives.Ints; import org.apache.cassandra.io.compress.BufferType; -import org.apache.cassandra.io.util.File; import org.apache.cassandra.io.util.Rebufferer.BufferHolder; @NotThreadSafe diff --git a/src/java/org/apache/cassandra/metrics/HintedHandoffMetrics.java b/src/java/org/apache/cassandra/metrics/HintedHandoffMetrics.java index f580d1c049..bc87218bbd 100644 --- a/src/java/org/apache/cassandra/metrics/HintedHandoffMetrics.java +++ b/src/java/org/apache/cassandra/metrics/HintedHandoffMetrics.java @@ -19,8 +19,6 @@ package org.apache.cassandra.metrics; import java.util.Map.Entry; -import com.google.common.util.concurrent.MoreExecutors; - import com.codahale.metrics.Counter; import com.github.benmanes.caffeine.cache.Caffeine; import com.github.benmanes.caffeine.cache.LoadingCache; diff --git a/src/java/org/apache/cassandra/metrics/HintsServiceMetrics.java b/src/java/org/apache/cassandra/metrics/HintsServiceMetrics.java index 50defd92c5..bcff389577 100644 --- a/src/java/org/apache/cassandra/metrics/HintsServiceMetrics.java +++ b/src/java/org/apache/cassandra/metrics/HintsServiceMetrics.java @@ -17,7 +17,6 @@ */ package org.apache.cassandra.metrics; -import com.google.common.util.concurrent.MoreExecutors; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java b/src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java index 5e936ace47..ee18a873ea 100644 --- a/src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java +++ b/src/java/org/apache/cassandra/net/AsyncStreamingInputPlus.java @@ -17,7 +17,6 @@ */ package org.apache.cassandra.net; -import java.io.EOFException; import java.io.IOException; import java.nio.ByteBuffer; import java.nio.channels.ClosedChannelException; diff --git a/src/java/org/apache/cassandra/net/OutboundConnections.java b/src/java/org/apache/cassandra/net/OutboundConnections.java index 1c582f45e5..ad87ec588c 100644 --- a/src/java/org/apache/cassandra/net/OutboundConnections.java +++ b/src/java/org/apache/cassandra/net/OutboundConnections.java @@ -50,7 +50,6 @@ import static org.apache.cassandra.net.ConnectionType.URGENT_MESSAGES; import static org.apache.cassandra.net.ConnectionType.LARGE_MESSAGES; import static org.apache.cassandra.net.ConnectionType.SMALL_MESSAGES; import static org.apache.cassandra.net.ResourceLimits.*; -import static org.apache.cassandra.net.Verb.Priority.P0; import static org.apache.cassandra.utils.concurrent.Condition.newOneTimeCondition; /** diff --git a/src/java/org/apache/cassandra/net/ParamType.java b/src/java/org/apache/cassandra/net/ParamType.java index 42222d0412..2f661d2b68 100644 --- a/src/java/org/apache/cassandra/net/ParamType.java +++ b/src/java/org/apache/cassandra/net/ParamType.java @@ -27,7 +27,6 @@ import org.apache.cassandra.tracing.Tracing; import org.apache.cassandra.utils.Int32Serializer; import org.apache.cassandra.utils.Int64Serializer; import org.apache.cassandra.utils.TimeUUID; -import org.apache.cassandra.utils.UUIDSerializer; import static java.lang.Math.max; import static org.apache.cassandra.locator.InetAddressAndPort.FwdFrmSerializer.fwdFrmSerializer; diff --git a/src/java/org/apache/cassandra/net/RequestCallbacks.java b/src/java/org/apache/cassandra/net/RequestCallbacks.java index 4409a704e3..ae57078964 100644 --- a/src/java/org/apache/cassandra/net/RequestCallbacks.java +++ b/src/java/org/apache/cassandra/net/RequestCallbacks.java @@ -26,7 +26,6 @@ import javax.annotation.Nullable; import com.google.common.annotations.VisibleForTesting; -import org.apache.cassandra.concurrent.ExecutorFactory; import org.apache.cassandra.concurrent.ScheduledExecutorPlus; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/src/java/org/apache/cassandra/repair/IncrementalRepairTask.java b/src/java/org/apache/cassandra/repair/IncrementalRepairTask.java index b9b9e3aa59..af1a234d34 100644 --- a/src/java/org/apache/cassandra/repair/IncrementalRepairTask.java +++ b/src/java/org/apache/cassandra/repair/IncrementalRepairTask.java @@ -19,7 +19,6 @@ package org.apache.cassandra.repair; import java.util.List; import java.util.Set; -import java.util.UUID; import com.google.common.collect.ImmutableSet; diff --git a/src/java/org/apache/cassandra/repair/PreviewRepairTask.java b/src/java/org/apache/cassandra/repair/PreviewRepairTask.java index 9bda0d15a7..7ce7d1fbba 100644 --- a/src/java/org/apache/cassandra/repair/PreviewRepairTask.java +++ b/src/java/org/apache/cassandra/repair/PreviewRepairTask.java @@ -21,7 +21,6 @@ import java.util.Collections; import java.util.HashSet; import java.util.List; import java.util.Set; -import java.util.UUID; import com.google.common.base.Preconditions; diff --git a/src/java/org/apache/cassandra/repair/RepairJobDesc.java b/src/java/org/apache/cassandra/repair/RepairJobDesc.java index 3a4635db4a..c6b1898f79 100644 --- a/src/java/org/apache/cassandra/repair/RepairJobDesc.java +++ b/src/java/org/apache/cassandra/repair/RepairJobDesc.java @@ -37,8 +37,6 @@ import org.apache.cassandra.io.util.DataInputPlus; import org.apache.cassandra.io.util.DataOutputPlus; import org.apache.cassandra.streaming.PreviewKind; import org.apache.cassandra.utils.TimeUUID; -import org.apache.cassandra.utils.ByteBufferUtil; -import org.apache.cassandra.utils.UUIDSerializer; import static org.apache.cassandra.utils.ByteBufferUtil.bytes; import static org.apache.cassandra.utils.ByteBufferUtil.getArray; diff --git a/src/java/org/apache/cassandra/repair/RepairRunnable.java b/src/java/org/apache/cassandra/repair/RepairRunnable.java index 19c3f10fb7..7607b045fa 100644 --- a/src/java/org/apache/cassandra/repair/RepairRunnable.java +++ b/src/java/org/apache/cassandra/repair/RepairRunnable.java @@ -88,7 +88,6 @@ import static org.apache.cassandra.repair.state.AbstractState.INIT; import static org.apache.cassandra.service.QueryState.forInternalCalls; import static org.apache.cassandra.utils.Clock.Global.currentTimeMillis; import static org.apache.cassandra.utils.Clock.Global.nanoTime; -import static org.apache.cassandra.utils.TimeUUID.Generator.nextTimeUUID; public class RepairRunnable implements Runnable, ProgressEventNotifier, RepairNotifier { diff --git a/src/java/org/apache/cassandra/repair/state/SessionState.java b/src/java/org/apache/cassandra/repair/state/SessionState.java index 607c7b6174..8e8e6485be 100644 --- a/src/java/org/apache/cassandra/repair/state/SessionState.java +++ b/src/java/org/apache/cassandra/repair/state/SessionState.java @@ -26,7 +26,6 @@ import java.util.concurrent.ConcurrentMap; import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.repair.CommonRange; import org.apache.cassandra.utils.TimeUUID; -import org.apache.cassandra.utils.UUIDGen; import static org.apache.cassandra.utils.TimeUUID.Generator.nextTimeUUID; diff --git a/src/java/org/apache/cassandra/schema/SchemaPullVerbHandler.java b/src/java/org/apache/cassandra/schema/SchemaPullVerbHandler.java index 533090b7eb..6589075ce3 100644 --- a/src/java/org/apache/cassandra/schema/SchemaPullVerbHandler.java +++ b/src/java/org/apache/cassandra/schema/SchemaPullVerbHandler.java @@ -17,20 +17,15 @@ */ package org.apache.cassandra.schema; -import java.util.Collection; import java.util.List; import java.util.concurrent.CopyOnWriteArrayList; import java.util.function.Consumer; -import java.util.function.Function; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.cassandra.db.Mutation; -import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.net.IVerbHandler; import org.apache.cassandra.net.Message; -import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.net.NoPayload; /** diff --git a/src/java/org/apache/cassandra/schema/SchemaPushVerbHandler.java b/src/java/org/apache/cassandra/schema/SchemaPushVerbHandler.java index 114f918e0e..4f2325a3ac 100644 --- a/src/java/org/apache/cassandra/schema/SchemaPushVerbHandler.java +++ b/src/java/org/apache/cassandra/schema/SchemaPushVerbHandler.java @@ -25,11 +25,9 @@ import java.util.function.Consumer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.cassandra.concurrent.Stage; import org.apache.cassandra.db.Mutation; import org.apache.cassandra.net.IVerbHandler; import org.apache.cassandra.net.Message; -import org.apache.cassandra.net.NoPayload; /** * Called when node receives updated schema state from the schema migration coordinator node. diff --git a/src/java/org/apache/cassandra/security/CipherFactory.java b/src/java/org/apache/cassandra/security/CipherFactory.java index c42ebcaea5..4674fd17cd 100644 --- a/src/java/org/apache/cassandra/security/CipherFactory.java +++ b/src/java/org/apache/cassandra/security/CipherFactory.java @@ -31,7 +31,6 @@ import javax.crypto.NoSuchPaddingException; import javax.crypto.spec.IvParameterSpec; import com.google.common.annotations.VisibleForTesting; -import com.google.common.util.concurrent.MoreExecutors; import com.github.benmanes.caffeine.cache.Caffeine; import com.github.benmanes.caffeine.cache.LoadingCache; diff --git a/src/java/org/apache/cassandra/serializers/ListSerializer.java b/src/java/org/apache/cassandra/serializers/ListSerializer.java index 429be986b7..b6a381cb7e 100644 --- a/src/java/org/apache/cassandra/serializers/ListSerializer.java +++ b/src/java/org/apache/cassandra/serializers/ListSerializer.java @@ -20,7 +20,6 @@ package org.apache.cassandra.serializers; import java.nio.BufferUnderflowException; import java.nio.ByteBuffer; -import java.nio.charset.CharacterCodingException; import java.util.*; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentMap; diff --git a/src/java/org/apache/cassandra/service/ActiveRepairService.java b/src/java/org/apache/cassandra/service/ActiveRepairService.java index 68247eaf58..b288065bd7 100644 --- a/src/java/org/apache/cassandra/service/ActiveRepairService.java +++ b/src/java/org/apache/cassandra/service/ActiveRepairService.java @@ -40,7 +40,6 @@ import com.google.common.collect.ImmutableSet; import com.google.common.collect.Iterables; import com.google.common.collect.Lists; import com.google.common.collect.Multimap; -import com.google.common.util.concurrent.MoreExecutors; import org.apache.cassandra.concurrent.ExecutorPlus; import org.apache.cassandra.config.Config; @@ -53,13 +52,11 @@ import org.apache.cassandra.utils.ExecutorUtils; import org.apache.cassandra.repair.state.CoordinatorState; import org.apache.cassandra.repair.state.ParticipateState; import org.apache.cassandra.repair.state.ValidationState; -import org.apache.cassandra.utils.ObjectSizes; import org.apache.cassandra.utils.Simulate; import org.apache.cassandra.locator.EndpointsForToken; import org.apache.cassandra.schema.Schema; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.streaming.PreviewKind; -import org.apache.cassandra.utils.Simulate; import org.apache.cassandra.utils.TimeUUID; import org.apache.cassandra.utils.concurrent.CountDownLatch; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/service/ClientState.java b/src/java/org/apache/cassandra/service/ClientState.java index c7def848ec..9e35c7f4b0 100644 --- a/src/java/org/apache/cassandra/service/ClientState.java +++ b/src/java/org/apache/cassandra/service/ClientState.java @@ -28,7 +28,6 @@ import java.util.Optional; import java.util.Set; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicLong; -import java.util.function.LongSupplier; import com.google.common.annotations.VisibleForTesting; import com.google.common.collect.ImmutableMap; diff --git a/src/java/org/apache/cassandra/service/StorageProxy.java b/src/java/org/apache/cassandra/service/StorageProxy.java index 31d54771fe..8499d625a4 100644 --- a/src/java/org/apache/cassandra/service/StorageProxy.java +++ b/src/java/org/apache/cassandra/service/StorageProxy.java @@ -39,7 +39,6 @@ import java.util.concurrent.atomic.AtomicLong; import java.util.function.Function; import java.util.stream.Collectors; -import com.google.common.annotations.VisibleForTesting; import com.google.common.base.Preconditions; import com.google.common.cache.CacheLoader; import com.google.common.collect.Iterables; diff --git a/src/java/org/apache/cassandra/service/paxos/Paxos.java b/src/java/org/apache/cassandra/service/paxos/Paxos.java index cd5ab1e588..ee5b27e407 100644 --- a/src/java/org/apache/cassandra/service/paxos/Paxos.java +++ b/src/java/org/apache/cassandra/service/paxos/Paxos.java @@ -33,8 +33,6 @@ import javax.annotation.Nullable; import com.google.common.base.Preconditions; import com.google.common.collect.Maps; -import org.apache.commons.httpclient.methods.multipart.Part; - import com.codahale.metrics.Meter; import org.apache.cassandra.exceptions.CasWriteTimeoutException; import org.apache.cassandra.exceptions.ExceptionCode; @@ -80,7 +78,6 @@ import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.metrics.ClientRequestMetrics; import org.apache.cassandra.service.CASRequest; import org.apache.cassandra.service.ClientState; -import org.apache.cassandra.service.FailureRecordingCallback; import org.apache.cassandra.service.FailureRecordingCallback.AsMap; import org.apache.cassandra.service.paxos.Commit.Proposal; import org.apache.cassandra.service.reads.DataResolver; diff --git a/src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java b/src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java index 7270cc5eac..7a9dba7b5a 100644 --- a/src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java +++ b/src/java/org/apache/cassandra/service/paxos/PaxosCommitAndPrepare.java @@ -31,7 +31,6 @@ import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.service.paxos.Commit.Agreed; import org.apache.cassandra.tracing.Tracing; -import org.apache.cassandra.service.paxos.Ballot; import static org.apache.cassandra.exceptions.RequestFailureReason.UNKNOWN; import static org.apache.cassandra.net.Verb.PAXOS2_COMMIT_AND_PREPARE_REQ; diff --git a/src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java b/src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java index 6c13104960..19aff7428a 100644 --- a/src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java +++ b/src/java/org/apache/cassandra/service/paxos/PaxosPrepareRefresh.java @@ -33,7 +33,6 @@ import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.net.IVerbHandler; import org.apache.cassandra.net.Message; import org.apache.cassandra.net.MessagingService; -import org.apache.cassandra.net.RequestCallback; import org.apache.cassandra.net.RequestCallbackWithFailure; import org.apache.cassandra.service.paxos.Commit.Agreed; import org.apache.cassandra.service.paxos.Commit.Committed; diff --git a/src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java b/src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java index a88e83136e..1627fdba8c 100644 --- a/src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java +++ b/src/java/org/apache/cassandra/service/paxos/PaxosRepairHistory.java @@ -30,7 +30,6 @@ import com.google.common.collect.ImmutableList; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.TypeSizes; import org.apache.cassandra.db.marshal.BytesType; -import org.apache.cassandra.db.marshal.TimeUUIDType; import org.apache.cassandra.db.marshal.TupleType; import org.apache.cassandra.dht.Range; import org.apache.cassandra.dht.Token; diff --git a/src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java b/src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java index ad4836676a..81e0b145b0 100644 --- a/src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java +++ b/src/java/org/apache/cassandra/service/paxos/TablePaxosRepairHistory.java @@ -23,7 +23,6 @@ import java.util.Collection; import org.apache.cassandra.db.SystemKeyspace; import org.apache.cassandra.dht.Range; import org.apache.cassandra.dht.Token; -import org.apache.cassandra.service.paxos.Ballot; public class TablePaxosRepairHistory { diff --git a/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java b/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java index 0cd95c85dd..7b882768fa 100644 --- a/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java +++ b/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupLocalCoordinator.java @@ -40,7 +40,6 @@ import org.apache.cassandra.service.paxos.PaxosRepair; import org.apache.cassandra.service.paxos.PaxosState; import org.apache.cassandra.service.paxos.uncommitted.UncommittedPaxosKey; import org.apache.cassandra.utils.CloseableIterator; -import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.concurrent.AsyncFuture; import static org.apache.cassandra.service.paxos.cleanup.PaxosCleanupSession.TIMEOUT_NANOS; diff --git a/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java b/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java index 3e081c3196..4db457f4af 100644 --- a/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java +++ b/src/java/org/apache/cassandra/service/paxos/cleanup/PaxosCleanupRequest.java @@ -43,7 +43,6 @@ import org.apache.cassandra.utils.UUIDSerializer; import static org.apache.cassandra.net.MessagingService.instance; import static org.apache.cassandra.net.NoPayload.noPayload; -import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_RSP; import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_RSP2; // TODO: send the high bound as a minimum commit point, so later repairs can terminate early if a later commit has been witnessed diff --git a/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java b/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java index 931497c730..b2a5004b80 100644 --- a/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java +++ b/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedDataFile.java @@ -46,7 +46,6 @@ import org.apache.cassandra.io.util.File; import org.apache.cassandra.io.util.RandomAccessReader; import org.apache.cassandra.io.util.SequentialWriter; import org.apache.cassandra.io.util.SequentialWriterOption; -import org.apache.cassandra.net.MessagingService; import org.apache.cassandra.schema.TableId; import org.apache.cassandra.service.paxos.Ballot; import org.apache.cassandra.utils.AbstractIterator; diff --git a/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java b/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java index 92cdb85799..dd47e40ce6 100644 --- a/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java +++ b/src/java/org/apache/cassandra/service/paxos/uncommitted/UncommittedTableData.java @@ -61,7 +61,6 @@ import org.apache.cassandra.service.paxos.PaxosRepairHistory; import org.apache.cassandra.utils.AbstractIterator; import org.apache.cassandra.utils.CloseableIterator; import org.apache.cassandra.utils.ExecutorUtils; -import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.MergeIterator; import org.apache.cassandra.utils.Throwables; diff --git a/src/java/org/apache/cassandra/service/reads/FixedSpeculativeRetryPolicy.java b/src/java/org/apache/cassandra/service/reads/FixedSpeculativeRetryPolicy.java index ce81169211..7338b2c5f5 100644 --- a/src/java/org/apache/cassandra/service/reads/FixedSpeculativeRetryPolicy.java +++ b/src/java/org/apache/cassandra/service/reads/FixedSpeculativeRetryPolicy.java @@ -23,7 +23,6 @@ import java.util.regex.Pattern; import com.google.common.base.Objects; -import com.codahale.metrics.Snapshot; import org.apache.cassandra.exceptions.ConfigurationException; import org.apache.cassandra.metrics.SnapshottingTimer; import org.apache.cassandra.schema.TableParams; diff --git a/src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java b/src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java index c7180058e8..9143a475fe 100644 --- a/src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java +++ b/src/java/org/apache/cassandra/service/reads/repair/BlockingReadRepair.java @@ -21,7 +21,6 @@ package org.apache.cassandra.service.reads.repair; import java.util.Map; import java.util.Queue; import java.util.concurrent.ConcurrentLinkedQueue; -import java.util.concurrent.TimeUnit; import org.apache.cassandra.db.DecoratedKey; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/transport/ExceptionHandlers.java b/src/java/org/apache/cassandra/transport/ExceptionHandlers.java index e2c570da86..0039bc0e7d 100644 --- a/src/java/org/apache/cassandra/transport/ExceptionHandlers.java +++ b/src/java/org/apache/cassandra/transport/ExceptionHandlers.java @@ -24,7 +24,6 @@ import java.util.Set; import java.util.concurrent.TimeUnit; import com.google.common.base.Predicate; -import com.google.common.base.Predicates; import com.google.common.collect.ImmutableSet; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/transport/messages/BatchMessage.java b/src/java/org/apache/cassandra/transport/messages/BatchMessage.java index a52480827e..de575ce045 100644 --- a/src/java/org/apache/cassandra/transport/messages/BatchMessage.java +++ b/src/java/org/apache/cassandra/transport/messages/BatchMessage.java @@ -20,13 +20,9 @@ package org.apache.cassandra.transport.messages; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; -import java.util.concurrent.TimeUnit; import com.google.common.collect.ImmutableMap; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import io.netty.buffer.ByteBuf; import org.apache.cassandra.cql3.Attributes; import org.apache.cassandra.cql3.BatchQueryOptions; @@ -49,7 +45,6 @@ import org.apache.cassandra.transport.ProtocolException; import org.apache.cassandra.transport.ProtocolVersion; import org.apache.cassandra.utils.JVMStabilityInspector; import org.apache.cassandra.utils.MD5Digest; -import org.apache.cassandra.utils.NoSpamLogger; import static org.apache.cassandra.utils.Clock.Global.currentTimeMillis; diff --git a/src/java/org/apache/cassandra/utils/CloseableIterator.java b/src/java/org/apache/cassandra/utils/CloseableIterator.java index a4cb857daf..32de799ba9 100644 --- a/src/java/org/apache/cassandra/utils/CloseableIterator.java +++ b/src/java/org/apache/cassandra/utils/CloseableIterator.java @@ -19,7 +19,6 @@ package org.apache.cassandra.utils; import java.util.Iterator; import java.util.NoSuchElementException; -import java.util.function.Supplier; // so we can instantiate anonymous classes implementing both interfaces public interface CloseableIterator extends Iterator, AutoCloseable diff --git a/src/java/org/apache/cassandra/utils/IntervalTree.java b/src/java/org/apache/cassandra/utils/IntervalTree.java index f761180cd1..35ec614a81 100644 --- a/src/java/org/apache/cassandra/utils/IntervalTree.java +++ b/src/java/org/apache/cassandra/utils/IntervalTree.java @@ -23,7 +23,6 @@ import java.lang.reflect.InvocationTargetException; import java.util.*; import com.google.common.base.Joiner; -import org.apache.cassandra.utils.AbstractIterator; import com.google.common.collect.Iterators; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/utils/Isolated.java b/src/java/org/apache/cassandra/utils/Isolated.java index 12f88e3395..d132b73a08 100644 --- a/src/java/org/apache/cassandra/utils/Isolated.java +++ b/src/java/org/apache/cassandra/utils/Isolated.java @@ -23,8 +23,6 @@ import java.lang.annotation.Retention; import java.lang.annotation.RetentionPolicy; import java.lang.annotation.Target; -import org.apache.cassandra.utils.Shared; - /** * Tells jvm-dtest that a class should be isolated and loaded into the instance class loader. * diff --git a/src/java/org/apache/cassandra/utils/NativeLibrary.java b/src/java/org/apache/cassandra/utils/NativeLibrary.java index 59a95b040c..9348433939 100644 --- a/src/java/org/apache/cassandra/utils/NativeLibrary.java +++ b/src/java/org/apache/cassandra/utils/NativeLibrary.java @@ -23,7 +23,6 @@ import java.lang.reflect.Field; import java.nio.channels.FileChannel; import java.util.concurrent.TimeUnit; -import org.apache.cassandra.config.CassandraRelevantProperties; import org.apache.cassandra.io.util.File; import org.apache.cassandra.io.util.FileInputStreamPlus; import org.slf4j.Logger; diff --git a/src/java/org/apache/cassandra/utils/UUIDGen.java b/src/java/org/apache/cassandra/utils/UUIDGen.java index 351a5d3a03..14ab23083b 100644 --- a/src/java/org/apache/cassandra/utils/UUIDGen.java +++ b/src/java/org/apache/cassandra/utils/UUIDGen.java @@ -19,7 +19,6 @@ package org.apache.cassandra.utils; import java.nio.ByteBuffer; import java.util.UUID; -import java.util.concurrent.TimeUnit; /** * The goods are here: www.ietf.org/rfc/rfc4122.txt. diff --git a/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java b/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java index 8717335d60..e61d56545f 100644 --- a/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java +++ b/src/java/org/apache/cassandra/utils/concurrent/IntrusiveStack.java @@ -25,7 +25,6 @@ import java.util.function.Consumer; import java.util.function.Function; import net.nicoulaj.compilecommand.annotations.Inline; -import org.apache.cassandra.utils.BiLongAccumulator; import org.apache.cassandra.utils.LongAccumulator; /** diff --git a/src/java/org/apache/cassandra/utils/concurrent/Ref.java b/src/java/org/apache/cassandra/utils/concurrent/Ref.java index f728a2023c..56cd7ab176 100644 --- a/src/java/org/apache/cassandra/utils/concurrent/Ref.java +++ b/src/java/org/apache/cassandra/utils/concurrent/Ref.java @@ -30,7 +30,6 @@ import java.util.*; import java.util.concurrent.*; import java.util.concurrent.atomic.AtomicInteger; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; -import java.util.function.Consumer; import org.slf4j.Logger; import org.slf4j.LoggerFactory; diff --git a/test/distributed/org/apache/cassandra/distributed/Cluster.java b/test/distributed/org/apache/cassandra/distributed/Cluster.java index 4e1690503f..b7b9207654 100644 --- a/test/distributed/org/apache/cassandra/distributed/Cluster.java +++ b/test/distributed/org/apache/cassandra/distributed/Cluster.java @@ -25,7 +25,6 @@ import org.apache.cassandra.distributed.api.IInstanceConfig; import org.apache.cassandra.distributed.impl.AbstractCluster; import org.apache.cassandra.distributed.api.IInvokableInstance; import org.apache.cassandra.distributed.shared.Versions; -import org.apache.cassandra.utils.Shared; /** * A simple cluster supporting only the 'current' Cassandra version, offering easy access to the convenience methods diff --git a/test/distributed/org/apache/cassandra/distributed/action/GossipHelper.java b/test/distributed/org/apache/cassandra/distributed/action/GossipHelper.java index 955936ef1e..b04167d960 100644 --- a/test/distributed/org/apache/cassandra/distributed/action/GossipHelper.java +++ b/test/distributed/org/apache/cassandra/distributed/action/GossipHelper.java @@ -29,7 +29,6 @@ import java.util.HashMap; import java.util.List; import java.util.Map; import java.util.UUID; -import java.util.concurrent.TimeUnit; import java.util.stream.Collectors; import java.util.stream.Stream; diff --git a/test/distributed/org/apache/cassandra/distributed/fuzz/SSTableGenerator.java b/test/distributed/org/apache/cassandra/distributed/fuzz/SSTableGenerator.java index 6140ce6b07..627d3606da 100644 --- a/test/distributed/org/apache/cassandra/distributed/fuzz/SSTableGenerator.java +++ b/test/distributed/org/apache/cassandra/distributed/fuzz/SSTableGenerator.java @@ -18,7 +18,6 @@ package org.apache.cassandra.distributed.fuzz; -import java.io.IOException; import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.Collection; diff --git a/test/distributed/org/apache/cassandra/distributed/impl/AbstractCluster.java b/test/distributed/org/apache/cassandra/distributed/impl/AbstractCluster.java index b8e4bbed26..aad18243be 100644 --- a/test/distributed/org/apache/cassandra/distributed/impl/AbstractCluster.java +++ b/test/distributed/org/apache/cassandra/distributed/impl/AbstractCluster.java @@ -97,7 +97,6 @@ import org.apache.cassandra.utils.Shared.Recursive; import org.apache.cassandra.utils.concurrent.Condition; import org.reflections.Reflections; import org.reflections.scanners.Scanners; -import org.reflections.scanners.TypeAnnotationsScanner; import org.reflections.util.ConfigurationBuilder; import org.reflections.util.NameHelper; diff --git a/test/distributed/org/apache/cassandra/distributed/impl/InstanceMetrics.java b/test/distributed/org/apache/cassandra/distributed/impl/InstanceMetrics.java index 733a671cdd..7bedce183f 100644 --- a/test/distributed/org/apache/cassandra/distributed/impl/InstanceMetrics.java +++ b/test/distributed/org/apache/cassandra/distributed/impl/InstanceMetrics.java @@ -24,7 +24,6 @@ import java.util.List; import java.util.Map; import java.util.function.Predicate; -import com.codahale.metrics.Counter; import com.codahale.metrics.Counting; import com.codahale.metrics.Gauge; import com.codahale.metrics.Histogram; diff --git a/test/distributed/org/apache/cassandra/distributed/impl/UnsafeGossipHelper.java b/test/distributed/org/apache/cassandra/distributed/impl/UnsafeGossipHelper.java index 97fa7bcbaa..7cf4c167f7 100644 --- a/test/distributed/org/apache/cassandra/distributed/impl/UnsafeGossipHelper.java +++ b/test/distributed/org/apache/cassandra/distributed/impl/UnsafeGossipHelper.java @@ -23,8 +23,6 @@ import java.net.InetSocketAddress; import java.util.Collection; import java.util.UUID; -import com.google.common.collect.Iterables; - import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.SystemKeyspace; import org.apache.cassandra.dht.IPartitioner; diff --git a/test/distributed/org/apache/cassandra/distributed/test/AbstractEncryptionOptionsImpl.java b/test/distributed/org/apache/cassandra/distributed/test/AbstractEncryptionOptionsImpl.java index 0d12c7ca96..1c5ddbf6b5 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/AbstractEncryptionOptionsImpl.java +++ b/test/distributed/org/apache/cassandra/distributed/test/AbstractEncryptionOptionsImpl.java @@ -56,7 +56,6 @@ import org.apache.cassandra.security.SSLFactory; import static java.util.concurrent.TimeUnit.SECONDS; import static org.apache.cassandra.distributed.test.AbstractEncryptionOptionsImpl.ConnectResult.CONNECTING; import static org.apache.cassandra.distributed.test.AbstractEncryptionOptionsImpl.ConnectResult.UNINITIALIZED; -import static org.apache.cassandra.security.SSLFactory.getOrCreateSslContext; import static org.apache.cassandra.utils.concurrent.Condition.newOneTimeCondition; public class AbstractEncryptionOptionsImpl extends TestBaseImpl diff --git a/test/distributed/org/apache/cassandra/distributed/test/CASAddTest.java b/test/distributed/org/apache/cassandra/distributed/test/CASAddTest.java index c50b9b526e..d6c892e151 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/CASAddTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/CASAddTest.java @@ -30,8 +30,6 @@ import org.assertj.core.api.Assertions; import static org.apache.cassandra.distributed.shared.AssertUtils.assertRows; import static org.apache.cassandra.distributed.shared.AssertUtils.row; -import static org.junit.Assert.assertFalse; -import static org.junit.Assert.assertTrue; public class CASAddTest extends TestBaseImpl { diff --git a/test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java b/test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java index 7ed59da0f1..cae6eefef8 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java +++ b/test/distributed/org/apache/cassandra/distributed/test/CASTestBase.java @@ -26,7 +26,6 @@ import org.junit.Assert; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.cassandra.db.ConsistencyLevel; import org.apache.cassandra.db.DecoratedKey; import org.apache.cassandra.db.Keyspace; import org.apache.cassandra.db.marshal.Int32Type; diff --git a/test/distributed/org/apache/cassandra/distributed/test/FailingTruncationTest.java b/test/distributed/org/apache/cassandra/distributed/test/FailingTruncationTest.java index ee573c4315..dd419dbf2b 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/FailingTruncationTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/FailingTruncationTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.distributed.test; import java.io.IOException; -import java.util.concurrent.atomic.AtomicBoolean; import org.junit.Test; diff --git a/test/distributed/org/apache/cassandra/distributed/test/GossipShutdownTest.java b/test/distributed/org/apache/cassandra/distributed/test/GossipShutdownTest.java index d6a418874d..c05925fa0e 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/GossipShutdownTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/GossipShutdownTest.java @@ -30,10 +30,8 @@ import org.apache.cassandra.utils.concurrent.Condition; import org.junit.Test; import org.apache.cassandra.distributed.Cluster; -import org.apache.cassandra.gms.ApplicationState; import org.apache.cassandra.gms.EndpointState; import org.apache.cassandra.gms.IEndpointStateChangeSubscriber; -import org.apache.cassandra.gms.VersionedValue; import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.service.StorageService; diff --git a/test/distributed/org/apache/cassandra/distributed/test/NativeProtocolTest.java b/test/distributed/org/apache/cassandra/distributed/test/NativeProtocolTest.java index 389b0a9c32..f965572d80 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/NativeProtocolTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/NativeProtocolTest.java @@ -31,14 +31,6 @@ import com.datastax.driver.core.ResultSet; import com.datastax.driver.core.Session; import com.datastax.driver.core.SimpleStatement; import com.datastax.driver.core.Statement; -import com.datastax.driver.core.exceptions.DriverInternalError; -import com.datastax.driver.core.policies.LoadBalancingPolicy; -import net.bytebuddy.ByteBuddy; -import net.bytebuddy.dynamic.loading.ClassLoadingStrategy; -import net.bytebuddy.implementation.MethodDelegation; -import org.apache.cassandra.cql3.CQLStatement; -import org.apache.cassandra.cql3.QueryHandler; -import org.apache.cassandra.cql3.QueryProcessor; import org.apache.cassandra.distributed.api.ICluster; import org.apache.cassandra.distributed.impl.RowUtil; diff --git a/test/distributed/org/apache/cassandra/distributed/test/RepairTest.java b/test/distributed/org/apache/cassandra/distributed/test/RepairTest.java index 23ce43c12f..669e762c10 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/RepairTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/RepairTest.java @@ -22,7 +22,6 @@ import java.io.IOException; import java.util.Arrays; import java.util.Map; import java.util.Set; -import java.util.concurrent.TimeUnit; import java.util.function.Consumer; import com.google.common.collect.ImmutableMap; diff --git a/test/distributed/org/apache/cassandra/distributed/test/ReplicaFilteringProtectionTest.java b/test/distributed/org/apache/cassandra/distributed/test/ReplicaFilteringProtectionTest.java index 12239f8ee9..099ea053ae 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/ReplicaFilteringProtectionTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/ReplicaFilteringProtectionTest.java @@ -22,8 +22,6 @@ import java.io.IOException; import java.util.List; import org.junit.AfterClass; -import org.junit.Assume; -import org.junit.AssumptionViolatedException; import org.junit.BeforeClass; import org.junit.Test; diff --git a/test/distributed/org/apache/cassandra/distributed/test/UpgradeSSTablesTest.java b/test/distributed/org/apache/cassandra/distributed/test/UpgradeSSTablesTest.java index c599f17e87..ee89a81019 100644 --- a/test/distributed/org/apache/cassandra/distributed/test/UpgradeSSTablesTest.java +++ b/test/distributed/org/apache/cassandra/distributed/test/UpgradeSSTablesTest.java @@ -23,7 +23,6 @@ import java.util.Set; import org.junit.Assert; import org.junit.Test; -import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.ColumnFamilyStore; import org.apache.cassandra.db.Keyspace; import org.apache.cassandra.distributed.api.ConsistencyLevel; diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/GroupByTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/GroupByTest.java index 634c886f13..b09b882f69 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/GroupByTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/GroupByTest.java @@ -21,7 +21,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; import org.apache.cassandra.distributed.api.ConsistencyLevel; -import org.apache.cassandra.distributed.shared.Versions; import static org.apache.cassandra.distributed.api.Feature.GOSSIP; import static org.apache.cassandra.distributed.api.Feature.NETWORK; diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV30Test.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV30Test.java index 8687c55e17..2712a46040 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV30Test.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV30Test.java @@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import org.apache.cassandra.distributed.shared.Versions; - /** * {@link MixedModeConsistencyTestBase} for upgrades from v30. */ diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV3XTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV3XTest.java index 9e4ec6a70b..d39ea56039 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV3XTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeConsistencyV3XTest.java @@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import org.apache.cassandra.distributed.shared.Versions; - /** * {@link MixedModeConsistencyTestBase} for upgrades from v3X. */ diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3LoggedBatchTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3LoggedBatchTest.java index 77eb0586d8..7326f6fec9 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3LoggedBatchTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3LoggedBatchTest.java @@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import org.apache.cassandra.distributed.shared.Versions; - public class MixedModeFrom3LoggedBatchTest extends MixedModeBatchTestBase { @Test diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3ReplicationTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3ReplicationTest.java index a38e25d4b5..4902385619 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3ReplicationTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3ReplicationTest.java @@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import org.apache.cassandra.distributed.shared.Versions; - public class MixedModeFrom3ReplicationTest extends MixedModeReplicationTestBase { @Test diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3UnloggedBatchTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3UnloggedBatchTest.java index 7256d2e0cd..d169142367 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3UnloggedBatchTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeFrom3UnloggedBatchTest.java @@ -20,8 +20,6 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import org.apache.cassandra.distributed.shared.Versions; - public class MixedModeFrom3UnloggedBatchTest extends MixedModeBatchTestBase { @Test diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeGossipTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeGossipTest.java index 35c4fb3815..f4c9695fcb 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeGossipTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeGossipTest.java @@ -33,7 +33,6 @@ import org.junit.Test; import org.apache.cassandra.distributed.UpgradeableCluster; import org.apache.cassandra.distributed.api.Feature; import org.apache.cassandra.distributed.api.IMessageFilters; -import org.apache.cassandra.distributed.shared.Versions; import org.apache.cassandra.net.Verb; import org.assertj.core.api.Assertions; diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeReadTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeReadTest.java index b11678dc55..cbbcff0fb6 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeReadTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/MixedModeReadTest.java @@ -22,7 +22,6 @@ import org.junit.Test; import org.apache.cassandra.distributed.api.Feature; import org.apache.cassandra.distributed.api.IInvokableInstance; -import org.apache.cassandra.distributed.shared.Versions; import org.apache.cassandra.gms.Gossiper; import org.apache.cassandra.utils.CassandraVersion; diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/RepairRequestTimeoutUpgradeTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/RepairRequestTimeoutUpgradeTest.java index 9ef4fc0c83..4929d8dea6 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/RepairRequestTimeoutUpgradeTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/RepairRequestTimeoutUpgradeTest.java @@ -20,13 +20,8 @@ package org.apache.cassandra.distributed.upgrade; import org.junit.Test; -import com.vdurmont.semver4j.Semver; -import org.apache.cassandra.distributed.api.ConsistencyLevel; import org.apache.cassandra.distributed.api.Feature; -import static org.apache.cassandra.distributed.shared.AssertUtils.assertRows; -import static org.apache.cassandra.distributed.shared.AssertUtils.row; -import static org.apache.cassandra.net.Verb.SYNC_REQ; import static org.apache.cassandra.net.Verb.VALIDATION_REQ; public class RepairRequestTimeoutUpgradeTest extends UpgradeTestBase diff --git a/test/distributed/org/apache/cassandra/distributed/upgrade/UpgradeTest.java b/test/distributed/org/apache/cassandra/distributed/upgrade/UpgradeTest.java index 691d8af94f..b1692b986b 100644 --- a/test/distributed/org/apache/cassandra/distributed/upgrade/UpgradeTest.java +++ b/test/distributed/org/apache/cassandra/distributed/upgrade/UpgradeTest.java @@ -22,7 +22,6 @@ import org.junit.Test; import org.apache.cassandra.distributed.api.ConsistencyLevel; import org.apache.cassandra.distributed.api.Feature; -import org.apache.cassandra.distributed.shared.Versions; import static org.apache.cassandra.distributed.shared.AssertUtils.*; public class UpgradeTest extends UpgradeTestBase diff --git a/test/microbench/org/apache/cassandra/test/microbench/btree/AtomicBTreePartitionUpdateBench.java b/test/microbench/org/apache/cassandra/test/microbench/btree/AtomicBTreePartitionUpdateBench.java index 767e3f942a..34ec29ac59 100644 --- a/test/microbench/org/apache/cassandra/test/microbench/btree/AtomicBTreePartitionUpdateBench.java +++ b/test/microbench/org/apache/cassandra/test/microbench/btree/AtomicBTreePartitionUpdateBench.java @@ -24,7 +24,6 @@ import java.util.Comparator; import java.util.List; import java.util.Random; import java.util.UUID; -import java.util.concurrent.CompletableFuture; import java.util.concurrent.ThreadLocalRandom; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicInteger; diff --git a/test/simulator/asm/org/apache/cassandra/simulator/asm/InterceptAgent.java b/test/simulator/asm/org/apache/cassandra/simulator/asm/InterceptAgent.java index c58c5d26da..87cfab0f6f 100644 --- a/test/simulator/asm/org/apache/cassandra/simulator/asm/InterceptAgent.java +++ b/test/simulator/asm/org/apache/cassandra/simulator/asm/InterceptAgent.java @@ -45,11 +45,9 @@ import static org.apache.cassandra.simulator.asm.Flag.LOCK_SUPPORT; import static org.apache.cassandra.simulator.asm.Flag.NO_PROXY_METHODS; import static org.apache.cassandra.simulator.asm.Flag.SYSTEM_CLOCK; import static org.apache.cassandra.simulator.asm.InterceptClasses.BYTECODE_VERSION; -import static org.objectweb.asm.Opcodes.ARETURN; import static org.objectweb.asm.Opcodes.ALOAD; import static org.objectweb.asm.Opcodes.GETFIELD; import static org.objectweb.asm.Opcodes.GETSTATIC; -import static org.objectweb.asm.Opcodes.INVOKEINTERFACE; import static org.objectweb.asm.Opcodes.INVOKESPECIAL; import static org.objectweb.asm.Opcodes.INVOKESTATIC; import static org.objectweb.asm.Opcodes.INVOKEVIRTUAL; diff --git a/test/simulator/asm/org/apache/cassandra/simulator/asm/MethodLogger.java b/test/simulator/asm/org/apache/cassandra/simulator/asm/MethodLogger.java index 45f33dd90e..1e6a844772 100644 --- a/test/simulator/asm/org/apache/cassandra/simulator/asm/MethodLogger.java +++ b/test/simulator/asm/org/apache/cassandra/simulator/asm/MethodLogger.java @@ -27,7 +27,6 @@ import java.util.EnumSet; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; import java.util.regex.Pattern; -import java.util.stream.Collectors; import org.objectweb.asm.MethodVisitor; import org.objectweb.asm.util.Printer; diff --git a/test/simulator/main/org/apache/cassandra/simulator/ClusterSimulation.java b/test/simulator/main/org/apache/cassandra/simulator/ClusterSimulation.java index a1f68621df..caf642e218 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/ClusterSimulation.java +++ b/test/simulator/main/org/apache/cassandra/simulator/ClusterSimulation.java @@ -102,7 +102,6 @@ import static java.util.concurrent.TimeUnit.NANOSECONDS; import static java.util.concurrent.TimeUnit.SECONDS; import static org.apache.cassandra.distributed.impl.AbstractCluster.getSharedClassPredicate; import static org.apache.cassandra.simulator.SimulatorUtils.failWithOOM; -import static org.apache.cassandra.simulator.systems.NonInterceptible.Permit.REQUIRED; import static org.apache.cassandra.utils.Shared.Scope.ANY; import static org.apache.cassandra.utils.Shared.Scope.SIMULATION; diff --git a/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java b/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java index 63496f1de7..8fa9375a67 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java +++ b/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceBootstrap.java @@ -29,7 +29,6 @@ import org.apache.cassandra.simulator.systems.SimulatedActionTask; import static java.util.Collections.singletonList; import static org.apache.cassandra.simulator.Action.Modifier.DISPLAY_ORIGIN; import static org.apache.cassandra.simulator.Action.Modifiers.RELIABLE_NO_TIMEOUTS; -import static org.apache.cassandra.simulator.Action.Modifiers.RELIABLE_NO_TIMEOUTS; import static org.apache.cassandra.simulator.cluster.Utils.parseTokens; class OnInstanceBootstrap extends SimulatedActionTask diff --git a/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java b/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java index e5b2c5747f..0532b35d89 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java +++ b/test/simulator/main/org/apache/cassandra/simulator/cluster/OnInstanceGossipWith.java @@ -21,7 +21,6 @@ package org.apache.cassandra.simulator.cluster; import java.net.InetSocketAddress; import java.util.function.BiFunction; -import org.apache.cassandra.cql3.functions.Function; import org.apache.cassandra.distributed.Cluster; import org.apache.cassandra.distributed.api.IIsolatedExecutor; import org.apache.cassandra.gms.Gossiper; diff --git a/test/simulator/main/org/apache/cassandra/simulator/debug/Reconcile.java b/test/simulator/main/org/apache/cassandra/simulator/debug/Reconcile.java index 61700c5c73..5acf7648fe 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/debug/Reconcile.java +++ b/test/simulator/main/org/apache/cassandra/simulator/debug/Reconcile.java @@ -40,7 +40,6 @@ import org.apache.cassandra.io.util.File; import org.apache.cassandra.simulator.ClusterSimulation; import org.apache.cassandra.simulator.RandomSource; import org.apache.cassandra.simulator.SimulationRunner.RecordOption; -import org.apache.cassandra.simulator.systems.InterceptedWait; import org.apache.cassandra.simulator.systems.InterceptedWait.CaptureSites.Capture; import org.apache.cassandra.simulator.systems.SimulatedTime; import org.apache.cassandra.utils.Closeable; diff --git a/test/simulator/main/org/apache/cassandra/simulator/paxos/PairOfSequencesPaxosSimulation.java b/test/simulator/main/org/apache/cassandra/simulator/paxos/PairOfSequencesPaxosSimulation.java index b94648d495..77eefb337b 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/paxos/PairOfSequencesPaxosSimulation.java +++ b/test/simulator/main/org/apache/cassandra/simulator/paxos/PairOfSequencesPaxosSimulation.java @@ -21,7 +21,6 @@ package org.apache.cassandra.simulator.paxos; import java.util.ArrayList; import java.util.Arrays; import java.util.List; -import java.util.concurrent.ExecutionException; import java.util.concurrent.atomic.AtomicInteger; import java.util.function.LongSupplier; import java.util.function.Supplier; @@ -53,7 +52,6 @@ import org.apache.cassandra.simulator.systems.SimulatedActionTask; import org.apache.cassandra.simulator.systems.SimulatedSystems; import org.apache.cassandra.simulator.utils.IntRange; import org.apache.cassandra.utils.ByteBufferUtil; -import org.apache.cassandra.utils.concurrent.UncheckedInterruptedException; import static java.lang.Boolean.TRUE; import static java.util.Collections.emptyList; diff --git a/test/simulator/main/org/apache/cassandra/simulator/paxos/PaxosTopologyChangeVerifier.java b/test/simulator/main/org/apache/cassandra/simulator/paxos/PaxosTopologyChangeVerifier.java index 694efe754e..46c4c9ecf6 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/paxos/PaxosTopologyChangeVerifier.java +++ b/test/simulator/main/org/apache/cassandra/simulator/paxos/PaxosTopologyChangeVerifier.java @@ -21,7 +21,6 @@ package org.apache.cassandra.simulator.paxos; import org.apache.cassandra.distributed.Cluster; import org.apache.cassandra.simulator.cluster.ClusterActionListener.TopologyChangeValidator; import org.apache.cassandra.simulator.cluster.Topology; -import org.apache.cassandra.simulator.systems.NonInterceptible; import static java.util.Arrays.stream; import static org.apache.cassandra.simulator.systems.NonInterceptible.Permit.REQUIRED; diff --git a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutor.java b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutor.java index 26f096e84d..94e068c661 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutor.java +++ b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutor.java @@ -35,8 +35,6 @@ import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicIntegerFieldUpdater; -import com.google.common.base.Preconditions; - import org.apache.cassandra.concurrent.ExecutorPlus; import org.apache.cassandra.concurrent.LocalAwareExecutorPlus; import org.apache.cassandra.concurrent.LocalAwareSequentialExecutorPlus; diff --git a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutorFactory.java b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutorFactory.java index a7915e1d6e..c7f4dce8b8 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutorFactory.java +++ b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptingExecutorFactory.java @@ -27,7 +27,6 @@ import java.util.concurrent.ThreadFactory; import java.util.concurrent.TimeUnit; import java.util.function.BiFunction; import java.util.function.Consumer; -import java.util.function.Supplier; import com.google.common.annotations.VisibleForTesting; @@ -49,10 +48,8 @@ import org.apache.cassandra.concurrent.Interruptible; import org.apache.cassandra.concurrent.SyncFutureTask; import org.apache.cassandra.concurrent.TaskFactory; import org.apache.cassandra.distributed.api.IIsolatedExecutor; -import org.apache.cassandra.distributed.api.IIsolatedExecutor.QuadFunction; import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableBiFunction; import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableCallable; -import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableFunction; import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableQuadFunction; import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableRunnable; import org.apache.cassandra.distributed.api.IIsolatedExecutor.SerializableSupplier; @@ -68,10 +65,8 @@ import org.apache.cassandra.simulator.systems.InterceptingExecutor.InterceptingS import org.apache.cassandra.simulator.systems.InterceptorOfExecution.InterceptExecution; import org.apache.cassandra.simulator.systems.SimulatedTime.LocalTime; import org.apache.cassandra.utils.Closeable; -import org.apache.cassandra.utils.JVMStabilityInspector; import org.apache.cassandra.utils.WithResources; import org.apache.cassandra.utils.concurrent.RunnableFuture; -import org.apache.cassandra.utils.concurrent.UncheckedInterruptedException; import static org.apache.cassandra.simulator.systems.SimulatedAction.Kind.INFINITE_LOOP; diff --git a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptorOfGlobalMethods.java b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptorOfGlobalMethods.java index dde5870ffd..749f91e42d 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptorOfGlobalMethods.java +++ b/test/simulator/main/org/apache/cassandra/simulator/systems/InterceptorOfGlobalMethods.java @@ -25,9 +25,6 @@ import java.util.function.IntSupplier; import java.util.function.LongConsumer; import java.util.function.ToIntFunction; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import net.openhft.chronicle.core.util.WeakIdentityHashMap; import org.apache.cassandra.simulator.systems.InterceptedWait.CaptureSites; import org.apache.cassandra.utils.Clock; diff --git a/test/simulator/main/org/apache/cassandra/simulator/systems/NetworkConfig.java b/test/simulator/main/org/apache/cassandra/simulator/systems/NetworkConfig.java index db4297aab8..bde5e9e8cc 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/systems/NetworkConfig.java +++ b/test/simulator/main/org/apache/cassandra/simulator/systems/NetworkConfig.java @@ -19,7 +19,6 @@ package org.apache.cassandra.simulator.systems; import org.apache.cassandra.simulator.utils.ChanceRange; -import org.apache.cassandra.simulator.utils.IntRange; import org.apache.cassandra.simulator.utils.LongRange; public class NetworkConfig diff --git a/test/simulator/main/org/apache/cassandra/simulator/systems/NonInterceptible.java b/test/simulator/main/org/apache/cassandra/simulator/systems/NonInterceptible.java index 61f7f7878a..6aee396f92 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/systems/NonInterceptible.java +++ b/test/simulator/main/org/apache/cassandra/simulator/systems/NonInterceptible.java @@ -23,8 +23,6 @@ import java.util.function.Supplier; import org.apache.cassandra.utils.Shared; -import static java.lang.Boolean.FALSE; -import static java.lang.Boolean.TRUE; import static org.apache.cassandra.utils.Shared.Scope.SIMULATION; @Shared(scope = SIMULATION) diff --git a/test/simulator/main/org/apache/cassandra/simulator/utils/IntRange.java b/test/simulator/main/org/apache/cassandra/simulator/utils/IntRange.java index fa5ce6e176..ad465dd544 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/utils/IntRange.java +++ b/test/simulator/main/org/apache/cassandra/simulator/utils/IntRange.java @@ -25,9 +25,6 @@ import com.google.common.base.Preconditions; import org.apache.cassandra.simulator.RandomSource; -import static java.util.concurrent.TimeUnit.NANOSECONDS; -import static java.util.concurrent.TimeUnit.SECONDS; - public class IntRange { public final int min; diff --git a/test/simulator/main/org/apache/cassandra/simulator/utils/LongRange.java b/test/simulator/main/org/apache/cassandra/simulator/utils/LongRange.java index 103ee85adc..92c4051239 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/utils/LongRange.java +++ b/test/simulator/main/org/apache/cassandra/simulator/utils/LongRange.java @@ -21,8 +21,6 @@ package org.apache.cassandra.simulator.utils; import java.util.Optional; import java.util.concurrent.TimeUnit; -import com.google.common.base.Preconditions; - import org.apache.cassandra.simulator.RandomSource; import static java.util.concurrent.TimeUnit.NANOSECONDS; diff --git a/test/simulator/main/org/apache/cassandra/simulator/utils/SafeCollections.java b/test/simulator/main/org/apache/cassandra/simulator/utils/SafeCollections.java index a1778cc57d..396a4beb16 100644 --- a/test/simulator/main/org/apache/cassandra/simulator/utils/SafeCollections.java +++ b/test/simulator/main/org/apache/cassandra/simulator/utils/SafeCollections.java @@ -19,7 +19,6 @@ package org.apache.cassandra.simulator.utils; import java.util.Collection; -import java.util.List; import java.util.function.Consumer; import org.apache.cassandra.utils.Throwables; diff --git a/test/simulator/test/org/apache/cassandra/simulator/test/ShortPaxosSimulationTest.java b/test/simulator/test/org/apache/cassandra/simulator/test/ShortPaxosSimulationTest.java index 7e726ed435..19d66018c6 100644 --- a/test/simulator/test/org/apache/cassandra/simulator/test/ShortPaxosSimulationTest.java +++ b/test/simulator/test/org/apache/cassandra/simulator/test/ShortPaxosSimulationTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.simulator.test; import java.io.IOException; -import java.util.concurrent.ThreadLocalRandom; import org.junit.Ignore; import org.junit.Test; @@ -33,12 +32,11 @@ public class ShortPaxosSimulationTest { PaxosSimulationRunner.main(new String[] { "run", "-n", "3..6", "-t", "1000", "-c", "2", "--cluster-action-limit", "2", "-s", "30" }); } -// -// fails due to OOM DirectMemory - unclear why -// -// @Test -// public void selfReconcileTest() throws IOException -// { -// PaxosSimulationRunner.main(new String[] { "reconcile", "-n", "3..6", "-t", "1000", "-c", "2", "--cluster-action-limit", "2", "-s", "30", "--with-self" }); -// } + + @Test + @Ignore("fails due to OOM DirectMemory - unclear why") + public void selfReconcileTest() throws IOException + { + PaxosSimulationRunner.main(new String[] { "reconcile", "-n", "3..6", "-t", "1000", "-c", "2", "--cluster-action-limit", "2", "-s", "30", "--with-self" }); + } } diff --git a/test/simulator/test/org/apache/cassandra/simulator/test/TrivialSimulationTest.java b/test/simulator/test/org/apache/cassandra/simulator/test/TrivialSimulationTest.java index 892adca8bc..cf8fe1b25f 100644 --- a/test/simulator/test/org/apache/cassandra/simulator/test/TrivialSimulationTest.java +++ b/test/simulator/test/org/apache/cassandra/simulator/test/TrivialSimulationTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.simulator.test; import java.io.IOException; -import java.util.Collections; import java.util.EnumMap; import java.util.IdentityHashMap; diff --git a/test/unit/org/apache/cassandra/config/FailStartupDuplicateParamsTest.java b/test/unit/org/apache/cassandra/config/FailStartupDuplicateParamsTest.java index 073ff8f9b1..341a0e83ec 100644 --- a/test/unit/org/apache/cassandra/config/FailStartupDuplicateParamsTest.java +++ b/test/unit/org/apache/cassandra/config/FailStartupDuplicateParamsTest.java @@ -19,20 +19,16 @@ package org.apache.cassandra.config; import java.io.IOException; -import java.net.URISyntaxException; import java.net.URL; import java.nio.file.Files; import java.nio.file.Path; -import java.nio.file.Paths; import java.util.ArrayList; import java.util.Collections; import java.util.List; import java.util.function.Predicate; import com.google.common.collect.ImmutableList; -import com.google.common.collect.Lists; import org.junit.Before; -import org.junit.BeforeClass; import org.junit.Test; import static org.apache.cassandra.config.CassandraRelevantProperties.ALLOW_DUPLICATE_CONFIG_KEYS; diff --git a/test/unit/org/apache/cassandra/cql3/validation/operations/DeleteTest.java b/test/unit/org/apache/cassandra/cql3/validation/operations/DeleteTest.java index eda49a6557..980b791e77 100644 --- a/test/unit/org/apache/cassandra/cql3/validation/operations/DeleteTest.java +++ b/test/unit/org/apache/cassandra/cql3/validation/operations/DeleteTest.java @@ -28,7 +28,6 @@ import org.junit.Test; import org.apache.cassandra.cql3.CQLTester; import org.apache.cassandra.db.ColumnFamilyStore; import org.apache.cassandra.db.Keyspace; -import org.apache.cassandra.utils.btree.BTree; import static org.apache.cassandra.utils.ByteBufferUtil.EMPTY_BYTE_BUFFER; import static org.apache.cassandra.utils.ByteBufferUtil.bytes; diff --git a/test/unit/org/apache/cassandra/cql3/validation/operations/InsertUpdateIfConditionTest.java b/test/unit/org/apache/cassandra/cql3/validation/operations/InsertUpdateIfConditionTest.java index 20acd10ff1..8429ec0b3d 100644 --- a/test/unit/org/apache/cassandra/cql3/validation/operations/InsertUpdateIfConditionTest.java +++ b/test/unit/org/apache/cassandra/cql3/validation/operations/InsertUpdateIfConditionTest.java @@ -21,8 +21,6 @@ package org.apache.cassandra.cql3.validation.operations; import java.util.Arrays; import java.util.Collection; -import com.google.common.annotations.VisibleForTesting; - import org.junit.AfterClass; import org.junit.Before; import org.junit.BeforeClass; diff --git a/test/unit/org/apache/cassandra/cql3/validation/operations/TTLTest.java b/test/unit/org/apache/cassandra/cql3/validation/operations/TTLTest.java index aaaecd0da9..9ef2520c78 100644 --- a/test/unit/org/apache/cassandra/cql3/validation/operations/TTLTest.java +++ b/test/unit/org/apache/cassandra/cql3/validation/operations/TTLTest.java @@ -42,7 +42,6 @@ import org.apache.cassandra.io.util.FileOutputStreamPlus; import org.apache.cassandra.tools.StandaloneScrubber; import org.apache.cassandra.tools.ToolRunner; import org.apache.cassandra.tools.ToolRunner.ToolResult; -import org.apache.cassandra.utils.FBUtilities; import org.assertj.core.api.Assertions; import static org.junit.Assert.assertEquals; diff --git a/test/unit/org/apache/cassandra/db/CellTest.java b/test/unit/org/apache/cassandra/db/CellTest.java index 90c18ffc6c..4100c541aa 100644 --- a/test/unit/org/apache/cassandra/db/CellTest.java +++ b/test/unit/org/apache/cassandra/db/CellTest.java @@ -22,8 +22,6 @@ import java.nio.ByteBuffer; import java.util.ArrayList; import java.util.List; -import com.google.common.collect.Lists; - import org.junit.Assert; import org.junit.BeforeClass; import org.junit.Test; @@ -41,7 +39,6 @@ import org.apache.cassandra.schema.KeyspaceParams; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.serializers.MarshalException; import org.apache.cassandra.utils.ByteBufferUtil; -import org.apache.cassandra.utils.FBUtilities; import static java.util.Arrays.asList; diff --git a/test/unit/org/apache/cassandra/db/commitlog/CommitLogFailurePolicyTest.java b/test/unit/org/apache/cassandra/db/commitlog/CommitLogFailurePolicyTest.java index 79f83fe1f5..aadd2fda3b 100644 --- a/test/unit/org/apache/cassandra/db/commitlog/CommitLogFailurePolicyTest.java +++ b/test/unit/org/apache/cassandra/db/commitlog/CommitLogFailurePolicyTest.java @@ -25,7 +25,6 @@ import org.junit.Test; import org.apache.cassandra.SchemaLoader; import org.apache.cassandra.config.Config; import org.apache.cassandra.config.DatabaseDescriptor; -import org.apache.cassandra.db.commitlog.CommitLog; import org.apache.cassandra.exceptions.ConfigurationException; import org.apache.cassandra.gms.Gossiper; import org.apache.cassandra.service.CassandraDaemon; diff --git a/test/unit/org/apache/cassandra/db/compaction/TTLExpiryTest.java b/test/unit/org/apache/cassandra/db/compaction/TTLExpiryTest.java index 0711f4ae04..0e3fb7659f 100644 --- a/test/unit/org/apache/cassandra/db/compaction/TTLExpiryTest.java +++ b/test/unit/org/apache/cassandra/db/compaction/TTLExpiryTest.java @@ -40,7 +40,6 @@ import org.apache.cassandra.db.marshal.*; import org.apache.cassandra.io.sstable.format.SSTableReader; import org.apache.cassandra.io.sstable.format.SSTableReadsListener; import org.apache.cassandra.exceptions.ConfigurationException; -import org.apache.cassandra.io.sstable.ISSTableScanner; import org.apache.cassandra.schema.KeyspaceParams; import org.apache.cassandra.tools.SSTableExpiredBlockers; import org.apache.cassandra.utils.ByteBufferUtil; diff --git a/test/unit/org/apache/cassandra/db/compaction/TimeWindowCompactionStrategyTest.java b/test/unit/org/apache/cassandra/db/compaction/TimeWindowCompactionStrategyTest.java index a9b148eedd..581801653b 100644 --- a/test/unit/org/apache/cassandra/db/compaction/TimeWindowCompactionStrategyTest.java +++ b/test/unit/org/apache/cassandra/db/compaction/TimeWindowCompactionStrategyTest.java @@ -34,7 +34,6 @@ import static org.junit.Assert.assertFalse; import static org.junit.Assert.assertNotNull; import static org.junit.Assert.assertNull; import static org.junit.Assert.assertTrue; -import static org.junit.Assert.assertFalse; import static org.junit.Assert.fail; import org.apache.cassandra.SchemaLoader; diff --git a/test/unit/org/apache/cassandra/db/guardrails/GuardrailMinimumReplicationFactorTest.java b/test/unit/org/apache/cassandra/db/guardrails/GuardrailMinimumReplicationFactorTest.java index 9c984e99f5..d3df9833ff 100644 --- a/test/unit/org/apache/cassandra/db/guardrails/GuardrailMinimumReplicationFactorTest.java +++ b/test/unit/org/apache/cassandra/db/guardrails/GuardrailMinimumReplicationFactorTest.java @@ -31,7 +31,6 @@ import org.junit.Test; import org.apache.cassandra.ServerTestUtils; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.Keyspace; -import org.apache.cassandra.exceptions.ConfigurationException; import org.apache.cassandra.locator.AbstractEndpointSnitch; import org.apache.cassandra.locator.IEndpointSnitch; import org.apache.cassandra.locator.InetAddressAndPort; diff --git a/test/unit/org/apache/cassandra/db/marshal/DecimalTypeTest.java b/test/unit/org/apache/cassandra/db/marshal/DecimalTypeTest.java index 108f48ff05..b1f4a439c9 100644 --- a/test/unit/org/apache/cassandra/db/marshal/DecimalTypeTest.java +++ b/test/unit/org/apache/cassandra/db/marshal/DecimalTypeTest.java @@ -24,7 +24,6 @@ import java.math.BigDecimal; import java.nio.ByteBuffer; import java.util.Arrays; -import org.apache.cassandra.db.marshal.DecimalType; import org.apache.cassandra.utils.ByteBufferUtil; import org.junit.Test; diff --git a/test/unit/org/apache/cassandra/db/virtual/LocalRepairTablesTest.java b/test/unit/org/apache/cassandra/db/virtual/LocalRepairTablesTest.java index 6c3f3a1f1c..2a6da1ac69 100644 --- a/test/unit/org/apache/cassandra/db/virtual/LocalRepairTablesTest.java +++ b/test/unit/org/apache/cassandra/db/virtual/LocalRepairTablesTest.java @@ -22,7 +22,6 @@ import java.util.Arrays; import java.util.Collections; import java.util.Date; import java.util.List; -import java.util.Set; import java.util.stream.Collectors; import com.google.common.collect.ImmutableList; diff --git a/test/unit/org/apache/cassandra/db/virtual/SSTableTasksTableTest.java b/test/unit/org/apache/cassandra/db/virtual/SSTableTasksTableTest.java index 356ae416dc..f642a2f18d 100644 --- a/test/unit/org/apache/cassandra/db/virtual/SSTableTasksTableTest.java +++ b/test/unit/org/apache/cassandra/db/virtual/SSTableTasksTableTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.db.virtual; import java.util.List; -import java.util.UUID; import java.util.stream.Collectors; import java.util.stream.IntStream; diff --git a/test/unit/org/apache/cassandra/locator/SimpleStrategyTest.java b/test/unit/org/apache/cassandra/locator/SimpleStrategyTest.java index 809b6fc989..ca4841dfe8 100644 --- a/test/unit/org/apache/cassandra/locator/SimpleStrategyTest.java +++ b/test/unit/org/apache/cassandra/locator/SimpleStrategyTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.locator; import java.net.UnknownHostException; import java.util.ArrayList; -import java.util.Collection; import java.util.HashMap; import java.util.HashSet; import java.util.List; diff --git a/test/unit/org/apache/cassandra/net/ChunkedInputPlusTest.java b/test/unit/org/apache/cassandra/net/ChunkedInputPlusTest.java index 3209759a49..36bc53d815 100644 --- a/test/unit/org/apache/cassandra/net/ChunkedInputPlusTest.java +++ b/test/unit/org/apache/cassandra/net/ChunkedInputPlusTest.java @@ -29,8 +29,6 @@ import org.junit.BeforeClass; import org.junit.Test; import org.apache.cassandra.config.DatabaseDescriptor; -import org.apache.cassandra.net.ChunkedInputPlus; -import org.apache.cassandra.net.ShareableBytes; import static org.junit.Assert.*; diff --git a/test/unit/org/apache/cassandra/net/PrunableArrayQueueTest.java b/test/unit/org/apache/cassandra/net/PrunableArrayQueueTest.java index 50e0928123..e9a60cd3f3 100644 --- a/test/unit/org/apache/cassandra/net/PrunableArrayQueueTest.java +++ b/test/unit/org/apache/cassandra/net/PrunableArrayQueueTest.java @@ -24,8 +24,6 @@ import org.junit.Test; import org.slf4j.Logger; import org.slf4j.LoggerFactory; -import org.apache.cassandra.net.PrunableArrayQueue; - import static org.junit.Assert.*; public class PrunableArrayQueueTest diff --git a/test/unit/org/apache/cassandra/repair/RepairJobTest.java b/test/unit/org/apache/cassandra/repair/RepairJobTest.java index 6f410e110a..c7c68c4689 100644 --- a/test/unit/org/apache/cassandra/repair/RepairJobTest.java +++ b/test/unit/org/apache/cassandra/repair/RepairJobTest.java @@ -88,7 +88,6 @@ import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertFalse; import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_START_PREPARE_REQ; import static org.apache.cassandra.net.Verb.PAXOS2_CLEANUP_REQ; -import static org.junit.Assert.assertEquals; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; diff --git a/test/unit/org/apache/cassandra/repair/ValidationTaskTest.java b/test/unit/org/apache/cassandra/repair/ValidationTaskTest.java index 1af81f4ef6..1ea40e9617 100644 --- a/test/unit/org/apache/cassandra/repair/ValidationTaskTest.java +++ b/test/unit/org/apache/cassandra/repair/ValidationTaskTest.java @@ -24,7 +24,6 @@ import org.apache.cassandra.dht.Range; import org.apache.cassandra.locator.InetAddressAndPort; import org.apache.cassandra.streaming.PreviewKind; import org.apache.cassandra.utils.MerkleTrees; -import org.apache.cassandra.utils.TimeUUID; import org.junit.Test; diff --git a/test/unit/org/apache/cassandra/security/PEMBasedSslContextFactoryConfigTest.java b/test/unit/org/apache/cassandra/security/PEMBasedSslContextFactoryConfigTest.java index 49a3653946..ab6b00a982 100644 --- a/test/unit/org/apache/cassandra/security/PEMBasedSslContextFactoryConfigTest.java +++ b/test/unit/org/apache/cassandra/security/PEMBasedSslContextFactoryConfigTest.java @@ -27,7 +27,6 @@ import org.junit.Test; import org.apache.cassandra.config.Config; import org.apache.cassandra.config.DatabaseDescriptor; -import org.apache.cassandra.exceptions.ConfigurationException; public class PEMBasedSslContextFactoryConfigTest { diff --git a/test/unit/org/apache/cassandra/service/ActiveRepairServiceTest.java b/test/unit/org/apache/cassandra/service/ActiveRepairServiceTest.java index 70d40d89f8..9c1660a9c3 100644 --- a/test/unit/org/apache/cassandra/service/ActiveRepairServiceTest.java +++ b/test/unit/org/apache/cassandra/service/ActiveRepairServiceTest.java @@ -27,7 +27,6 @@ import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; -import java.util.UUID; import java.util.concurrent.CountDownLatch; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; @@ -66,7 +65,6 @@ import org.apache.cassandra.repair.messages.RepairOption; import org.apache.cassandra.schema.KeyspaceParams; import org.apache.cassandra.streaming.PreviewKind; import org.apache.cassandra.utils.FBUtilities; -import org.apache.cassandra.utils.concurrent.Condition; import org.apache.cassandra.utils.concurrent.Refs; import static org.apache.cassandra.repair.messages.RepairOption.DATACENTERS_KEY; diff --git a/test/unit/org/apache/cassandra/service/PartitionDenylistTest.java b/test/unit/org/apache/cassandra/service/PartitionDenylistTest.java index 13649d092c..ed51518719 100644 --- a/test/unit/org/apache/cassandra/service/PartitionDenylistTest.java +++ b/test/unit/org/apache/cassandra/service/PartitionDenylistTest.java @@ -31,7 +31,6 @@ import org.apache.cassandra.db.ConsistencyLevel; import org.apache.cassandra.exceptions.InvalidRequestException; import org.apache.cassandra.schema.KeyspaceMetadata; import org.apache.cassandra.schema.KeyspaceParams; -import org.apache.cassandra.schema.Schema; import org.apache.cassandra.schema.SchemaTestUtil; import org.apache.cassandra.schema.Tables; diff --git a/test/unit/org/apache/cassandra/service/PaxosStateTest.java b/test/unit/org/apache/cassandra/service/PaxosStateTest.java index f4fb8d027b..e73147d97e 100644 --- a/test/unit/org/apache/cassandra/service/PaxosStateTest.java +++ b/test/unit/org/apache/cassandra/service/PaxosStateTest.java @@ -23,7 +23,6 @@ import com.google.common.collect.Iterables; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.service.paxos.Ballot; -import org.apache.cassandra.service.paxos.BallotGenerator; import org.apache.cassandra.service.paxos.v1.PrepareVerbHandler; import org.apache.cassandra.service.paxos.v1.ProposeVerbHandler; diff --git a/test/unit/org/apache/cassandra/service/StartupChecksTest.java b/test/unit/org/apache/cassandra/service/StartupChecksTest.java index 4a63fc1eb2..72f8804ffe 100644 --- a/test/unit/org/apache/cassandra/service/StartupChecksTest.java +++ b/test/unit/org/apache/cassandra/service/StartupChecksTest.java @@ -36,13 +36,10 @@ import org.apache.cassandra.exceptions.StartupException; import org.apache.cassandra.service.DataResurrectionCheck.Heartbeat; import org.apache.cassandra.utils.Clock; -import static java.time.Instant.ofEpochMilli; import static java.util.Collections.singletonList; import static org.apache.cassandra.io.util.FileUtils.createTempFile; -import static org.apache.cassandra.io.util.FileUtils.write; import static org.apache.cassandra.service.DataResurrectionCheck.HEARTBEAT_FILE_CONFIG_PROPERTY; import static org.apache.cassandra.service.StartupChecks.StartupCheckType.check_data_resurrection; -import static org.apache.cassandra.utils.Clock.Global.currentTimeMillis; import static org.junit.Assert.assertNotEquals; import static org.junit.Assert.assertTrue; import static org.junit.Assert.fail; diff --git a/test/unit/org/apache/cassandra/service/paxos/PaxosStateTest.java b/test/unit/org/apache/cassandra/service/paxos/PaxosStateTest.java index fd6afba99f..23488fb2f0 100644 --- a/test/unit/org/apache/cassandra/service/paxos/PaxosStateTest.java +++ b/test/unit/org/apache/cassandra/service/paxos/PaxosStateTest.java @@ -32,7 +32,6 @@ import org.junit.Test; import org.apache.cassandra.SchemaLoader; import org.apache.cassandra.Util; -import org.apache.cassandra.config.Config; import org.apache.cassandra.db.*; import org.apache.cassandra.db.rows.Row; import org.apache.cassandra.db.partitions.PartitionUpdate; diff --git a/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTests.java b/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTests.java index c693d14df1..2804508e64 100644 --- a/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTests.java +++ b/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTests.java @@ -26,7 +26,6 @@ import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.db.*; import org.apache.cassandra.db.commitlog.CommitLog; import org.apache.cassandra.dht.*; -import org.apache.cassandra.schema.SchemaConstants; import org.apache.cassandra.schema.TableMetadata; import org.apache.cassandra.service.paxos.Ballot; import org.apache.cassandra.utils.ByteBufferUtil; diff --git a/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerIntegrationTest.java b/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerIntegrationTest.java index fdb524ef30..8c3dd250f5 100644 --- a/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerIntegrationTest.java +++ b/test/unit/org/apache/cassandra/service/paxos/uncommitted/PaxosUncommittedTrackerIntegrationTest.java @@ -26,7 +26,6 @@ import org.apache.cassandra.SchemaLoader; import org.apache.cassandra.Util; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.cql3.statements.schema.CreateTableStatement; -import org.apache.cassandra.db.ColumnFamilyStore; import org.apache.cassandra.db.DecoratedKey; import org.apache.cassandra.schema.KeyspaceParams; import org.apache.cassandra.schema.TableMetadata; diff --git a/test/unit/org/apache/cassandra/tools/StandaloneSplitterWithCQLTesterTest.java b/test/unit/org/apache/cassandra/tools/StandaloneSplitterWithCQLTesterTest.java index 14e1b93d6f..944b8dece7 100644 --- a/test/unit/org/apache/cassandra/tools/StandaloneSplitterWithCQLTesterTest.java +++ b/test/unit/org/apache/cassandra/tools/StandaloneSplitterWithCQLTesterTest.java @@ -18,7 +18,6 @@ package org.apache.cassandra.tools; -import java.io.IOException; import java.util.ArrayList; import java.util.Arrays; import java.util.List; @@ -26,7 +25,6 @@ import java.util.Set; import java.util.stream.Collectors; import org.junit.Before; -import com.google.common.io.Files; import org.apache.cassandra.io.util.File; import org.junit.Test; diff --git a/test/unit/org/apache/cassandra/tools/nodetool/CompactTest.java b/test/unit/org/apache/cassandra/tools/nodetool/CompactTest.java index f8fe6078d4..34059aa13c 100644 --- a/test/unit/org/apache/cassandra/tools/nodetool/CompactTest.java +++ b/test/unit/org/apache/cassandra/tools/nodetool/CompactTest.java @@ -26,7 +26,6 @@ import org.apache.cassandra.cql3.CQLTester; import org.apache.cassandra.db.ColumnFamilyStore; import org.apache.cassandra.db.Keyspace; import org.apache.cassandra.dht.Murmur3Partitioner; -import org.apache.cassandra.tools.ToolRunner; import org.assertj.core.api.Assertions; import static org.apache.cassandra.tools.ToolRunner.invokeNodetool; diff --git a/test/unit/org/apache/cassandra/tools/nodetool/CompactionStatsTest.java b/test/unit/org/apache/cassandra/tools/nodetool/CompactionStatsTest.java index 4ed1e000c5..b42a166038 100644 --- a/test/unit/org/apache/cassandra/tools/nodetool/CompactionStatsTest.java +++ b/test/unit/org/apache/cassandra/tools/nodetool/CompactionStatsTest.java @@ -19,7 +19,6 @@ package org.apache.cassandra.tools.nodetool; import java.util.List; -import java.util.UUID; import java.util.stream.Collectors; import java.util.stream.IntStream; diff --git a/test/unit/org/apache/cassandra/tools/nodetool/GetDefaultKeyspaceRFTest.java b/test/unit/org/apache/cassandra/tools/nodetool/GetDefaultKeyspaceRFTest.java index 9e93e1aeac..7db6f10ad2 100644 --- a/test/unit/org/apache/cassandra/tools/nodetool/GetDefaultKeyspaceRFTest.java +++ b/test/unit/org/apache/cassandra/tools/nodetool/GetDefaultKeyspaceRFTest.java @@ -24,7 +24,6 @@ import org.junit.Test; import org.apache.cassandra.config.DatabaseDescriptor; import org.apache.cassandra.cql3.CQLTester; import org.apache.cassandra.tools.ToolRunner; -import org.assertj.core.api.Assertions; import static org.assertj.core.api.Assertions.assertThat; diff --git a/test/unit/org/apache/cassandra/triggers/TriggerExecutorTest.java b/test/unit/org/apache/cassandra/triggers/TriggerExecutorTest.java index d0966fbe94..257d0c2436 100644 --- a/test/unit/org/apache/cassandra/triggers/TriggerExecutorTest.java +++ b/test/unit/org/apache/cassandra/triggers/TriggerExecutorTest.java @@ -34,7 +34,6 @@ import org.apache.cassandra.exceptions.ConfigurationException; import org.apache.cassandra.exceptions.InvalidRequestException; import org.apache.cassandra.schema.TriggerMetadata; import org.apache.cassandra.schema.Triggers; -import org.apache.cassandra.triggers.TriggerExecutorTest.SameKeySameCfTrigger; import org.apache.cassandra.utils.FBUtilities; import static org.apache.cassandra.utils.ByteBufferUtil.bytes; diff --git a/test/unit/org/apache/cassandra/utils/FBUtilitiesTest.java b/test/unit/org/apache/cassandra/utils/FBUtilitiesTest.java index 5294d81073..e0ee67cd58 100644 --- a/test/unit/org/apache/cassandra/utils/FBUtilitiesTest.java +++ b/test/unit/org/apache/cassandra/utils/FBUtilitiesTest.java @@ -46,7 +46,6 @@ import org.apache.cassandra.dht.*; import org.apache.cassandra.config.Config; import org.apache.cassandra.config.DatabaseDescriptor; -import org.assertj.core.api.Assertions; import static org.assertj.core.api.Assertions.assertThat; import static org.junit.Assert.assertEquals; diff --git a/test/unit/org/apache/cassandra/utils/KeyGenerator.java b/test/unit/org/apache/cassandra/utils/KeyGenerator.java index 9bbfb2cf8b..f1ff7e3ce8 100644 --- a/test/unit/org/apache/cassandra/utils/KeyGenerator.java +++ b/test/unit/org/apache/cassandra/utils/KeyGenerator.java @@ -21,7 +21,6 @@ package org.apache.cassandra.utils; import org.apache.cassandra.io.util.FileInputStreamPlus; import java.io.BufferedReader; -import java.io.FileNotFoundException; import java.io.IOException; import java.io.InputStreamReader; import java.nio.ByteBuffer; diff --git a/test/unit/org/apache/cassandra/utils/MergeIteratorTest.java b/test/unit/org/apache/cassandra/utils/MergeIteratorTest.java index fe2cecfc85..056a4a762e 100644 --- a/test/unit/org/apache/cassandra/utils/MergeIteratorTest.java +++ b/test/unit/org/apache/cassandra/utils/MergeIteratorTest.java @@ -21,7 +21,6 @@ package org.apache.cassandra.utils; import java.util.Arrays; import java.util.Iterator; -import org.apache.cassandra.utils.AbstractIterator; import com.google.common.collect.Iterators; import com.google.common.collect.Ordering; import org.junit.Before; diff --git a/test/unit/org/apache/cassandra/utils/concurrent/AbstractTestAsyncPromise.java b/test/unit/org/apache/cassandra/utils/concurrent/AbstractTestAsyncPromise.java index 51a07fbfa6..8420ba5aba 100644 --- a/test/unit/org/apache/cassandra/utils/concurrent/AbstractTestAsyncPromise.java +++ b/test/unit/org/apache/cassandra/utils/concurrent/AbstractTestAsyncPromise.java @@ -22,7 +22,6 @@ import java.util.ArrayList; import java.util.List; import java.util.concurrent.CancellationException; import java.util.concurrent.ExecutionException; -import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; import java.util.function.Consumer; import java.util.function.Function; diff --git a/test/unit/org/apache/cassandra/utils/memory/MemtableCleanerThreadTest.java b/test/unit/org/apache/cassandra/utils/memory/MemtableCleanerThreadTest.java index 31fc79d388..2ce9a8ed78 100644 --- a/test/unit/org/apache/cassandra/utils/memory/MemtableCleanerThreadTest.java +++ b/test/unit/org/apache/cassandra/utils/memory/MemtableCleanerThreadTest.java @@ -18,7 +18,6 @@ package org.apache.cassandra.utils.memory; -import java.util.concurrent.CompletableFuture; import java.util.concurrent.CountDownLatch; import java.util.concurrent.TimeUnit; import java.util.concurrent.atomic.AtomicBoolean; @@ -30,9 +29,6 @@ import org.junit.Test; import org.apache.cassandra.utils.FBUtilities; import org.apache.cassandra.utils.concurrent.AsyncPromise; -import org.apache.cassandra.utils.concurrent.Future; -import org.apache.cassandra.utils.concurrent.ImmediateFuture; -import org.apache.cassandra.utils.concurrent.SyncFuture; import org.mockito.Mock; import org.mockito.MockitoAnnotations;