Fix indentation

xiliu82 · Dec 19, 2013 · 4d7ef2e · 4d7ef2e
1 parent f1d73e3
commit 4d7ef2e
Showing 1 changed file with 11 additions and 11 deletions.
diff --git a/core/src/main/scala/org/apache/spark/api/python/SerDeUtil.scala b/core/src/main/scala/org/apache/spark/api/python/SerDeUtil.scala
@@ -43,27 +43,27 @@ private[python] object SerDeUtil extends Logging {
       val mp = new ScalaMessagePack
       var triedReg = false
       pairs.map{ pair =>
-      Try {
-        if (!triedReg) {
-          register(pair._1.getClass, mp)
-          register(pair._2.getClass, mp)
-          triedReg = true
-        }
-        mp.write(pair)
-      } match {
-        case Failure(err) =>
+        Try {
+          if (!triedReg) {
+            register(pair._1.getClass, mp)
+            register(pair._2.getClass, mp)
+            triedReg = true
+          }
+          mp.write(pair)
+        } match {
+          case Failure(err) =>
             log.debug("Failed to write", err)
             Try {
               write((pair._1.toString, pair._2.toString))
             } match {
               case Success(result) => result
               case Failure(e) => throw e
             }
-        case Success(result) => result
+          case Success(result) => result
+        }
       }
     }
   }
-  }
 
   /**
    * Converts an RDD of (K, V) pairs, where K and/or V could be instances of [[org.apache.hadoop.io.Writable]],