spark-cassandra-connector

2熱度

1回答

運行火花和卡桑德拉我同時使用火花卡桑德拉連接器收到以下錯誤： ERROR executor.Executor: Exception in task 0.0 in stage 10.0 (TID 207) java.lang.NoSuchMethodError: org.apache.spark.executor.TaskMetrics.inputMetrics_$eq(Lscala/Option

1熱度

1回答

使用spark-cassandra-connector-java api並在嘗試提交Spark任務時出錯

所以我試圖獲得一個使用Java和spark cassandra連接器的簡單示例程序。運行sbt程序集工作正常，我得到一個我提交的火花的胖罐子。問題就來了這裏，當我提交作業引發我得到這個錯誤： [email protected]:~$ source submit-job.sh Exception in thread "main" java.lang.NoClassDefFoundError: co

0熱度

1回答

Dataframe沒有保存到Cassandra中

我有一個應用程序Spark (version 1.4.0)和Spark-Cassandra-connector (version 1.3.0-M1)。其中，我試圖將一個數據框存儲到具有兩列（總計，消息）的Cassandra表中。我已經用這兩列創建了Cassandra表。這裏是我的代碼， scoredTweet.foreachRDD(new Function2<JavaRDD<Message>,T

0熱度

1回答

運行通過Spark SQL通過Spark SQL查詢Cassandra的作業時發生錯誤

因此，我試圖運行只使用spark-sql對cassandra運行查詢的作業，作業提交正常，作業開始正常。此代碼在不通過spark jobserver運行時（僅使用spark提交）。有人能告訴我什麼是我的工作代碼或配置文件錯誤導致下面的錯誤？ { "status": "ERROR", "ERROR": { "errorClass": "java.util.concurr

3熱度

1回答

卡桑德拉不與UDT合作

我有一個Java應用程序，其中，我有Spark-1.4.0和Cassandra-2.1.5與Cassandra-Spark-connection-1.4.0-M1。在此應用程序中，我試圖使用Dataframe或使用javaFunctions class將Java Bean類存儲到Cassandra表中，其中有一些UDTs。 messages.foreachRDD(new Function2<Ja