2017-11-02 5 views
-1

スパークバージョン2.0.2.6 Scalaのバージョン2.11.11 なぜ私はそれを提出しようとしている仕事としてこのプログラムを実行することはできませんよスパークへ。 IntelliJを使用してこのプログラムを実行すると、動作します。 しかし、JARを作成して実行すると、エラーが発生しています。スパークScalaのdatastaxのcsvロードファイルおよびプリントスキーマ

コマンド:

> dse spark-submit --class "csvtospark" /Users/del/target/scala-2.11/csvtospark_2.11-1.0.jar 

私は次のエラーを取得しています://127.0.0.1私はちょうどパス/ユーザ/デスクトップを与えているにもかかわらず、一部を:なぜそれはdsefsを付加している

ERROR 2017-11-02 11:46:10,245 org.apache.spark.deploy.DseSparkSubmitBootstrapper: Failed to start or submit Spark application 
org.apache.spark.sql.AnalysisException: Path does not exist: dsefs://127.0.0.1/Users/Desktop/csv/example.csv; 

/csv/example.csvを入力します。

私は--materオプションも与えてみました。どのように私は同じエラーが発生している。私はローカルマシンでDataStax Sparkを実行しています。クラスタはありません。
私が間違っているところで私を修正してください。

答えて

0

気にしないで。申し訳ありません。

入力はfile:///ファイル名にする必要があります。

関連する問題