DSE卡桑德拉火花错误

我花了整整一天的时间试图找出解决方法，但没有运气。DSE卡桑德拉火花错误

我的每一个Java应用程序试图连接到我的DSE星火主时，它抛出一个错误：

Association with remote system [akka.tcp://[email protected]:7077] has failed, address is now gated for [5000] ms. Reason is: [Disassociated].

泰陵卡桑德拉日志，我可以看到在类版本的不相容性：

ERROR [sparkMaster-akka.actor.default-dispatcher-2] 2015-06-09 16:39:12,066 
Slf4jLogger.scala:66 - org.apache.spark.deploy.ApplicationDescription; local 
class incompatible: stream classdesc serialVersionUID = 7674242335164700840, 
local 
class serialVersionUID = 2812534333379744973 
java.io.InvalidClassException: 
org.apache.spark.deploy.ApplicationDescription; local class incompatible: 
stream classdesc serialVersionUID = 7674242335164700840, local class 
serialVersionUID = 2812534333379744973

任何想法为什么会发生这种情况？

这是一个版本不匹配，但这不清楚如何解决它。

正在运行DSE 4.7和我的POM文件是象下面这样：

<dependency> 
    <groupId>org.apache.spark</groupId> 
    <artifactId>spark-core_2.10</artifactId> 
    <version>1.2.1</version> 
</dependency> 
<dependency> 
    <groupId>org.apache.spark</groupId> 
    <artifactId>spark-sql_2.10</artifactId> 
    <version>1.2.1</version> 
</dependency> 
<dependency> 
    <groupId>com.datastax.spark</groupId> 
    <artifactId>spark-cassandra-connector-java_2.10</artifactId> 
    <version>1.2.1</version> 
</dependency> 

<dependency> 
    <groupId>com.datastax</groupId> 
    <artifactId>dse</artifactId> 
    <version>version number</version> 
    <scope>system</scope> 
    <systemPath>${project.basedir}/lib/dse-4.7.0.jar</systemPath> 
</dependency>

问题是卡桑德拉连接器的版本的DSE 4.7的作品？

来源

2015-06-09 Adetiloye Philip Kehinde

你不知道有两个版本的火花瓶？ – phact

版本不匹配+1 – RussS

@RussS：我更新了我的问题。 –

存在版本不匹配。 DSE 4.7随Spark 1.2.1一起发布，但您正在根据1.1.1构建您的jar。

来源

2015-06-09 22:01:09 RussS

对，但还是吹起来！我在我的POM文件中尝试了不同的版本，但都没有成功。我确信DSE 4.7在这里打破了很多东西。 –

火花外壳是否工作？ 'dse spark' – phact

即使在运行1.2.1内建的驱动程序时，也会出现同样的异常，对4.7 DSE？ – RussS

DSE卡桑德拉火花错误

回答

相关问题