[ 
https://issues.apache.org/jira/browse/SPARK-10754?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Hyukjin Kwon closed SPARK-10754.
--------------------------------
    Resolution: Cannot Reproduce

I can't reproduce this in the current master.

{code}
scala> val df = spark.range(10).toDF()
df: org.apache.spark.sql.DataFrame = [id: bigint]

scala> df.registerTempTable("sparktable")
warning: there was one deprecation warning; re-run with -deprecation for details

scala> spark.sql("select * from sparktable").show()
+---+
| id|
+---+
|  0|
|  1|
|  2|
|  3|
|  4|
|  5|
|  6|
|  7|
|  8|
|  9|
+---+


scala> spark.sql("select * from sparkTable").show()
+---+
| id|
+---+
|  0|
|  1|
|  2|
|  3|
|  4|
|  5|
|  6|
|  7|
|  8|
|  9|
+---+
{code}

> table and column name are case sensitive when json Dataframe was registered 
> as tempTable using JavaSparkContext. 
> -----------------------------------------------------------------------------------------------------------------
>
>                 Key: SPARK-10754
>                 URL: https://issues.apache.org/jira/browse/SPARK-10754
>             Project: Spark
>          Issue Type: Bug
>          Components: SQL
>    Affects Versions: 1.3.0, 1.3.1, 1.4.1
>         Environment: Linux ,Hadoop Version 1.3
>            Reporter: Babulal
>
> Create a dataframe using json data source 
>       SparkConf conf=new 
> SparkConf().setMaster("spark://xyz:7077")).setAppName("Spark Tabble");
>       JavaSparkContext javacontext=new JavaSparkContext(conf);
>       SQLContext sqlContext=new SQLContext(javacontext);
>       
>       DataFrame df = 
> sqlContext.jsonFile("/user/root/examples/src/main/resources/people.json");
>               
>       df.registerTempTable("sparktable");
>       
>       Run the Query
>       
>       sqlContext.sql("select * from sparktable").show()    // this will PASs
>       
>       
>       sqlContext.sql("select * from sparkTable").show()    /// This will FAIL 
>       
>       java.lang.RuntimeException: Table Not Found: sparkTable
>         at scala.sys.package$.error(package.scala:27)
>         at 
> org.apache.spark.sql.catalyst.analysis.SimpleCatalog$$anonfun$1.apply(Catalog.scala:115)
>         at 
> org.apache.spark.sql.catalyst.analysis.SimpleCatalog$$anonfun$1.apply(Catalog.scala:115)
>         at scala.collection.MapLike$class.getOrElse(MapLike.scala:128)
>         at scala.collection.AbstractMap.getOrElse(Map.scala:58)
>         at 
> org.apache.spark.sql.catalyst.analysis.SimpleCatalog.lookupRelation(Catalog.scala:115)
>         at 
> org.apache.spark.sql.catalyst.analysis.Analyzer$ResolveRelations$.getTable(Analyzer.scala:233)
>               
>               
>       



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to