Code scan fixes (apache#9)

Author: jsukuma

src/java/org/apache/cassandra/db/memtable/PersistentMemoryMemtable.java

@@ -400,7 +400,6 @@ public long partitionKeysSize()
 
     public boolean shouldSwitch(ColumnFamilyStore.FlushReason reason)
     {
-        System.out.println("Reason : "+ reason);
         // We want to avoid all flushing.
         switch (reason)
         {
@@ -483,21 +482,19 @@ public void performSnapshot(String snapshotName)
         Path src = Paths.get(System.getProperty("pmem_path") + "/" + tableMetaId);
         String dest = DatabaseDescriptor.getRawConfig().data_file_directories[0] + "/" + metadata.keyspace + "/" + metadata.name + "-" + tableMetaId + "/snapshots/" + snapshotName;
 
-        try
-        {
+        try {
             Files.createDirectories(Paths.get(dest));
-            Files.walk(src)
-                 .forEach(source -> {
-                     try
-                     {
-                         Files.copy(source, Paths.get(dest).resolve(src.relativize(source)),
-                                    java.nio.file.StandardCopyOption.REPLACE_EXISTING);
-                     }
-                     catch (IOException e)
-                     {
-                         throw new IOError(e);
-                     }
-                 });
+            try (Stream<Path> pathStream = Files.walk(src)) {
+                pathStream
+                        .forEach(source -> {
+                            try {
+                                Files.copy(source, Paths.get(dest).resolve(src.relativize(source)),
+                                        java.nio.file.StandardCopyOption.REPLACE_EXISTING);
+                            } catch (IOException e) {
+                                throw new IOError(e);
+                            }
+                        });
+            }
         }
         catch (Exception e)
         {
@@ -507,6 +504,7 @@ public void performSnapshot(String snapshotName)
         {
             writeLock.compareAndSet(true, false);
         }
+
     }
 
     @Override

src/java/org/apache/cassandra/db/memtable/pmem/MemtableImporter.java

@@ -56,10 +56,8 @@ private List<String> restoreSnapshotData(Set<String> srcPath, String dest)
         List<String> failedSnapshotTasks = new ArrayList<String>();
         for (String src : srcPath)
         {
-            try
-            {
-                Stream<Path> walk = Files.walk(Paths.get(src));
-                walk
+            try (Stream<Path> pathStream = Files.walk(Paths.get(src))) {
+                pathStream
                 .filter(p -> !Files.isDirectory(p) && (p.toString().endsWith(".pmem") || p.toString().endsWith(".set")  ))
                 .forEach(f -> {
                     try {