- 浏览: 347702 次
- 性别:
- 来自: 杭州
文章分类
最新评论
-
lvyuan1234:
你好,你那个sample.txt文件可以分享给我吗
hive insert overwrite into -
107x:
不错,谢谢!
hive 表的一些默认值 -
on_way_:
赞
Hadoop相关书籍 -
bupt04406:
dengkanghua 写道出来这个问题该怎么解决?hbase ...
Unexpected state导致HMaster abort -
dengkanghua:
出来这个问题该怎么解决?hbase master启动不起来。
Unexpected state导致HMaster abort
Client端只有一个put请求,往server端写数据,server端处理时间过长,导致client端SocketTimeoutException
0.94版本
Client端发生异常SocketTimeoutException:
12/11/20 19:03:18 WARN client.HConnectionManager$HConnectionImplementation: Failed all from region=myLittleHBaseTable,,1353401128907.2879da4a2d609943473a2421520732cb., hostname=ubuntu, port=60020
java.util.concurrent.ExecutionException: java.net.SocketTimeoutException: Call to ubuntu/0:0:0:0:0:0:0:1:60020 failed on socket timeout exception: java.net.SocketTimeoutException: 60000 millis timeout while waiting for channel to be ready for read. ch : java.nio.channels.SocketChannel[connected local=/0:0:0:0:0:0:0:1:42426 remote=ubuntu/0:0:0:0:0:0:0:1:60020]
at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
at java.util.concurrent.FutureTask.get(FutureTask.java:83)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processBatchCallback(HConnectionManager.java:1553)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.processBatch(HConnectionManager.java:1376)
at org.apache.hadoop.hbase.client.HTable.flushCommits(HTable.java:937)
at org.apache.hadoop.hbase.client.HTable.doPut(HTable.java:793)
at org.apache.hadoop.hbase.client.HTable.put(HTable.java:768)
at updateTest.put(updateTest.java:61)
at updateTest.main(updateTest.java:96)
Caused by: java.net.SocketTimeoutException: Call to ubuntu/0:0:0:0:0:0:0:1:60020 failed on socket timeout exception: java.net.SocketTimeoutException: 60000 millis timeout while waiting for channel to be ready for read. ch : java.nio.channels.SocketChannel[connected local=/0:0:0:0:0:0:0:1:42426 remote=ubuntu/0:0:0:0:0:0:0:1:60020]
at org.apache.hadoop.hbase.ipc.HBaseClient.wrapException(HBaseClient.java:960)
at org.apache.hadoop.hbase.ipc.HBaseClient.call(HBaseClient.java:933)
at org.apache.hadoop.hbase.ipc.WritableRpcEngine$Invoker.invoke(WritableRpcEngine.java:147)
at $Proxy4.multi(Unknown Source)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$3$1.call(HConnectionManager.java:1353)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$3$1.call(HConnectionManager.java:1351)
at org.apache.hadoop.hbase.client.ServerCallable.withoutRetries(ServerCallable.java:210)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$3.call(HConnectionManager.java:1360)
at org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation$3.call(HConnectionManager.java:1348)
at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
at java.util.concurrent.FutureTask.run(FutureTask.java:138)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
Caused by: java.net.SocketTimeoutException: 60000 millis timeout while waiting for channel to be ready for read. ch : java.nio.channels.SocketChannel[connected local=/0:0:0:0:0:0:0:1:42426 remote=ubuntu/0:0:0:0:0:0:0:1:60020]
at org.apache.hadoop.net.SocketIOWithTimeout.doIO(SocketIOWithTimeout.java:164)
at org.apache.hadoop.net.SocketInputStream.read(SocketInputStream.java:155)
at org.apache.hadoop.net.SocketInputStream.read(SocketInputStream.java:128)
at java.io.FilterInputStream.read(FilterInputStream.java:116)
at java.io.FilterInputStream.read(FilterInputStream.java:116)
at org.apache.hadoop.hbase.ipc.HBaseClient$Connection$PingInputStream.read(HBaseClient.java:318)
at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
at java.io.BufferedInputStream.read(BufferedInputStream.java:237)
at java.io.DataInputStream.readInt(DataInputStream.java:370)
at org.apache.hadoop.hbase.ipc.HBaseClient$Connection.receiveResponse(HBaseClient.java:578)
at org.apache.hadoop.hbase.ipc.HBaseClient$Connection.run(HBaseClient.java:512)
HBaseClient的Connection一直在等待response,然后过了60000ms后,接收到SocketTimeoutException异常
我们可以看到在receiveResponse里面不会close掉这个connection,会把call从calls队列里面remove掉,所以导致calls队列为空,但是接着会执行waitForWork
2012-11-20 20:54:47,256 WARN org.apache.hadoop.ipc.HBaseServer: IPC Server listener on 60020: readAndProcess threw exception java.io.IOException: Connection reset by peer. Count of bytes read: 0
java.io.IOException: Connection reset by peer
at sun.nio.ch.FileDispatcher.read0(Native Method)
at sun.nio.ch.SocketDispatcher.read(SocketDispatcher.java:21)
at sun.nio.ch.IOUtil.readIntoNativeBuffer(IOUtil.java:202)
at sun.nio.ch.IOUtil.read(IOUtil.java:175)
at sun.nio.ch.SocketChannelImpl.read(SocketChannelImpl.java:243)
at org.apache.hadoop.hbase.ipc.HBaseServer.channelRead(HBaseServer.java:2119)
at org.apache.hadoop.hbase.ipc.HBaseServer$Connection.readAndProcess(HBaseServer.java:1394)
at org.apache.hadoop.hbase.ipc.HBaseServer$Listener.doRead(HBaseServer.java:956)
at org.apache.hadoop.hbase.ipc.HBaseServer$Listener$Reader.doRunLoop(HBaseServer.java:745)
at org.apache.hadoop.hbase.ipc.HBaseServer$Listener$Reader.run(HBaseServer.java:720)
at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
at java.lang.Thread.run(Thread.java:662)
2012-11-20 20:55:48,548 WARN org.apache.hadoop.ipc.HBaseServer: IPC Server Responder, call multi(#size=1#myLittleHBaseTable,,1353401128907.2879da4a2d609943473a2421520732cb.{"totalColumns":1,"families":{"myLittleFamily":[{"timestamp":1353473688277,"qualifier":"someQualifier","vlen":14}]},"row":"myLittleRow1010001"}#), rpc version=1, client version=29, methodsFingerPrint=-56040613 from 0:0:0:0:0:0:0:1:42785: output error
2012-11-20 20:55:48,549 WARN org.apache.hadoop.ipc.HBaseServer: IPC Server handler 5 on 60020 caught a ClosedChannelException, this means that the server was processing a request but the client went away. The error message was: null
发表评论
-
hbase flush前提: 等待相关事务都完成
2016-07-04 16:40 1065DefaultMemStore: @Override ... -
turn log on/off
2015-10-21 10:06 0wget -q "http://hostna ... -
hbase的一些语义
2014-06-04 16:39 1113hbase里面对一行操作前会加锁。 http://had ... -
Unexpected state导致HMaster abort
2014-01-09 11:44 2716线上和开发集群都遇到过master abort的情况,而且 ... -
hbase build Too many unapproved licenses
2013-12-30 16:02 2357[ERROR] Failed to execute ... -
hbase hbck 导致的multi assign
2013-12-25 18:03 1672http://hbase.apache.org/book. ... -
HBase Log Split 配置相关
2013-12-15 16:54 1568(1)HMaster SplitLogManager ... -
hbase jmx
2013-12-11 20:42 2940conf/hbase-env.sh 里面配了 JMX后就可 ... -
hbase bulk多family,锁住region
2013-10-29 15:14 1226HBase在bulk 多family的数据时,会获得整个r ... -
Phoneix
2013-10-22 11:42 1502https://github.com/forcedotco ... -
hbase RowCounter 使用
2013-10-15 16:48 5925hbase org.apache.hadoop.hb ... -
hbase add table
2013-09-26 21:49 1339把table数据从一个集群移动到另外一个集群 (1) ... -
hbase shell
2013-09-26 11:18 1667hbase shell 命令 mvn cle ... -
hbase snapshot
2013-06-06 16:40 2175Snapshot: (1) take a sn ... -
hbase split 导致compact abort的日志
2013-06-06 16:37 34772013-06-06 14:58:43,131 INF ... -
HBase maxIdleTime
2013-03-29 18:01 1677HBaseClient端会建立跟HRegionServer ... -
HBase Create Table
2013-01-10 15:50 2152基于HBase trunk代码http ... -
facebook hbase版本目前做的一些重要特性,提升性能
2012-11-22 19:36 2144(1)每个regionserver多个HLog,提升写。 社区 ... -
RPC HBaseServer
2012-11-12 20:28 1093HBaseServer: 一个请求发送的数据是:数据的长 ... -
HDFS HBase NIO相关知识
2012-09-26 18:29 2653HDFS的NIO有一些相关的知识偶尔需要注意下: (1) 使 ...
相关推荐
2. **如何设置和处理SocketTimeoutException**:介绍如何使用`setSoTimeout()`方法设置超时时间,以及当异常发生时如何捕获和处理。 3. **EJB与Socket通信**:可能详细解释了在EJB中如何使用Socket进行网络通信,...
综上所述,"AndroidStudio版登陆界面加直连Sqlserver"项目涵盖了Android UI设计、网络编程、数据库操作和异常处理等多方面知识,对于初学者来说,这是一个很好的实践项目,可以帮助理解Android应用与远程数据库交互...
WebHDFS客户端通常会处理如SocketTimeoutException、NetworkException等常见错误,并提供适当的恢复策略。 6. **测试与调试**: "webhdfs-java-client-master"项目中的测试用例可以帮助理解各种操作的正确用法,并...
在提供的`SocketServerDemo`文件中,很可能包含了实现上述功能的示例代码。通过分析这个示例,你可以更深入地理解如何用Java构建一个简单的`Socket`服务器,以及如何处理客户端连接和超时。 总的来说,Java的`...
在"clientSocketToDemo"项目中,有两个主要部分:客户端(Client)和服务器端(Server)。客户端负责发起连接请求,而服务器端则监听特定的端口号,等待连接的到来。 1. **服务器端**:使用`ServerSocket`类创建一...
在处理超时时,我们应捕获并处理`SocketTimeoutException`。这可能意味着网络延迟过高,或者服务器没有在规定时间内给出响应。在这种情况下,可以选择重新发起请求,或者向用户展示网络不稳定的通知。 在"TimeOut...
如果在指定的时间内没有接收到数据,`read()`方法会抛出一个`SocketTimeoutException`,从而强制退出阻塞状态。示例代码如下: ```java Socket socket = new Socket(host, port); socket.setSoTimeout(100); // ...
如果服务器没有响应,或者网络状况不佳,超过这个时间,OkHttp会抛出一个`SocketTimeoutException`。 读取超时(Read Timeout)是在连接建立后,等待服务器返回数据的时间。如果在这段时间内服务器没有发送任何数据...
在IT领域,Socket编程是网络通信的核心技术之一,主要用于实现客户端(Client)和服务器(Server)之间的双向通信。本文将详细解析"基于Socket的CS模式聊天室"的相关知识点,包括Socket的基本概念、CS模式的含义以及...
Socket编程在Java中主要用于实现客户端(Client)与服务器端(Server)的通信,是Internet应用程序的基础。以下是对"java Socket编程基础代码"的详细解释。 首先,我们需要了解Socket的基本概念。Socket可以被看作...
然后,使用HttpClient发送请求,并捕获可能的异常,例如SocketTimeoutException,用于处理请求超时: ```java HttpClient httpClient = new DefaultHttpClient(); try { HttpResponse response = httpClient....
2. 错误处理:正确处理各种网络异常,如SocketTimeoutException、IOException等。 3. 数据编码与解码:确保发送和接收的数据格式一致,避免数据解析错误。 4. 连接管理:合理控制连接的创建与销毁,避免资源浪费。 ...
常见的问题
在高并发写入情况下,客户端与NameNode之间的通信频繁,如果NameNode处理能力不足,则容易导致客户端等待时间过长,从而触发超时异常。 **解决方法** 针对此类问题,可以从以下几个方面进行优化: 1. **增加...
Socket编程在Java中主要用于实现客户端(Client)与服务器端(Server)的应用交互,例如文件传输、聊天应用、在线游戏等。本教程将提供一个详细的Java Socket编程介绍,结合实例教学,帮助开发者掌握其核心概念和...
网络编程中,必须妥善处理各种可能的异常,如SocketTimeoutException、IOException等。良好的异常处理能确保程序的健壮性。 10. **关闭资源** 当通信结束后,记得关闭Socket、InputStream、OutputStream以及...
例如,服务器端可能会因为没有客户端连接而抛出`SocketTimeoutException`,客户端可能会因为网络问题无法连接到服务器。 - 为了确保程序的健壮性,需要对可能出现的异常进行捕获和处理。 4. **关闭连接** - 通信...
如果超过这个时间,读取或写入操作将抛出SocketTimeoutException。 例如,以下代码设置了30秒的超时限制: ```java Socket socket = new Socket(); socket.connect(new InetSocketAddress("localhost", 8080), ...