diff --git a/core/src/main/scala/org/apache/spark/sql/rapids/tool/ToolUtils.scala b/core/src/main/scala/org/apache/spark/sql/rapids/tool/ToolUtils.scala index 7aaf51456..0bddd520a 100644 --- a/core/src/main/scala/org/apache/spark/sql/rapids/tool/ToolUtils.scala +++ b/core/src/main/scala/org/apache/spark/sql/rapids/tool/ToolUtils.scala @@ -80,14 +80,14 @@ object ToolUtils extends Logging { val targetEx = i.getTargetException if (targetEx != null) { targetEx match { - case k: com.fasterxml.jackson.core.io.JsonEOFException => + case j: com.fasterxml.jackson.core.io.JsonEOFException => // Spark3.41+ embeds JsonEOFException in the InvocationTargetException // We need to show a warning message instead of failing the entire app. - logWarning(s"Incomplete eventlog, ${k.getMessage}") - case j: com.fasterxml.jackson.core.JsonParseException => + logWarning(s"Incomplete eventlog, ${j.getMessage}") + case k: com.fasterxml.jackson.core.JsonParseException => // this is a parser error thrown by spark-3.4+ which indicates the log is // malformed - throw j + throw k case z: ClassNotFoundException if z.getMessage != null => logWarning(s"ClassNotFoundException while parsing an event: ${z.getMessage}") case t: Throwable =>