hbase-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From dhamodharan.ramalin...@tcs.com
Subject Unable to fetch data from HBase.
Date Thu, 27 Nov 2014 13:13:22 GMT
Hi,

I am using Hadoop 2.5.1 and HBase 0.98.8-hadoop2 stand-alone mode,  when I 
use the following client side code

public static void main(final String[] args) {

        HTableInterface table = null;

        try {

                final HBaseManager tableManager = 
HBaseManager.getInstance();

                table = tableManager
 .getHTable(HBaseConstants.TABLE_EMP_DETAILS);

                final Scan scan = new Scan();

                final ResultScanner resultScanner = 
table.getScanner(scan);

                for (final Result result : resultScanner) {

                        LOG.debug("The Employee id : "
                                        + 
HBaseHelper.getValueFromResult(result,
 HBaseConstants.COLUME_FAMILY,
 HBaseConstants.EMP_ID));

                        LOG.debug("The Employee Name to id : "
                                        + 
HBaseHelper.getValueFromResult(result,
 HBaseConstants.COLUME_FAMILY,
 HBaseConstants.EMP_NAME));
                }


        } catch (final Exception ex) {
                // TODO Auto-generated catch block
        }
}

When I execute the code I am getting the following error, I have firewall 
disabled for the port. Still I am getting this error.

27 Nov 2014 18:33:01,484 196074 [main] DEBUG 
org.apache.hadoop.ipc.RpcClient  - Connecting to localhost/127.0.0.1:60020
27 Nov 2014 18:33:02,484 197074 [main] DEBUG 
org.apache.hadoop.ipc.RpcClient  - IPC Client (21276817) connection to 
localhost/127.0.0.1:60020 from 394728: closing ipc connection to 
localhost/127.0.0.1:60020: Connection refused: no further information
java.net.ConnectException: Connection refused: no further information
        at sun.nio.ch.SocketChannelImpl.checkConnect(Native Method)
        at sun.nio.ch.SocketChannelImpl.finishConnect(Unknown Source)
        at org.apache.hadoop.net.SocketIOWithTimeout.connect(
SocketIOWithTimeout.java:206)
        at org.apache.hadoop.net.NetUtils.connect(NetUtils.java:529)
        at org.apache.hadoop.net.NetUtils.connect(NetUtils.java:493)
        at 
org.apache.hadoop.hbase.ipc.RpcClient$Connection.setupConnection(
RpcClient.java:578)
        at 
org.apache.hadoop.hbase.ipc.RpcClient$Connection.setupIOstreams(
RpcClient.java:868)
        at org.apache.hadoop.hbase.ipc.RpcClient.getConnection(
RpcClient.java:1543)
        at org.apache.hadoop.hbase.ipc.RpcClient.call(RpcClient.java:1442)
        at org.apache.hadoop.hbase.ipc.RpcClient.callBlockingMethod(
RpcClient.java:1661)
        at 
org.apache.hadoop.hbase.ipc.RpcClient$BlockingRpcChannelImplementation.callBlockingMethod(
RpcClient.java:1719)
        at 
org.apache.hadoop.hbase.protobuf.generated.ClientProtos$ClientService$BlockingStub.get(
ClientProtos.java:30363)
        at org.apache.hadoop.hbase.protobuf.ProtobufUtil.getRowOrBefore(
ProtobufUtil.java:1546)
        at org.apache.hadoop.hbase.client.HTable$2.call(HTable.java:717)
        at org.apache.hadoop.hbase.client.HTable$2.call(HTable.java:715)
        at 
org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithRetries(
RpcRetryingCaller.java:117)
        at org.apache.hadoop.hbase.client.HTable.getRowOrBefore(
HTable.java:721)
        at org.apache.hadoop.hbase.client.MetaScanner.metaScan(
MetaScanner.java:144)
        at 
org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.prefetchRegionCache(
HConnectionManager.java:1140)
        at 
org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegionInMeta(
HConnectionManager.java:1202)
        at 
org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(
HConnectionManager.java:1092)
        at 
org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.locateRegion(
HConnectionManager.java:1049)
        at 
org.apache.hadoop.hbase.client.HConnectionManager$HConnectionImplementation.getRegionLocation(
HConnectionManager.java:890)
        at org.apache.hadoop.hbase.client.RegionServerCallable.prepare(
RegionServerCallable.java:72)
        at org.apache.hadoop.hbase.client.ScannerCallable.prepare(
ScannerCallable.java:125)
        at 
org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithRetries(
RpcRetryingCaller.java:116)
        at 
org.apache.hadoop.hbase.client.RpcRetryingCaller.callWithRetries(
RpcRetryingCaller.java:93)
        at org.apache.hadoop.hbase.client.ClientScanner.nextScanner(
ClientScanner.java:283)
        at 
org.apache.hadoop.hbase.client.ClientScanner.initializeScannerInConstruction(
ClientScanner.java:188)
        at org.apache.hadoop.hbase.client.ClientScanner.<init>(
ClientScanner.java:183)
        at org.apache.hadoop.hbase.client.ClientScanner.<init>(
ClientScanner.java:110)
        at org.apache.hadoop.hbase.client.HTable.getScanner(
HTable.java:745)
        at 
org.apache.hadoop.hbase.client.HTablePool$PooledHTable.getScanner(
HTablePool.java:417)
        at com.opt.assortment.dao.impl.CallHBase.main(CallHBase.java:57)

Any suggestion or help is deeply appricated,

Thanks & Regards
Dhamodharan Ramalingam
=====-----=====-----=====
Notice: The information contained in this e-mail
message and/or attachments to it may contain 
confidential or privileged information. If you are 
not the intended recipient, any dissemination, use, 
review, distribution, printing or copying of the 
information contained in this e-mail message 
and/or attachments to it are strictly prohibited. If 
you have received this communication in error, 
please notify us by reply e-mail or telephone and 
immediately and permanently delete the message 
and any attachments. Thank you



Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message