资讯动态

PySpark transformWithState 报 AttributeError 的版本原因

发布时间:2026/10/24 4:35:46 来源:尧图企业网站定制
照着结构化流的新一代有状态算子写了一个自定义StatefulProcessor,在 Spark 4.0.3 上一跑就AttributeError,提示GroupedData没有transformWithState这个属性。这不是代码写错,是版本号差了一档。问题现象output_schema=T.StructType([T.StructField('customer_id',T.StringType())/

读完文章,也想定制专属网站?

尧图设计师 24 小时内与您沟通定制方案

免费获取报价 →
↑