Hello, I'm basically stuck as I have no idea where to look;
Following simple code, given that my Datasource is working gives me an
exception.
DataFrame df = sqlc.load(filename, "com.epam.parso.spark.ds.DefaultSource");
df.cache();
df.printSchema(); <-- prints the schema perfectly fine!
df.show(); <-- Works perfectly fine (shows table
with 20 lines)!
df.registerTempTable("table");
df.select("select * from table limit 5").show(); <-- gives weird exception
Exception is:
AnalysisException: cannot resolve 'select * from table limit 5' given
input columns VER, CREATED, SOC, SOCC, HLTC, HLGTC, STATUS
I can do a collect on a dataframe, but cannot select any specific columns
either "select * from table" or "select VER, CREATED from table".
I use spark 1.5.2.
The same code perfectly works through Zeppelin 0.5.5.
Thanks.
--
Be well!
Jean Morozov
