Created
October 30, 2017 15:21
-
-
Save sebge2emasphere/8ba3c5d42a4a68bb2edd848119b187ef to your computer and use it in GitHub Desktop.
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2017-10-30 15:09:40,443 DEBUG [RpcServer.listener,port=16020] ipc.RpcServer: RpcServer.listener,port=16020: connection from 172.31.15.200:56894; # active connections: 3 | |
| 2017-10-30 15:09:40,470 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.DFSClient: Connecting to datanode 172.31.15.200:50010 | |
| 2017-10-30 15:09:40,470 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: BlockReaderFactory(fileName=/user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7, block=BP-983401122-172.31.15.200-1508568126354:blk_1073746500_5714): trying to create a remote block reader from a TCP socket | |
| 2017-10-30 15:09:40,471 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: reusing existing peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51498]) | |
| 2017-10-30 15:09:40,471 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.DataTransferProtocol: Sending DataTransferOp OpReadBlockProto: header { | |
| baseHeader { | |
| block { | |
| poolId: "BP-983401122-172.31.15.200-1508568126354" | |
| blockId: 1073746500 | |
| generationStamp: 5714 | |
| numBytes: 29666 | |
| } | |
| token { | |
| identifier: "" | |
| password: "" | |
| kind: "" | |
| service: "" | |
| } | |
| } | |
| clientName: "DFSClient_NONMAPREDUCE_-1070784671_1" | |
| } | |
| offset: 0 | |
| len: 29666 | |
| sendChecksums: false | |
| cachingStrategy { | |
| } | |
| 2017-10-30 15:09:40,472 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: Closed potentially stale remote peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51498]) | |
| java.io.EOFException: Premature EOF: no length prefix available | |
| at org.apache.hadoop.hdfs.protocolPB.PBHelper.vintPrefixed(PBHelper.java:2282) | |
| at org.apache.hadoop.hdfs.RemoteBlockReader2.newBlockReader(RemoteBlockReader2.java:423) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.getRemoteBlockReader(BlockReaderFactory.java:818) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.getRemoteBlockReaderFromTcp(BlockReaderFactory.java:697) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.build(BlockReaderFactory.java:355) | |
| at org.apache.hadoop.hdfs.DFSInputStream.blockSeekTo(DFSInputStream.java:673) | |
| at org.apache.hadoop.hdfs.DFSInputStream.readWithStrategy(DFSInputStream.java:882) | |
| at org.apache.hadoop.hdfs.DFSInputStream.read(DFSInputStream.java:934) | |
| at java.io.DataInputStream.read(DataInputStream.java:149) | |
| at org.apache.hadoop.io.IOUtils.readFully(IOUtils.java:199) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$AbstractFSReader.readAtOffset(HFileBlock.java:1456) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$FSReaderImpl.readBlockDataInternal(HFileBlock.java:1702) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$FSReaderImpl.readBlockData(HFileBlock.java:1560) | |
| at org.apache.hadoop.hbase.io.hfile.HFileReaderV2.readBlock(HFileReaderV2.java:454) | |
| at org.apache.hadoop.hbase.io.hfile.HFileReaderV2$ScannerV2.seekTo(HFileReaderV2.java:922) | |
| at org.apache.hadoop.hbase.regionserver.StoreFileScanner.seekAtOrAfter(StoreFileScanner.java:279) | |
| at org.apache.hadoop.hbase.regionserver.StoreFileScanner.seek(StoreFileScanner.java:174) | |
| at org.apache.hadoop.hbase.regionserver.StoreScanner.seekScanners(StoreScanner.java:361) | |
| at org.apache.hadoop.hbase.regionserver.StoreScanner.<init>(StoreScanner.java:209) | |
| at org.apache.hadoop.hbase.regionserver.HStore.getScanner(HStore.java:2132) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.initializeScanners(HRegion.java:5753) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.<init>(HRegion.java:5725) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.<init>(HRegion.java:5730) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.instantiateRegionScanner(HRegion.java:2678) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2658) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2640) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2634) | |
| at org.apache.hadoop.hbase.regionserver.RSRpcServices.newRegionScanner(RSRpcServices.java:2495) | |
| at org.apache.hadoop.hbase.regionserver.RSRpcServices.scan(RSRpcServices.java:2757) | |
| at org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:34950) | |
| at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:2339) | |
| at org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:123) | |
| at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:188) | |
| at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:168) | |
| 2017-10-30 15:09:40,475 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] ipc.ProtobufRpcEngine: 80: Call -> ip-172-31-15-200.ec2.internal/172.31.15.200:8020: getServerDefaults {} | |
| 2017-10-30 15:09:40,475 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] ipc.Client: The ping interval is 60000 ms. | |
| 2017-10-30 15:09:40,476 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] ipc.Client: Connecting to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 | |
| 2017-10-30 15:09:40,476 DEBUG [IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase] ipc.Client: IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase: starting, having connections 1 | |
| 2017-10-30 15:09:40,478 DEBUG [IPC Parameter Sending Thread #0] ipc.Client: IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase sending #173 | |
| 2017-10-30 15:09:40,481 DEBUG [IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase] ipc.Client: IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase got value #173 | |
| 2017-10-30 15:09:40,481 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] ipc.ProtobufRpcEngine: Call: getServerDefaults took 6ms | |
| 2017-10-30 15:09:40,481 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] ipc.ProtobufRpcEngine: 80: Response <- ip-172-31-15-200.ec2.internal/172.31.15.200:8020: getServerDefaults {serverDefaults { blockSize: 134217728 bytesPerChecksum: 512 writePacketSize: 65536 replication: 1 fileBufferSize: 65536 encryptDataTransfer: false trashInterval: 0 checksumType: CHECKSUM_CRC32C }} | |
| 2017-10-30 15:09:40,481 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] sasl.SaslDataTransferClient: SASL client skipping handshake in unsecured configuration for addr = /172.31.15.200, datanodeId = DatanodeInfoWithStorage[172.31.15.200:50010,DS-a880eef5-7c7d-47ad-b2df-67a9f0e06072,DISK] | |
| 2017-10-30 15:09:40,481 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: created newConnectedPeer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51534]) | |
| 2017-10-30 15:09:40,481 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.DataTransferProtocol: Sending DataTransferOp OpReadBlockProto: header { | |
| baseHeader { | |
| block { | |
| poolId: "BP-983401122-172.31.15.200-1508568126354" | |
| blockId: 1073746500 | |
| generationStamp: 5714 | |
| numBytes: 29666 | |
| } | |
| token { | |
| identifier: "" | |
| password: "" | |
| kind: "" | |
| service: "" | |
| } | |
| } | |
| clientName: "DFSClient_NONMAPREDUCE_-1070784671_1" | |
| } | |
| offset: 0 | |
| len: 29666 | |
| sendChecksums: false | |
| cachingStrategy { | |
| } | |
| 2017-10-30 15:09:40,483 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.DFSClient: Address /172.31.15.200:50010 is local | |
| 2017-10-30 15:09:40,484 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Starting read #d6000d7b-b48d-4c06-a63c-9e122fddc19f file /user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,484 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 29666 headerLen = 25 | |
| 2017-10-30 15:09:40,484 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: DFSClient readNextPacket got header PacketHeader with packetLen=29670 header data: offsetInBlock: 0 | |
| seqno: 0 | |
| lastPacketInBlock: false | |
| dataLen: 29666 | |
| 2017-10-30 15:09:40,484 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Reading empty packet at end of read | |
| 2017-10-30 15:09:40,485 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 0 headerLen = 25 | |
| 2017-10-30 15:09:40,485 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Finishing read #d6000d7b-b48d-4c06-a63c-9e122fddc19f | |
| 2017-10-30 15:09:40,485 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Starting read #05a4c55e-6801-49d3-82ff-05e2deac6b5f file /user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,485 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Finishing read #05a4c55e-6801-49d3-82ff-05e2deac6b5f | |
| 2017-10-30 15:09:40,487 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.DFSClient: Connecting to datanode 172.31.15.200:50010 | |
| 2017-10-30 15:09:40,487 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: BlockReaderFactory(fileName=/user/hbase/data/hbase/meta/1588230740/info/c9b54afd4b2b423187f6e98082c6f1b6, block=BP-983401122-172.31.15.200-1508568126354:blk_1073746517_5731): trying to create a remote block reader from a TCP socket | |
| 2017-10-30 15:09:40,487 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: reusing existing peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51500]) | |
| 2017-10-30 15:09:40,488 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.DataTransferProtocol: Sending DataTransferOp OpReadBlockProto: header { | |
| baseHeader { | |
| block { | |
| poolId: "BP-983401122-172.31.15.200-1508568126354" | |
| blockId: 1073746517 | |
| generationStamp: 5731 | |
| numBytes: 7233 | |
| } | |
| token { | |
| identifier: "" | |
| password: "" | |
| kind: "" | |
| service: "" | |
| } | |
| } | |
| clientName: "DFSClient_NONMAPREDUCE_-1070784671_1" | |
| } | |
| offset: 0 | |
| len: 7233 | |
| sendChecksums: false | |
| cachingStrategy { | |
| } | |
| 2017-10-30 15:09:40,488 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: Closed potentially stale remote peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51500]) | |
| java.io.EOFException: Premature EOF: no length prefix available | |
| at org.apache.hadoop.hdfs.protocolPB.PBHelper.vintPrefixed(PBHelper.java:2282) | |
| at org.apache.hadoop.hdfs.RemoteBlockReader2.newBlockReader(RemoteBlockReader2.java:423) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.getRemoteBlockReader(BlockReaderFactory.java:818) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.getRemoteBlockReaderFromTcp(BlockReaderFactory.java:697) | |
| at org.apache.hadoop.hdfs.BlockReaderFactory.build(BlockReaderFactory.java:355) | |
| at org.apache.hadoop.hdfs.DFSInputStream.blockSeekTo(DFSInputStream.java:673) | |
| at org.apache.hadoop.hdfs.DFSInputStream.readWithStrategy(DFSInputStream.java:882) | |
| at org.apache.hadoop.hdfs.DFSInputStream.read(DFSInputStream.java:934) | |
| at java.io.DataInputStream.read(DataInputStream.java:149) | |
| at org.apache.hadoop.io.IOUtils.readFully(IOUtils.java:199) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$AbstractFSReader.readAtOffset(HFileBlock.java:1456) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$FSReaderImpl.readBlockDataInternal(HFileBlock.java:1702) | |
| at org.apache.hadoop.hbase.io.hfile.HFileBlock$FSReaderImpl.readBlockData(HFileBlock.java:1560) | |
| at org.apache.hadoop.hbase.io.hfile.HFileReaderV2.readBlock(HFileReaderV2.java:454) | |
| at org.apache.hadoop.hbase.io.hfile.HFileReaderV2$ScannerV2.seekTo(HFileReaderV2.java:922) | |
| at org.apache.hadoop.hbase.regionserver.StoreFileScanner.seekAtOrAfter(StoreFileScanner.java:279) | |
| at org.apache.hadoop.hbase.regionserver.StoreFileScanner.seek(StoreFileScanner.java:174) | |
| at org.apache.hadoop.hbase.regionserver.StoreScanner.seekScanners(StoreScanner.java:361) | |
| at org.apache.hadoop.hbase.regionserver.StoreScanner.<init>(StoreScanner.java:209) | |
| at org.apache.hadoop.hbase.regionserver.HStore.getScanner(HStore.java:2132) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.initializeScanners(HRegion.java:5753) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.<init>(HRegion.java:5725) | |
| at org.apache.hadoop.hbase.regionserver.HRegion$RegionScannerImpl.<init>(HRegion.java:5730) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.instantiateRegionScanner(HRegion.java:2678) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2658) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2640) | |
| at org.apache.hadoop.hbase.regionserver.HRegion.getScanner(HRegion.java:2634) | |
| at org.apache.hadoop.hbase.regionserver.RSRpcServices.newRegionScanner(RSRpcServices.java:2495) | |
| at org.apache.hadoop.hbase.regionserver.RSRpcServices.scan(RSRpcServices.java:2757) | |
| at org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$2.callBlockingMethod(ClientProtos.java:34950) | |
| at org.apache.hadoop.hbase.ipc.RpcServer.call(RpcServer.java:2339) | |
| at org.apache.hadoop.hbase.ipc.CallRunner.run(CallRunner.java:123) | |
| at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:188) | |
| at org.apache.hadoop.hbase.ipc.RpcExecutor$Handler.run(RpcExecutor.java:168) | |
| 2017-10-30 15:09:40,488 DEBUG [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] sasl.SaslDataTransferClient: SASL client skipping handshake in unsecured configuration for addr = /172.31.15.200, datanodeId = DatanodeInfoWithStorage[172.31.15.200:50010,DS-a880eef5-7c7d-47ad-b2df-67a9f0e06072,DISK] | |
| 2017-10-30 15:09:40,489 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: created newConnectedPeer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51538]) | |
| 2017-10-30 15:09:40,489 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.DataTransferProtocol: Sending DataTransferOp OpReadBlockProto: header { | |
| baseHeader { | |
| block { | |
| poolId: "BP-983401122-172.31.15.200-1508568126354" | |
| blockId: 1073746517 | |
| generationStamp: 5731 | |
| numBytes: 7233 | |
| } | |
| token { | |
| identifier: "" | |
| password: "" | |
| kind: "" | |
| service: "" | |
| } | |
| } | |
| clientName: "DFSClient_NONMAPREDUCE_-1070784671_1" | |
| } | |
| offset: 0 | |
| len: 7233 | |
| sendChecksums: false | |
| cachingStrategy { | |
| } | |
| 2017-10-30 15:09:40,495 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.DFSClient: Address /172.31.15.200:50010 is local | |
| 2017-10-30 15:09:40,495 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Starting read #486f0395-fb26-4c25-a800-d5bb98cd39e4 file /user/hbase/data/hbase/meta/1588230740/info/c9b54afd4b2b423187f6e98082c6f1b6 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,495 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 7233 headerLen = 25 | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: DFSClient readNextPacket got header PacketHeader with packetLen=7237 header data: offsetInBlock: 0 | |
| seqno: 0 | |
| lastPacketInBlock: false | |
| dataLen: 7233 | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Reading empty packet at end of read | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 0 headerLen = 25 | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Finishing read #486f0395-fb26-4c25-a800-d5bb98cd39e4 | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Starting read #d22df285-43c6-439a-855b-f9dd082d918e file /user/hbase/data/hbase/meta/1588230740/info/c9b54afd4b2b423187f6e98082c6f1b6 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,496 TRACE [RpcServer.FifoWFPBQ.priority.handler=19,queue=1,port=16020] hdfs.RemoteBlockReader2: Finishing read #d22df285-43c6-439a-855b-f9dd082d918e | |
| 2017-10-30 15:09:40,518 DEBUG [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.DFSClient: Connecting to datanode 172.31.15.200:50010 | |
| 2017-10-30 15:09:40,518 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.BlockReaderFactory: BlockReaderFactory(fileName=/user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7, block=BP-983401122-172.31.15.200-1508568126354:blk_1073746500_5714): trying to create a remote block reader from a TCP socket | |
| 2017-10-30 15:09:40,518 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.BlockReaderFactory: nextTcpPeer: reusing existing peer NioInetPeer(Socket[addr=/172.31.15.200,port=50010,localport=51534]) | |
| 2017-10-30 15:09:40,518 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] datatransfer.DataTransferProtocol: Sending DataTransferOp OpReadBlockProto: header { | |
| baseHeader { | |
| block { | |
| poolId: "BP-983401122-172.31.15.200-1508568126354" | |
| blockId: 1073746500 | |
| generationStamp: 5714 | |
| numBytes: 29666 | |
| } | |
| token { | |
| identifier: "" | |
| password: "" | |
| kind: "" | |
| service: "" | |
| } | |
| } | |
| clientName: "DFSClient_NONMAPREDUCE_-1070784671_1" | |
| } | |
| offset: 8265 | |
| len: 21401 | |
| sendChecksums: false | |
| cachingStrategy { | |
| } | |
| 2017-10-30 15:09:40,519 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.DFSClient: Address /172.31.15.200:50010 is local | |
| 2017-10-30 15:09:40,519 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: Starting read #ef3ddcc3-cf6e-4294-9ed3-92eeea2bff74 file /user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,519 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 21474 headerLen = 25 | |
| 2017-10-30 15:09:40,519 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: DFSClient readNextPacket got header PacketHeader with packetLen=21478 header data: offsetInBlock: 8192 | |
| seqno: 0 | |
| lastPacketInBlock: false | |
| dataLen: 21474 | |
| 2017-10-30 15:09:40,519 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: Reading empty packet at end of read | |
| 2017-10-30 15:09:40,520 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] datatransfer.PacketReceiver: readNextPacket: dataPlusChecksumLen = 0 headerLen = 25 | |
| 2017-10-30 15:09:40,520 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: Finishing read #ef3ddcc3-cf6e-4294-9ed3-92eeea2bff74 | |
| 2017-10-30 15:09:40,525 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: Starting read #67f8f801-9183-4d43-9bf5-694bd19aff21 file /user/hbase/data/hbase/meta/1588230740/info/70870e4a202a4ac681d63edc151488e7 from datanode ip-172-31-15-200.ec2.internal | |
| 2017-10-30 15:09:40,525 TRACE [RpcServer.FifoWFPBQ.priority.handler=18,queue=0,port=16020] hdfs.RemoteBlockReader2: Finishing read #67f8f801-9183-4d43-9bf5-694bd19aff21 | |
| 2017-10-30 15:09:40,565 DEBUG [RpcServer.reader=3,bindAddress=ip-172-31-15-200.ec2.internal,port=16020] ipc.RpcServer: RpcServer.listener,port=16020: DISCONNECTING client 172.31.15.200:56894 because read count=-1. Number of active connections: 3 | |
| 2017-10-30 15:09:40,622 DEBUG [RpcServer.listener,port=16020] ipc.RpcServer: RpcServer.listener,port=16020: connection from 172.31.15.200:56906; # active connections: 3 | |
| 2017-10-30 15:09:45,176 DEBUG [regionserver/ip-172-31-15-200.ec2.internal/172.31.15.200:16020-SendThread(ip-172-31-15-200.ec2.internal:2181)] zookeeper.ClientCnxn: Got ping response for sessionid: 0x15f6ceb51100030 after 0ms | |
| 2017-10-30 15:09:45,641 DEBUG [main-SendThread(ip-172-31-15-200.ec2.internal:2181)] zookeeper.ClientCnxn: Got ping response for sessionid: 0x15f6ceb5110002f after 0ms | |
| 2017-10-30 15:09:46,821 DEBUG [RpcServer.reader=4,bindAddress=ip-172-31-15-200.ec2.internal,port=16020] ipc.RpcServer: RpcServer.listener,port=16020: DISCONNECTING client 172.31.15.200:56906 because read count=-1. Number of active connections: 3 | |
| 2017-10-30 15:09:47,151 TRACE [LeaseRenewer:hbase@ip-172-31-15-200.ec2.internal:8020, clients=[DFSClient_NONMAPREDUCE_-1516524792_1], created at java.lang.Throwable: TRACE | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:202) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:71) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.get(LeaseRenewer.java:143) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.access$100(LeaseRenewer.java:90) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.getInstance(LeaseRenewer.java:80) | |
| at org.apache.hadoop.hdfs.DFSClient.getLeaseRenewer(DFSClient.java:818) | |
| at org.apache.hadoop.hdfs.DFSClient.beginFileLease(DFSClient.java:824) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1693) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1658) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:493) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:489) | |
| at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem.createNonRecursive(DistributedFileSystem.java:504) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1119) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1095) | |
| at org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter.init(ProtobufLogWriter.java:90) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.createWriter(DefaultWALProvider.java:374) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.createWriterInstance(FSHLog.java:738) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:703) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:610) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.<init>(FSHLog.java:537) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.getWAL(DefaultWALProvider.java:132) | |
| at org.apache.hadoop.hbase.wal.WALFactory.getMetaWAL(WALFactory.java:260) | |
| at org.apache.hadoop.hbase.regionserver.HRegionServer.getWAL(HRegionServer.java:1901) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.openRegion(OpenRegionHandler.java:363) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.process(OpenRegionHandler.java:129) | |
| at org.apache.hadoop.hbase.executor.EventHandler.run(EventHandler.java:129) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| ] ipc.ProtobufRpcEngine: 178: Call -> ip-172-31-15-200.ec2.internal/172.31.15.200:8020: renewLease {clientName: "DFSClient_NONMAPREDUCE_-1516524792_1"} | |
| 2017-10-30 15:09:47,152 DEBUG [IPC Parameter Sending Thread #0] ipc.Client: IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase sending #174 | |
| 2017-10-30 15:09:47,152 DEBUG [IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase] ipc.Client: IPC Client (79290250) connection to ip-172-31-15-200.ec2.internal/172.31.15.200:8020 from hbase got value #174 | |
| 2017-10-30 15:09:47,152 DEBUG [LeaseRenewer:hbase@ip-172-31-15-200.ec2.internal:8020, clients=[DFSClient_NONMAPREDUCE_-1516524792_1], created at java.lang.Throwable: TRACE | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:202) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:71) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.get(LeaseRenewer.java:143) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.access$100(LeaseRenewer.java:90) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.getInstance(LeaseRenewer.java:80) | |
| at org.apache.hadoop.hdfs.DFSClient.getLeaseRenewer(DFSClient.java:818) | |
| at org.apache.hadoop.hdfs.DFSClient.beginFileLease(DFSClient.java:824) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1693) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1658) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:493) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:489) | |
| at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem.createNonRecursive(DistributedFileSystem.java:504) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1119) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1095) | |
| at org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter.init(ProtobufLogWriter.java:90) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.createWriter(DefaultWALProvider.java:374) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.createWriterInstance(FSHLog.java:738) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:703) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:610) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.<init>(FSHLog.java:537) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.getWAL(DefaultWALProvider.java:132) | |
| at org.apache.hadoop.hbase.wal.WALFactory.getMetaWAL(WALFactory.java:260) | |
| at org.apache.hadoop.hbase.regionserver.HRegionServer.getWAL(HRegionServer.java:1901) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.openRegion(OpenRegionHandler.java:363) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.process(OpenRegionHandler.java:129) | |
| at org.apache.hadoop.hbase.executor.EventHandler.run(EventHandler.java:129) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| ] ipc.ProtobufRpcEngine: Call: renewLease took 1ms | |
| 2017-10-30 15:09:47,154 TRACE [LeaseRenewer:hbase@ip-172-31-15-200.ec2.internal:8020, clients=[DFSClient_NONMAPREDUCE_-1516524792_1], created at java.lang.Throwable: TRACE | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:202) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:71) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.get(LeaseRenewer.java:143) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.access$100(LeaseRenewer.java:90) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.getInstance(LeaseRenewer.java:80) | |
| at org.apache.hadoop.hdfs.DFSClient.getLeaseRenewer(DFSClient.java:818) | |
| at org.apache.hadoop.hdfs.DFSClient.beginFileLease(DFSClient.java:824) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1693) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1658) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:493) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:489) | |
| at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem.createNonRecursive(DistributedFileSystem.java:504) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1119) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1095) | |
| at org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter.init(ProtobufLogWriter.java:90) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.createWriter(DefaultWALProvider.java:374) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.createWriterInstance(FSHLog.java:738) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:703) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:610) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.<init>(FSHLog.java:537) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.getWAL(DefaultWALProvider.java:132) | |
| at org.apache.hadoop.hbase.wal.WALFactory.getMetaWAL(WALFactory.java:260) | |
| at org.apache.hadoop.hbase.regionserver.HRegionServer.getWAL(HRegionServer.java:1901) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.openRegion(OpenRegionHandler.java:363) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.process(OpenRegionHandler.java:129) | |
| at org.apache.hadoop.hbase.executor.EventHandler.run(EventHandler.java:129) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| ] ipc.ProtobufRpcEngine: 178: Response <- ip-172-31-15-200.ec2.internal/172.31.15.200:8020: renewLease {} | |
| 2017-10-30 15:09:47,154 DEBUG [LeaseRenewer:hbase@ip-172-31-15-200.ec2.internal:8020, clients=[DFSClient_NONMAPREDUCE_-1516524792_1], created at java.lang.Throwable: TRACE | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:202) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:71) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.get(LeaseRenewer.java:143) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.access$100(LeaseRenewer.java:90) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.getInstance(LeaseRenewer.java:80) | |
| at org.apache.hadoop.hdfs.DFSClient.getLeaseRenewer(DFSClient.java:818) | |
| at org.apache.hadoop.hdfs.DFSClient.beginFileLease(DFSClient.java:824) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1693) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1658) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:493) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:489) | |
| at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem.createNonRecursive(DistributedFileSystem.java:504) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1119) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1095) | |
| at org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter.init(ProtobufLogWriter.java:90) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.createWriter(DefaultWALProvider.java:374) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.createWriterInstance(FSHLog.java:738) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:703) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:610) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.<init>(FSHLog.java:537) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.getWAL(DefaultWALProvider.java:132) | |
| at org.apache.hadoop.hbase.wal.WALFactory.getMetaWAL(WALFactory.java:260) | |
| at org.apache.hadoop.hbase.regionserver.HRegionServer.getWAL(HRegionServer.java:1901) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.openRegion(OpenRegionHandler.java:363) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.process(OpenRegionHandler.java:129) | |
| at org.apache.hadoop.hbase.executor.EventHandler.run(EventHandler.java:129) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| ] hdfs.LeaseRenewer: Lease renewed for client DFSClient_NONMAPREDUCE_-1516524792_1 | |
| 2017-10-30 15:09:47,154 DEBUG [LeaseRenewer:hbase@ip-172-31-15-200.ec2.internal:8020, clients=[DFSClient_NONMAPREDUCE_-1516524792_1], created at java.lang.Throwable: TRACE | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:202) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.<init>(LeaseRenewer.java:71) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.get(LeaseRenewer.java:143) | |
| at org.apache.hadoop.hdfs.LeaseRenewer$Factory.access$100(LeaseRenewer.java:90) | |
| at org.apache.hadoop.hdfs.LeaseRenewer.getInstance(LeaseRenewer.java:80) | |
| at org.apache.hadoop.hdfs.DFSClient.getLeaseRenewer(DFSClient.java:818) | |
| at org.apache.hadoop.hdfs.DFSClient.beginFileLease(DFSClient.java:824) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1693) | |
| at org.apache.hadoop.hdfs.DFSClient.create(DFSClient.java:1658) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:493) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem$8.doCall(DistributedFileSystem.java:489) | |
| at org.apache.hadoop.fs.FileSystemLinkResolver.resolve(FileSystemLinkResolver.java:81) | |
| at org.apache.hadoop.hdfs.DistributedFileSystem.createNonRecursive(DistributedFileSystem.java:504) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1119) | |
| at org.apache.hadoop.fs.FileSystem.createNonRecursive(FileSystem.java:1095) | |
| at org.apache.hadoop.hbase.regionserver.wal.ProtobufLogWriter.init(ProtobufLogWriter.java:90) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.createWriter(DefaultWALProvider.java:374) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.createWriterInstance(FSHLog.java:738) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:703) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.rollWriter(FSHLog.java:610) | |
| at org.apache.hadoop.hbase.regionserver.wal.FSHLog.<init>(FSHLog.java:537) | |
| at org.apache.hadoop.hbase.wal.DefaultWALProvider.getWAL(DefaultWALProvider.java:132) | |
| at org.apache.hadoop.hbase.wal.WALFactory.getMetaWAL(WALFactory.java:260) | |
| at org.apache.hadoop.hbase.regionserver.HRegionServer.getWAL(HRegionServer.java:1901) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.openRegion(OpenRegionHandler.java:363) | |
| at org.apache.hadoop.hbase.regionserver.handler.OpenRegionHandler.process(OpenRegionHandler.java:129) | |
| at org.apache.hadoop.hbase.executor.EventHandler.run(EventHandler.java:129) | |
| at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) | |
| at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) | |
| at java.lang.Thread.run(Thread.java:748) | |
| ] hdfs.LeaseRenewer: Lease renewer daemon for [DFSClient_NONMAPREDUCE_-1516524792_1] with renew id 1 executed |
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment