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

Popular posts from this blog

elasticsearch - what is the equivalent data type for geo_point in hibernate search? -

firebase - How to wait value in Ionic 2 -

Jenkins: find build number for git commit -