java.io.FileNotFoundException : localhost/broadcast_1

标签 java apache-spark filenotfoundexception spark-streaming apache-spark-sql

我试图在内部使用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

最佳答案

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

关于java.io.FileNotFoundException : localhost/broadcast_1,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/30233505/

相关文章:

python - Spark RDD中是否有类似sql中的 'like'函数的函数?

java - 使用消息捕获并处理 Java 中的异常抛出(打开文件过多)

java - 在 Eclipse 中导入项目的一部分

java - 如何在套接字连接中发送不同的数据类型

scala - 修剪Java中Apache Spark中的特殊字符

java - 检测 java.io.FileNotFoundException 的根本原因

android - Android getAssets()。openFd(string)-找不到文件

java - 导致 session ID 递增的原因

Java括号在字符串中翻转

java - 为 REST 服务中的每个端点创建单独的 SparkSession