diff --git a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java index bd34b1f9f1..46f0acfe3d 100644 --- a/src/java/org/apache/cassandra/db/compaction/CompactionManager.java +++ b/src/java/org/apache/cassandra/db/compaction/CompactionManager.java @@ -844,6 +844,7 @@ public class CompactionManager implements CompactionManagerMBean * * @throws IOException */ + @SuppressWarnings("resource") private void doCleanupOne(final ColumnFamilyStore cfs, LifecycleTransaction txn, CleanupStrategy cleanupStrategy, Collection> ranges, boolean hasIndexes) throws IOException { assert !cfs.isIndex(); diff --git a/src/java/org/apache/cassandra/db/compaction/LeveledCompactionStrategy.java b/src/java/org/apache/cassandra/db/compaction/LeveledCompactionStrategy.java index bdc9141012..6daea36517 100644 --- a/src/java/org/apache/cassandra/db/compaction/LeveledCompactionStrategy.java +++ b/src/java/org/apache/cassandra/db/compaction/LeveledCompactionStrategy.java @@ -215,6 +215,7 @@ public class LeveledCompactionStrategy extends AbstractCompactionStrategy return maxSSTableSizeInMB * 1024L * 1024L; } + @SuppressWarnings("resource") public ScannerList getScanners(Collection sstables, Range range) { Set[] sstablesPerLevel = manifest.getSStablesPerLevelSnapshot(); diff --git a/src/java/org/apache/cassandra/tools/SSTableExport.java b/src/java/org/apache/cassandra/tools/SSTableExport.java index 58070e69ea..50d6611b10 100644 --- a/src/java/org/apache/cassandra/tools/SSTableExport.java +++ b/src/java/org/apache/cassandra/tools/SSTableExport.java @@ -312,8 +312,7 @@ public class SSTableExport excludeSet = new HashSet<>(Arrays.asList(excludes)); SSTableIdentityIterator row; - ISSTableScanner scanner = reader.getScanner(); - try + try (ISSTableScanner scanner = reader.getScanner()) { outs.println("["); @@ -340,10 +339,6 @@ public class SSTableExport outs.println("\n]"); outs.flush(); } - finally - { - scanner.close(); - } } /**