2016-12-31 21 views
0

私はSparkRのチュートリアルに従おうとしています。私は必要に応じてセットアップに従います。しかし、すぐに、私は「read.json(パス)」機能を試してみて、私は次のエラーを取得する:Spark Rでjsonファイルの読み込みエラー

"Error in invokeJava(isStatic = FALSE, objId$id, methodName, ...) : 
    java.lang.reflect.InvocationTargetException 
    at sun.reflect.NativeConstructorAccessorImpl.newInstance0(Native Method) 
    at  sun.reflect.NativeConstructorAccessorImpl.newInstance(NativeConstructorAccessorImpl.java:62)..." 

チュートリアルで要求されるように、私はR 3.3.2およびJava JDK 1.8を実行しています。 コードと結果の画像を添付します:

私のJavaは見つかりましたか、それは正しいバージョンですか?

画像は右に左にコードとコンソール結果を示すRスタジオである:

enter image description here

+0

あなたの 'JAVA_HOME'は見つかりましたか?環境変数に追加されましたか?たとえば、 'Sys.getenv( 'JAVA_HOME')'とします。 – Abdou

+0

YES Sys.getenv( 'JAVA_HOME') [1]「C:\\ Program Files \\ Java \\ jdk1.8.0_112」 – Graham

+0

あなたが助けることができれば、非常に義務づけられます。他のマシンでinstllしようとしても、tryinfgtoがscを設定すると同様のエラーが発生します。つまり、接続がスパークします。 – Graham

答えて

0

対処:

火花送信又はsparkRインスタンスが存在します。 HDFS // ...パスを使用して

はのHadoop HDFS上のJSONファイルを置く:

hadoop-2.0.2\bin> hadoop fs -put "/example/../people.json" "/user/../people.json" 

その後、JSONを読み込み、データフレーム '人' を作成するために

people <- read.df (sqlContext, "/user/../people.json","json") 

を使用しています。

上記の手順は、データフレームの例で必要な変更を加えた後、私のために働いた。

+0

多くの編集についてお詫び申し上げます。 – user3692020

関連する問題