I have an exception when I am trying to run a simple where clause query. I can see the name attribute is present in the schema but somehow it still throws the exception.
query = "select name from business where business_id=" + business_id what am I doing wrong ? thx srinivas Exception in thread "main" org.apache.spark.sql.catalyst.errors.package$TreeNodeException: Unresolved attributes: 'name, tree: Project ['name] Filter (business_id#1 = 'Ba1hXOqb3Yhix8bhE0k_WQ) Subquery business SparkLogicalPlan (ExistingRdd [attributes#0,business_id#1,categories#2,city#3,full_address#4,hours#5,latitude#6,longitude#7,name#8,neighborhoods#9,open#10,review_count#11,stars#12,state#13,type#14], MappedRDD[5] at map at JsonRDD.scala:38)
