java.lang.AssertionError: assertion failed: No plan for CassandraRelation TableDef(yana_test,test1,ArrayBuffer(ColumnDef(customer_id,PartitionKeyColumn,IntType,false)),ArrayBuffer(ColumnDef(epoch,ClusteringColumn(0),BigIntType,false), ColumnDef(uri,ClusteringColumn(1),VarCharType,false)),ArrayBuffer(ColumnDef(browser,RegularColumn,VarCharType,false))), None, None

There are no available Samebug tips for this exception. Do you have an idea how to solve this issue? A short tip would help users who saw this issue last week.

  • I would like to be able to use a datafame which unions cassandra and non-cassandra data. Here is what I'm observing: I cannot populate the "affects version" field but I am using spark-cassandra-connector_2.10-1.4.0-M1.jar {code} CREATE TABLE test1( customer_id int , uri text , browser text, epoch bigint , PRIMARY KEY (customer_id , epoch,uri) ) insert into test1(customer_id,uri,browser,epoch) values (123242,'http://foobar','IE',1400820884) import org.apache.spark.sql.cassandra._ val cass=new CassandraSQLContext(sc) val cassDF = cass.sql("select * from yana_test.test1") case class Test(val epoch:Long,val uri:String,val browser:String,val customer_id:Int) val test1=Test(1400820884,"http://foobar","Firefox",123242) val df=sc.parallelize(Seq(test1)).toDF val unionDF= df.unionAll(cassDF) unionDF.show java.lang.AssertionError: assertion failed: No plan for CassandraRelation TableDef(yana_test,test1,ArrayBuffer(ColumnDef(customer_id,PartitionKeyColumn,IntType,false)),ArrayBuffer(ColumnDef(epoch,ClusteringColumn(0),BigIntType,false), ColumnDef(uri,ClusteringColumn(1),VarCharType,false)),ArrayBuffer(ColumnDef(browser,RegularColumn,VarCharType,false))), None, None at scala.Predef$.assert(Predef.scala:179) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$.apply(SparkStrategies.scala:300) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316) {code}
    via by Yana Kadiyska,
  • I would like to be able to use a datafame which unions cassandra and non-cassandra data. Here is what I'm observing: I cannot populate the "affects version" field but I am using spark-cassandra-connector_2.10-1.4.0-M1.jar {code} CREATE TABLE test1( customer_id int , uri text , browser text, epoch bigint , PRIMARY KEY (customer_id , epoch,uri) ) insert into test1(customer_id,uri,browser,epoch) values (123242,'http://foobar','IE',1400820884) import org.apache.spark.sql.cassandra._ val cass=new CassandraSQLContext(sc) val cassDF = cass.sql("select * from yana_test.test1") case class Test(val epoch:Long,val uri:String,val browser:String,val customer_id:Int) val test1=Test(1400820884,"http://foobar","Firefox",123242) val df=sc.parallelize(Seq(test1)).toDF val unionDF= df.unionAll(cassDF) unionDF.show java.lang.AssertionError: assertion failed: No plan for CassandraRelation TableDef(yana_test,test1,ArrayBuffer(ColumnDef(customer_id,PartitionKeyColumn,IntType,false)),ArrayBuffer(ColumnDef(epoch,ClusteringColumn(0),BigIntType,false), ColumnDef(uri,ClusteringColumn(1),VarCharType,false)),ArrayBuffer(ColumnDef(browser,RegularColumn,VarCharType,false))), None, None at scala.Predef$.assert(Predef.scala:179) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$.apply(SparkStrategies.scala:300) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316) {code}
    via by Yana Kadiyska,
  • Tests Failing.
    via GitHub by paulmagid
    ,
  • GitHub comment 72#74986726
    via GitHub by velvia
    ,
  • Cannot use coref
    via GitHub by schmmd
    ,
  • Can't profile UNION queries
    via GitHub by nawroth
    ,
    • java.lang.AssertionError: assertion failed: No plan for CassandraRelation TableDef(yana_test,test1,ArrayBuffer(ColumnDef(customer_id,PartitionKeyColumn,IntType,false)),ArrayBuffer(ColumnDef(epoch,ClusteringColumn(0),BigIntType,false), ColumnDef(uri,ClusteringColumn(1),VarCharType,false)),ArrayBuffer(ColumnDef(browser,RegularColumn,VarCharType,false))), None, None at scala.Predef$.assert(Predef.scala:179) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$.apply(SparkStrategies.scala:300) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58) at scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371) at org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59) at org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316) at org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316)

    Users with the same issue

    Unknown visitor1 times, last one,
    poroszd
    poroszd1 times, last one,
    Unknown visitor1 times, last one,
    Unknown visitor1 times, last one,
    Unknown visitor1 times, last one,
    19 more bugmates