嘿,
目前我使用Pyspark利用SparkListener跟蹤指標的火花工作。我似乎無法解決的問題就是為什麼在磚與removeSparkListener偵聽器不能刪除它仍是附著在上下文。
# Func - def注銷(spark_context: SparkContext *聽眾:SparkListener):偵聽器的聽眾:spark_context._jsc.sc () .removeSparkListener(聽眾)# spark_context._gateway.shutdown_callback_server() #單——sc._jsc.sc () .removeSparkListener(聽眾)# SC SparkContext