spark-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From r...@apache.org
Subject spark git commit: Fix missing close-parens for In filter's toString
Date Fri, 13 Jan 2017 07:14:18 GMT
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 <andrew@andrewash.com>

Closes #16558 from ash211/patch-9.

(cherry picked from commit b040cef2ed0ed46c3dfb483a117200c9dac074ca)
Signed-off-by: Reynold Xin <rxin@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 <andrew@andrewash.com>
Authored: Thu Jan 12 23:14:07 2017 -0800
Committer: Reynold Xin <rxin@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-unsubscribe@spark.apache.org
For additional commands, e-mail: commits-help@spark.apache.org


Mime
View raw message