2015-10-13 81 views
1

我试图按照这里提供了答案:SparkR重新初始化工作不

Trying to find R equivalent for SetConf from Java

当我这样做,我加载SparkR:

sparkR 
....initialisation spam.... 
sparkR.stop() 
sc<-sparkR.init(sparkEnvir=....) 
sqlContext<-sparkRSQL.init(sc) 

我得到一个错误消息:

Error in callJMethod(x,'getClass'): 
    Invalid jobj 1. If SparkR was restarted, Spark operations need to be re-executed. 

当我不使用时出现同样的错误消息的论点,所以只是标准的停止和重新初始化似乎是有问题的。

回答

0

我想你有一个从停止的Spark会话加载的DataFrame。重新初始化Spark后,需要重新加载DataFrame。