问题标签 [broken-pipe]

我在 Ubuntu 12.04 上运行 Hadoop Pipes 作业，但是当减速器启动时出现 Broken Pipe 错误：

2013-04-17 10:40:38,088 INFO org.apache.hadoop.mapred.ReduceTask：将 0 个段，0 个字节从内存合并到 reduce 2013-04-17 10:40:38,088 INFO org.apache.hadoop.mapred。合并：合并 1 个已排序的段 2013-04-17 10:40:38,088 INFO org.apache.hadoop.mapred.Merger：到最后一个合并通道，总大小还剩下 1 个段：1795675 字节 2013-04-17 10:40:38,118 INFO org.apache.hadoop.mapred.pipes.PipesReducer：启动应用程序 2013-04-17 10:40:38,264 INFO org.apache.hadoop.mapred.pipes.PipesReducer：等待完成 2013-04- 17 10:40:38,265 错误 org.apache.hadoop.mapred.pipes.BinaryProtocol：java.net.SocketException：在 java.net.SocketInputStream.read 的 java.net.SocketInputStream.read(SocketInputStream.java:189) 处的连接重置(SocketInputStream.java:121) 在 java.io.BufferedInputStream。fill(BufferedInputStream.java:235) at java.io.BufferedInputStream.read(BufferedInputStream.java:254) at java.io.DataInputStream.readByte(DataInputStream.java:265) at org.apache.hadoop.io.WritableUtils.readVlong (WritableUtils.java:299) 在 org.apache.hadoop.io.WritableUtils.readVInt(WritableUtils.java:320) 在 org.apache.hadoop.mapred.pipes.BinaryProtocol$UplinkReaderThread.run(BinaryProtocol.java:121)121)121)

2013-04-17 10:40:38,265 INFO org.apache.hadoop.mapred.pipes.Application：由于 java.net.SocketException 而中止：java.net 的 java.net.SocketOutputStream.socketWrite0（本机方法）的管道损坏.SocketOutputStream.socketWrite(SocketOutputStream.java:109) at java.net.SocketOutputStream.write(SocketOutputStream.java:153) at java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:82

任何帮助表示赞赏，在此先感谢。

我需要使用 Cassandra-CLI 创建一个键空间，但是当我执行命令时

create keyspace "name" with strategy_options={replication_factor:1};

我收到消息：

第一次，第二次和下一次我尝试创建它，我得到

我的 java 版本是 Java(TM) SE Runtime Enviroment (build 1.6.0_26-b03) Java HotSpot(TM) Client VM (build 20.1-b02，混合模式，共享)

附加信息：

当我运行命令 init.d/cassandra status 时，我收到以下消息：

我已经为（linux - IPC）编写了一个基本的示例程序，pipe但我得到broken pipe了输出。

下面是代码：

编译：

c++ pipe.cpp -g -o pipe

输出：

使用 fd[0] - 3 和 fd[1] - 4 创建的管道

在子进程中

在子进程中

断管

如何解决这个问题或我在做什么错误？

我正在使用以下命令从 ssh 运行 php 脚本

该脚本有一个循环，应该循环大约 800,000 次（因此需要几天时间才能运行）。然而，它目前正在停止进入该过程的数千个循环。我的错误处理程序没有从脚本中捕获任何错误，但控制台会读取。

任何人都可以阐明这条消息的含义，这表明什么样的问题，以及我如何去追踪它？

更新：

为了总结脚本的作用，它从我的数据库（与脚本托管在同一台服务器上）的表中选择 800,000 行。对于每一行，它都会对第三方站点进行一次休息调用，然后将该数据写入同一数据库中的不同表（与脚本托管在同一台服务器上）。

我正在实现一个服务器，我在其中监听客户端使用接受套接字调用进行连接。

在接受发生并且我收到套接字后，我等待大约 10-15 秒，然后再进行第一次接收/发送调用。

发送到客户端的调用失败，errno = 32 即管道损坏。

因为我不控制客户端，所以我在接受的套接字中设置了套接字选项 *SO_KEEPALIVE*。

谁能告诉这里可能出了什么问题，我们如何防止客户端套接字关闭？

注意 我想在这里添加的一件事是，如果在接受和发送/接收调用之间没有时间间隔或少于 5 秒，则客户端服务器通信按预期进行。

我已经完成了暑期实习的 Python 代码。

这是代码：

如您所见，我没有尝试过递归函数，只是为了让事情更简单。

现在，读取的文件格式如下：

对于 16383 行数据。当我尝试在 4 分钟后运行代码时，我收到以下错误消息：

我用一个 128 行的数据文件进行了尝试，并且在 1 秒内一切正常。

我想知道该消息首先意味着什么，以及如果可能的话，如何修复它。

我在 Ubuntu12.04、4 GB 内存、64 位桌面上运行。

我正在 C++ 上创建一个简单的客户端/服务器多人游戏。所以客户端连接成功，当我试图发送smth。对此，我从调试器“收到信号：SIGPIPE（断管）”收到此消息这是代码：

服务器：

客户：

客户端连接成功，但没有收到任何东西。

设置：

• 进程 A 创建进程 B 并将 stdin、stdout、stderr 正确附加到进程之间的匿名管道。
• 进程 B 通过标准输出生成少量数据，然后终止。
• 进程 A 很忙，直到进程 B 终止后的某个时间才有机会读取管道。

进程A是否仍然可以读取少量数据？

最近我用python写websocket服务端，握手是OK的，服务端可以接受客户端发来的消息，但是这么连线，当服务端给客户端发消息的时候，服务端会遇到像破管子这样的错误，我仔细检查了代码，可以找不到路，谁能帮帮我？这是我的服务器代码。提前致谢！

我的 Rails 服务器每天崩溃几次，我不知道是什么原因。这是打开调试模式时我在日志中得到的内容：

有人遇到过这个问题吗？