Repository: spark
Updated Branches:
  refs/heads/branch-2.1 23944d0d6 -> 0668e061b


Fix missing close-parens for In filter's toString

Otherwise the open parentheses isn't closed in query plan descriptions of batch 
scans.

    PushedFilters: [In(COL_A, [1,2,4,6,10,16,219,815], IsNotNull(COL_B), ...

Author: Andrew Ash <and...@andrewash.com>

Closes #16558 from ash211/patch-9.

(cherry picked from commit b040cef2ed0ed46c3dfb483a117200c9dac074ca)
Signed-off-by: Reynold Xin <r...@databricks.com>


Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/0668e061
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/0668e061
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/0668e061

Branch: refs/heads/branch-2.1
Commit: 0668e061beba683d026a2d48011ff74faf8a38ab
Parents: 23944d0
Author: Andrew Ash <and...@andrewash.com>
Authored: Thu Jan 12 23:14:07 2017 -0800
Committer: Reynold Xin <r...@databricks.com>
Committed: Thu Jan 12 23:14:15 2017 -0800

----------------------------------------------------------------------
 sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/spark/blob/0668e061/sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala
----------------------------------------------------------------------
diff --git a/sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala 
b/sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala
index e0494df..2499e9b 100644
--- a/sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala
+++ b/sql/core/src/main/scala/org/apache/spark/sql/sources/filters.scala
@@ -130,7 +130,7 @@ case class In(attribute: String, values: Array[Any]) 
extends Filter {
     case _ => false
   }
   override def toString: String = {
-    s"In($attribute, [${values.mkString(",")}]"
+    s"In($attribute, [${values.mkString(",")}])"
   }
 
   override def references: Array[String] = Array(attribute) ++ 
values.flatMap(findReferences)


---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org
For additional commands, e-mail: commits-h...@spark.apache.org

Reply via email to