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 | 1 year ago
  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 | 1 year 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 | 1 year 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

    Cannot use coref

    GitHub | 3 years ago | schmmd
    java.lang.AssertionError: assertion failed: Could not find annotator for goal class cc.factorie.app.nlp.phrase.NounPhraseList, map includes class cc.factorie.app.nlp.phrase.NumberLabel, class cc.factorie.app.nlp.ner.NerTag, class cc.factorie.app.nlp.lemma.SimplifyDigitsTokenLemma, class cc.factorie.app.nlp.coref.mention.ParseBasedMentionList, class cc.factorie.app.nlp.pos.PennPosTag, class cc.factorie.app.nlp.segment.PlainNormalizedTokenString, class cc.factorie.app.nlp.Token, class cc.factorie.app.nlp.ner.BilouConllNerTag, class cc.factorie.app.nlp.coref.mention.MentionEntityType, class cc.factorie.util.coref.GenericEntityMap, class cc.factorie.app.nlp.lemma.CollapseDigitsTokenLemma, class cc.factorie.app.nlp.ner.BilouOntonotesNerTag, class cc.factorie.app.nlp.phrase.GenderLabel, class cc.factorie.app.nlp.lemma.WordNetTokenLemma, class cc.factorie.app.nlp.parse.ParseTree, class cc.factorie.app.nlp.Sentence, class cc.factorie.app.nlp.lemma.PorterTokenLemma, class cc.factorie.app.nlp.coref.mention.NerMentionList, class cc.factorie.app.nlp.lemma.LowercaseTokenLemma
  4. Speed up your debug routine!

    Automated exception search integrated into your IDE

  5. 0

    Error when running profile with Cypher query

    GitHub | 3 years ago | peterneubauer
    java.lang.AssertionError: assertion failed: Can't profile the same pipe twice: NullPipe(SymbolTable(Map(a -> Node, b -> Node)),Eager() Filter(pred="Property(b,name(0)) == Literal(Central)") NodeByLabel(label="Division", identifier="b") Filter(pred="Property(a,name(0)) == Literal(East)") NodeByLabel(label="Conference", identifier="a"))
  6. 0

    Can't profile UNION queries

    GitHub | 3 years ago | nawroth
    java.lang.AssertionError: assertion failed: Can't profile the same pipe twice
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