Details
-
Bug
-
Status: Resolved
-
Major
-
Resolution: Fixed
-
None
-
None
-
None
Description
It's because we store stageId_attemptNum in JobMetricsListener but expect only stageId in LocalSparkJobStatus.
java.lang.NumberFormatException: For input string: "0_0" at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65) at java.lang.Integer.parseInt(Integer.java:580) at java.lang.Integer.parseInt(Integer.java:615) at org.apache.hadoop.hive.ql.exec.spark.status.impl.LocalSparkJobStatus.getSparkStatistics(LocalSparkJobStatus.java:146) at org.apache.hadoop.hive.ql.exec.spark.SparkTask.execute(SparkTask.java:104) at org.apache.hadoop.hive.ql.exec.Task.executeTask(Task.java:199)