diff --git a/core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala b/core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala index 45878849ed5fe..34cf780d57fa0 100644 --- a/core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala +++ b/core/src/main/scala/org/apache/spark/rdd/NewHadoopRDD.scala @@ -174,8 +174,11 @@ class NewHadoopRDD[K, V]( } } } catch { - case e: Exception => - logWarning("Exception in RecordReader.close()", e) + case e: Exception => { +- if (!Utils.inShutdown()) { +- logWarning("Exception in RecordReader.close()", e) +- } +- } } } }