Description
Test steps:
1) bin/spark-shell
sc.parallelize(1 to 5, 5).collect() sc.parallelize(1 to 5, 2).map{ x => throw new RuntimeException("Fail Job")}.collect()
Output in spark - 2.3.1:
Output in spark - 2.2.1:
Test steps:
1) bin/spark-shell
sc.parallelize(1 to 5, 5).collect() sc.parallelize(1 to 5, 2).map{ x => throw new RuntimeException("Fail Job")}.collect()
Output in spark - 2.3.1:
Output in spark - 2.2.1: