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

DataStax JIRA | Yana Kadiyska | 2 years ago
tip
Do you find the tips below useful? Click on the to mark them and say thanks to poroszd . Or join the community to write better ones.
  1. 0

    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}

    DataStax JIRA | 2 years ago | Yana Kadiyska
    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
  2. 0

    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}

    DataStax JIRA | 2 years ago | Yana Kadiyska
    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
  3. 0
    samebug tip
    Check if you use the right path
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Can't deploy jobserver in localhost

    GitHub | 2 years ago | prayagupd
    java.lang.AssertionError: assertion failed: timeout (3 seconds) during expectMsgClass waiting for class spark.jobserver.CommonMessages$JobErroredOut
  6. 0

    Tests Failing.

    GitHub | 3 years ago | paulmagid
    java.lang.AssertionError: assertion failed: timeout (3 seconds) while expecting 2 messages
Not finding the right solution?
Take a tour to get the most out of Samebug.

Tired of useless tips?

Automated exception search integrated into your IDE

Root Cause Analysis

  1. 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()
  2. Scala
    Predef$.assert
    1. scala.Predef$.assert(Predef.scala:179)
    1 frame
  3. Spark Project Catalyst
    QueryPlanner.planLater
    1. org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59)
    2. org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54)
    2 frames
  4. Spark Project SQL
    SparkStrategies$BasicOperators$.apply
    1. org.apache.spark.sql.execution.SparkStrategies$BasicOperators$.apply(SparkStrategies.scala:300)
    1 frame
  5. Spark Project Catalyst
    QueryPlanner$$anonfun$1.apply
    1. org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58)
    2. org.apache.spark.sql.catalyst.planning.QueryPlanner$$anonfun$1.apply(QueryPlanner.scala:58)
    2 frames
  6. Scala
    Iterator$$anon$13.hasNext
    1. scala.collection.Iterator$$anon$13.hasNext(Iterator.scala:371)
    1 frame
  7. Spark Project Catalyst
    QueryPlanner.planLater
    1. org.apache.spark.sql.catalyst.planning.QueryPlanner.plan(QueryPlanner.scala:59)
    2. org.apache.spark.sql.catalyst.planning.QueryPlanner.planLater(QueryPlanner.scala:54)
    2 frames
  8. Spark Project SQL
    SparkStrategies$BasicOperators$$anonfun$19.apply
    1. org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316)
    2. org.apache.spark.sql.execution.SparkStrategies$BasicOperators$$anonfun$19.apply(SparkStrategies.scala:316)
    2 frames