hive - org.apache.spark.sql.TableNotFoundException when trying to create a table in Snappydata -
i trying create table spark shell (snappydata 0.9) this:
val snappy = new org.apache.spark.sql.snappysession(spark.sparkcontext) val vertextableschema = structtype(array(structfield("vertexid", | stringtype, false), structfield("custname", stringtype, false))) snappy.createtable(tablename = "vertextable", | provider = "column", // create snappydata column table | schema = vertextableschema, | options = map.empty[string, string], // map options. | allowexisting = true) and getting following error:
org.apache.spark.sql.tablenotfoundexception: table 'app.vertextable' not found; @ org.apache.spark.sql.hive.snappystorehivecatalog$$anonfun$3.apply(snappystorehivecatalog.scala:449) @ org.apache.spark.sql.hive.snappystorehivecatalog$$anonfun$3.apply(snappystorehivecatalog.scala:449) @ scala.collection.maplike$class.getorelse(maplike.scala:128) @ scala.collection.abstractmap.getorelse(map.scala:59) @ org.apache.spark.sql.hive.snappystorehivecatalog.lookuprelation(snappystorehivecatalog.scala:448) @ org.apache.spark.sql.smartconnectorhelper.createtable(smartconnectorhelper.scala:112) @ org.apache.spark.sql.snappysession.createtable(snappysession.scala:969) @ org.apache.spark.sql.snappysession.createtable(snappysession.scala:786) this spark-shell command:
spark-shell --master yarn --conf spark.snappydata.connection=locator.local:1527 --packages "snappydatainc:snappydata:0.9-s_2.11" i'm using spark 2.0.2 , code works fine in local mode fails on yarn.
wiki
Comments
Post a Comment