You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@spark.apache.org by rx...@apache.org on 2017/01/13 07:14:10 UTC
spark git commit: Fix missing close-parens for In filter's toString
Repository: spark
Updated Branches:
refs/heads/master 6b34e745b -> b040cef2e
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 <an...@andrewash.com>
Closes #16558 from ash211/patch-9.
Project: http://git-wip-us.apache.org/repos/asf/spark/repo
Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/b040cef2
Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/b040cef2
Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/b040cef2
Branch: refs/heads/master
Commit: b040cef2ed0ed46c3dfb483a117200c9dac074ca
Parents: 6b34e74
Author: Andrew Ash <an...@andrewash.com>
Authored: Thu Jan 12 23:14:07 2017 -0800
Committer: Reynold Xin <rx...@databricks.com>
Committed: Thu Jan 12 23:14:07 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/b040cef2/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