diff --git a/core/src/main/java/org/apache/spark/io/FileUtility.java b/core/src/main/java/org/apache/spark/io/FileUtility.java index e91882222317b..4fc6765e20e31 100644 --- 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 index b4813f7eb58b0..771ade3e2a40e 100644 --- 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 }