0

我試圖運行使用sparkSQL內部火花的應用程序,但每當我使用LEFT OUTER JOIN它給我下面的錯誤,java.io.FileNotFoundException:本地主機/ broadcast_1

select a.name,b.phone FROM name a LEFT OUTER JOIN phone b ON (a.id=b.id)

java.io.FileNotFoundException: localhost:57067/broadcast_1 
at sun.net.www.protocol.http.HttpURLConnection.getInputStream(Unknown Source) 
at org.apache.spark.broadcast.HttpBroadcast$.read(HttpBroadcast.scala:196) 
at org.apache.spark.broadcast.HttpBroadcast.readObject(HttpBroadcast.scala:89) 
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) 
at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source) 
at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source) 

但如果我使用JOIN而不是它,那對我來說沒有任何問題。會有什麼問題? 我正在使用Spark版本1.0.0

+0

請張貼您的代碼。 – Sufian

回答

1

當在文件操作過程中發現文件時出現問題時,通常會看到文件未找到異常。如果SQL語句是異常的罪魁禍首,那麼您應該得到SQlException,那麼在執行SQL操作之前是否正在執行任何文件操作?