fix indent

Author: jose-torres

sql/core/src/test/scala/org/apache/spark/sql/streaming/StreamTest.scala

@@ -633,18 +633,18 @@ trait StreamTest extends QueryTest with SharedSQLContext with TimeLimits with Be
               // Try to find the index of the source to which data was added. Either get the index
               // from the current active query or the original input logical plan.
               val sourceIndex =
-              queryToUse.flatMap { query =>
-                findSourceIndex(query.logicalPlan)
-              }.orElse {
-                findSourceIndex(stream.logicalPlan)
-              }.orElse {
-                queryToUse.flatMap { q =>
-                  findSourceIndex(q.lastExecution.logical)
+                queryToUse.flatMap { query =>
+                  findSourceIndex(query.logicalPlan)
+                }.orElse {
+                  findSourceIndex(stream.logicalPlan)
+                }.orElse {
+                  queryToUse.flatMap { q =>
+                    findSourceIndex(q.lastExecution.logical)
+                  }
+                }.getOrElse {
+                  throw new IllegalArgumentException(
+                    "Could not find index of the source to which data was added")
                 }
-              }.getOrElse {
-                throw new IllegalArgumentException(
-                  "Could not find index of the source to which data was added")
-              }
 
               // Store the expected offset of added data to wait for it later
               awaiting.put(sourceIndex, offset)