单个JVM中有多个SparkSession
我有一个关于在一个JVM中创建多个Spark会话的查询。我已经读过,在早期版本的Spark中不建议创建多个上下文。Spark 2.0中的SparkSession也是如此。
我正在考虑从UI调用Web服务或servlet,然后该服务创建一个spark会话,执行一些操作并返回结果。这将导致为客户端的每个请求创建一个火花会话。是否推荐这种做法?
说我有一个类似的方法:
public void runSpark()引发异常{ SparkSession spark = SparkSession
.builder()
.master("spark://<masterURL>")
.appName("JavaWordCount")
.getOrCreate();
等等....
如果将这种方法放在Web服务中,会不会有JVM问题?因此,我可以从main方法多次调用此方法,但不确定这是否是一种好习惯。
回答:
不支持,也不会。SPARK-2243解决为“无法修复”。
如果您需要多个上下文,那么可以使用不同的项目来帮助您(Mist,Livy)。
以上是 单个JVM中有多个SparkSession 的全部内容, 来源链接: utcz.com/qa/421856.html