Hi there,
i was following Zeppelin tutorial and code following snippet:
%sql
select * from test_table
I got error:
org.apache.spark.sql.AnalysisException: no such table test_table; line 1
pos 14
test_table was created and registered (succesfully) one snippet above:
val df = sqlContext.load("com.databricks.spark.csv", Map("path" ->
"test_1000.csv","header"->"true"))
df.registerTempTable("test_table")
Any idea where is the problem?
The tutorial describes similar procedure but with sc.parallelize instead of
sqlContext.load.
thanks, Tomas
btw when I create scala request (e.g. df.select("FlightDate").show())
within the same snippet as the table was created - it is working.
