Fix review comments

apache · Jun 25, 2019 · f0f2f8d · f0f2f8d
1 parent 3f5f6b2
commit f0f2f8d
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/core/src/main/java/org/apache/spark/io/FileUtility.java b/core/src/main/java/org/apache/spark/io/FileUtility.java
@@ -92,7 +92,8 @@ public static void createTarFile(String source, String destFileName) throws Exce
                 tarOs.finish();
                 tarOs.close();
             } catch (IOException e) {
-                e.printStackTrace();
+                throw new IllegalStateException(String.format(
+                        "createTarFile failed with exception %s.", e.getMessage()));
             }
         }
     }

diff --git a/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala b/sql/core/src/main/scala/org/apache/spark/sql/execution/streaming/state/WALUtils.scala
@@ -89,7 +89,6 @@ object WALUtils {
       }
     }
     val storeFiles = versionToFiles.values.toSeq.sortBy(_.version)
-    // logDebug(s"Current set of files for $this: ${storeFiles.mkString(", ")}")
     storeFiles
   }
-Original file line number
+Diff line change
@@ Expand Up / @@ -89,7 +89,6 @@ object WALUtils { @@
           }
         }
         val storeFiles = versionToFiles.values.toSeq.sortBy(_.version)
-        // logDebug(s"Current set of files for $this: ${storeFiles.mkString(", ")}")
         storeFiles
       }
@@ Expand Down @@