You used one Spark version to compile your codes but another newer version to run. As the Source APIs are not stable, Spark doesn't guarantee that they are binary compatibility.
On Tue, Jan 31, 2017 at 1:39 PM, Sam Elamin <hussam.ela...@gmail.com> wrote: > Hi Folks > > > I am getting a weird error when trying to write a BigQuery Structured > Streaming source > > > Error: > java.lang.AbstractMethodError: com.samelamin.spark.bigquery. > streaming.BigQuerySource.commit(Lorg/apache/spark/sql/ > execution/streaming/Offset;)V > at org.apache.spark.sql.execution.streaming. > StreamExecution$$anonfun$org$apache$spark$sql$execution$ > streaming$StreamExecution$$constructNextBatch$1$$anonfun$ > apply$mcV$sp$5.apply(StreamExecution.scala:359) > at org.apache.spark.sql.execution.streaming. > StreamExecution$$anonfun$org$apache$spark$sql$execution$ > streaming$StreamExecution$$constructNextBatch$1$$anonfun$ > apply$mcV$sp$5.apply(StreamExecution.scala:358) > > > FYI if you are interested in Spark and BigQuery feel free to give my > connector a go! Still trying to get structured streaming to it as a source > hence this email. but you can use it as a sink! > > > Regards > Sam > > > >
