[SPARK-3650][GraphX] There will be an ArrayIndexOutOfBoundsException …

…if the format of the source file is wrong There will be an ArrayIndexOutOfBoundsException if the format of the source file is wrong
apache · Jan 23, 2015 · 23767f1 · 23767f1
1 parent ea74365
commit 23767f1
Showing 1 changed file with 7 additions and 6 deletions.
diff --git a/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala b/graphx/src/main/scala/org/apache/spark/graphx/GraphLoader.scala
@@ -78,13 +78,14 @@ object GraphLoader extends Logging {
           val lineArray = line.split("\\s+")
           if (lineArray.length < 2) {
             logWarning("Invalid line: " + line)
-          }
-          val srcId = lineArray(0).toLong
-          val dstId = lineArray(1).toLong
-          if (canonicalOrientation && srcId > dstId) {
-            builder.add(dstId, srcId, 1)
           } else {
-            builder.add(srcId, dstId, 1)
+            val srcId = lineArray(0).toLong
+            val dstId = lineArray(1).toLong
+            if (canonicalOrientation && srcId > dstId) {
+              builder.add(dstId, srcId, 1)
+            } else {
+              builder.add(srcId, dstId, 1)
+            }
           }
         }
       }