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卡桑德拉火花錯誤

回答

相關問題