Update NewHadoopRDD.scala

jeanlyn · Feb 20, 2015 · 6f41a1d · 6f41a1d
1 parent 0ce2c32
commit 6f41a1d
Showing 1 changed file with 5 additions and 2 deletions.
diff --git 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)
+-            }
+-         }
         }
       }
     }