java.io.FileNotFoundException : localhost/broadcast_1

Question

我试图在内部使用sparkSQL运行一个spark应用程序，但是每当我使用LEFT OUTER JOIN时，它都会给我以下错误，

从姓名 a LEFT OUTER JOIN 电话 b ON (a.id=b.id) 中选择 a.name,b.phone

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

Answer 1

通常，当文件操作期间查找文件出现问题时，会出现文件未找到异常。如果 SQL 语句是导致异常的罪魁祸首，那么您应该在执行 SQL 操作之前执行任何文件操作吗？