Update NewHadoopRDD.scala

jeanlyn · Feb 20, 2015 · d453197 · d453197
1 parent 6f41a1d
commit d453197
Showing 1 changed file with 4 additions and 4 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
@@ -175,10 +175,10 @@ class NewHadoopRDD[K, V](
           }
         } catch {
           case e: Exception => {
--            if (!Utils.inShutdown()) {
--              logWarning("Exception in RecordReader.close()", e)
--            }
--         }
+            if (!Utils.inShutdown()) {
+              logWarning("Exception in RecordReader.close()", e)
+            }
+          }
         }
       }
     }