1.【报错】AttributeError: ‘SparkContext’ object has no attribute ‘setcheckpointDir’
本人传参:
conf = SparkConf().setAppName("test").setMaster("local[*]")
sc = SparkContext(conf=conf)
# 1.告知spark,开启CheckPoint功能
sc.setcheckpointDir("hdfs://node1:8020/output/ckp")
分析:SparkContext找不到setcheckpointDir方法,参数传参错误
解决:将setcheckpointDir改成setCheckpointDir,其中c字母大写。是因为两个方法的传参不同导致文章来源:https://www.toymoban.com/news/detail-821795.html
updateTime:2024-01-23文章来源地址https://www.toymoban.com/news/detail-821795.html
到了这里,关于学习Spark遇到的问题的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!