python—当我试图通过pyspark从sql写入kudu时,如何处理这个错误

imzjd6km  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(454)

我想把一个巨大的表从sql写到kudu表,但我不能把它写到kudu表。
代码如下:

kuduDF.write.format('org.apache.kudu.spark.kudu')
              .option('kudu.master',kudu_master)
              .option('kudu.table',"impala::"+kudu_database_name+"."+kudu_table_name).mode('append')
              .option("kudu.operation", operation_type)
              .save()

但我得到以下错误:
调用o202.save时出错:java.lang.abstractmethoderror:org.apache.kudu.spark.kudu.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;

axkjgtzd

axkjgtzd1#

你能试试这个jar kudu-spark2-tools_2.11.jar吗。你用哪个jar做的

相关问题