I have created a table HCatalog table with partitions mapping to some zip files in S3.
In Zeppelin, I created a paragraph using the %pyspark module with the following codes:
Paragraph 1: %pyspark from pyspark.sql import HiveContext
hc = HiveContext( sc ) f_req_2h = hc.table( "default.f_req_2h" ) # a HCatalog table in the default schema" print f_req_sh.count() f_req_2h.registerTempTable("f_req_2h")
When I ran it, so far so good. Then I created a second paragraph to query the f_req_2h table, which was registered in paragraph 1, as follows:
Paragraph 2: %sql select * from f_req_2h limit 1;
I got an "table not found" error. Any help or pointer is appreciated.