You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@phoenix.apache.org by sa...@apache.org on 2015/04/24 22:38:23 UTC
phoenix git commit: PHOENIX-1916 Spark tests are failing (Josh
Mahonin)
Repository: phoenix
Updated Branches:
refs/heads/master 20e772caf -> e35662052
PHOENIX-1916 Spark tests are failing (Josh Mahonin)
Project: http://git-wip-us.apache.org/repos/asf/phoenix/repo
Commit: http://git-wip-us.apache.org/repos/asf/phoenix/commit/e3566205
Tree: http://git-wip-us.apache.org/repos/asf/phoenix/tree/e3566205
Diff: http://git-wip-us.apache.org/repos/asf/phoenix/diff/e3566205
Branch: refs/heads/master
Commit: e35662052ff7cafed7ae74904332654bd050cb6e
Parents: 20e772c
Author: Samarth <sa...@salesforce.com>
Authored: Fri Apr 24 13:38:19 2015 -0700
Committer: Samarth <sa...@salesforce.com>
Committed: Fri Apr 24 13:38:19 2015 -0700
----------------------------------------------------------------------
.../src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/phoenix/blob/e3566205/phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala
----------------------------------------------------------------------
diff --git a/phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala b/phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala
index 9a359e3..773026d 100644
--- a/phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala
+++ b/phoenix-spark/src/main/scala/org/apache/phoenix/spark/PhoenixRDD.scala
@@ -85,7 +85,7 @@ class PhoenixRDD(sc: SparkContext, table: String, columns: Seq[String],
if(!columns.isEmpty) {
PhoenixConfigurationUtil.setSelectColumnNames(config, columns.mkString(","))
}
- PhoenixConfigurationUtil.setInputTableName(config, "\"" + table + "\"")
+ PhoenixConfigurationUtil.setInputTableName(config, table)
PhoenixConfigurationUtil.setInputClass(config, classOf[PhoenixRecordWritable])
// Override the Zookeeper URL if present. Throw exception if no address given.