You need to enable JavaScript to run this app.
优惠活动
大模型
产品
解决方案
定价
更多

Databricks Notebook发送Spark DataFrame至EventHub时遇NoSuchMethodError错误

Databricks中PySpark DataFrame写入Azure EventHub报错求助

我在Databricks Notebook里尝试把PySpark DataFrame发送到Azure EventHub,执行以下代码时出现问题:

ehWriteConf = {
  'eventhubs.connectionString' : EVENT_HUB_CONNECTION_STRING
}

def send_to_eventhub(df:DataFrame):
    ds = df.select(struct(*[c for c in df.columns]).alias("body"))\
      .select("body")\
      .write.format("eventhubs")\
      .options(**ehWriteConf)\
      .save()

处理完DataFrame后调用该方法:

# 将feature_df写入EventHub
send_to_eventhub(feature_df)

之前查到类似问题是版本兼容导致的,我已经尝试安装了兼容版本的库com.microsoft.azure:azure-eventhubs-spark_2.12:2.3.22,但还是抛出java.lang.NoSuchMethodError错误,错误栈显示缺失org.apache.spark.sql.AnalysisException的特定构造方法,目前不清楚具体原因。集群配置详情见截图。

内容的提问来源于stack exchange,提问作者Pedro Silva

相关产品推荐
方舟 Agent Plan

超全模态模型 × Harness 升级,最新支持 Deepseek-V4.1-Flash、GLM-5.3 系列、Doubao-Seedream-5.0-pro、Kimi-K3 (部分), 限时 9.9 元起

最近更新时间:2026.08.17 11:01:06