线程“主”org.apache.spark.SparkException中的异常:此JVM中只能运行一个SparkContext(请参阅SPARK-2243)

线程“主”org.apache.spark.SparkException中的异常:此JVM中只能运行一个SparkContext(请参阅SPARK-2243),第1张

线程“主”org.apache.spark.SparkException中的异常:此JVM中只能运行一个SparkContext(请参阅SPARK-2243)

您一次只能拥有一个SparkContext,并且由于StreamingContext中包含一个SparkContext,因此在同一代码中不能有单独的Streaming和Spark
Context。您可以做的是在SparkContext的基础上构建一个StreamingContext,这样,如果您确实需要,就可以访问两者。

使用此构造函数

JavaStreamingContext(sparkContext: JavaSparkContext, batchDuration:Duration)



欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/zaji/5462080.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2022-12-11
下一篇 2022-12-12

发表评论

登录后才能评论

评论列表(0条)

保存