我遇到了以下错误:
py4j.protocol.Py4JJavaError: An error occurred while calling z:org.apache.spark.api.python.PythonRDD.collectAndServe.
在这一行:
result = df.select('student_age').rdd.flatMap(lambda x: x).collect()
“student_age” 是一个列名。它一直运行良好,直到上周出现了这个错误。
请问有人对此有任何见解吗?
data_percentage
和count_percentage
函数的代码吗? - Jonathan Lam