hi,all:
        I try to write a dataframe to phoenix with spark2.1:
            
df.write.format("org.apache.phoenix.spark").mode(SaveMode.Overwrite).options(Map("table"
 -> "biz","zkUrl" -> "slave1:2181,slave2:2181")).save()
        but it's not work,I got error:
        java.lang.AbstractMethodError: 
org.apache.phoenix.spark.DefaultSource.createRelation(Lorg/apache/spark/sql/SQLContext;Lorg/apache/spark/sql/SaveMode;Lscala/collection/immutable/Map;Lorg/apache/spark/sql/Dataset;)Lorg/apache/spark/sql/sources/BaseRelation;
  at 
org.apache.spark.sql.execution.datasources.DataSource.write(DataSource.scala:426)
  at org.apache.spark.sql.DataFrameWriter.save(DataFrameWriter.scala:215)
  ... 60 elided

2017-01-11


lk_phoenix 

Reply via email to