java - 在线程"主要" org.apache.spark.SparkException 中,java异常: 在这个 JVM ( 请参见 SPARK 2243 ) 中,只有一个SparkContext可以运行

  显示原文与译文双语对照的内容
81 4

我在尝试使用cassandra运行spark应用程序时出现错误。

Exception in thread"main" org.apache.spark.SparkException: Only one SparkContext may be running in this JVM (see SPARK-2243). 

我使用spark版本 1.2.0,明确我在应用程序中只使用一个spark上下文。但是每当我尝试添加以下代码进行流化时,我都会。

JavaStreamingContext activitySummaryScheduler = new JavaStreamingContext(
 sparkConf, new Duration(1000));
时间:原作者:0个回答

131 0

你一次只能有一个 SparkContext,因为一个StreamingContext在它里面有一个 SparkContext,你不能在同一代码中有一个单独的流和火花上下文。你可以在你的SparkContext上建立一个 StreamingContext,这样你就可以在你真正需要的时候同时访问这两个。

使用这里构造函数JavaStreamingContext(sparkContext: JavaSparkContext, batchDuration: Duration)

原作者:
...