Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
Received-SPF: pass (athena.apache.org: domain of vboylin1987@gmail.com
 designates 209.85.192.170 as permitted sender)
MIME-Version: 1.0
Date: Wed, 4 Dec 2013 00:22:17 +0800
Message-ID: 
 <CAKxYK2G58DM6ib12Ae_zM9+sNN4YHXqj=mNazc+MRuN9HWU90w@mail.gmail.com>
Subject: Strange Problem on using HRegion's getScanner Method in RegionServer
From: Wukang Lin <vboylin1987@gmail.com>
To: user@hbase.apache.org
Content-Type: multipart/alternative; boundary=047d7b10ccb53487f704eca3b35e

--047d7b10ccb53487f704eca3b35e
Content-Type: text/plain; charset=ISO-8859-1

Hi all,
    I got a trouble in using HRegion's RegionScanner in RegionServer.
    In my project, a custom RPC server was started in RegionServer using
coprocessor mechanism, and it work well. In this RPC server, it receive a
call from client, and scan the HRegion specialised by the params setted by
the client like this:
---------------------------------------------------------------------------------------------------------------------
HRegion region = this.getHRegionByEncodeName(encodeName);

Scan scan = new Scan();
RegionScanner scanner = null;
try {
      scanner = region.getScanner(scan);
      long total = 0;
      boolean hasNext = true;
      List<KeyValue> kvs = new ArrayList<KeyValue>();
      while (hasNext) {
          kvs.clear();
          hasNext = scanner.next(kvs);
          if (kvs.size() > 0) {
              total++;
           }
      } catch (IOException e) {
           LOG.warn("Exception thrown when scanning region '" + regionName
+ "', SKIP IT!", e);
      } finally {

              if (scanner != null) {
                   try {
                        scanner.close();
                   } catch (IOException e) {
                         e.printStackTrace();
                   }
             }
       }
       LOG.info("Total " + total + " rows scanned.");
---------------------------------------------------------------------------------------------------------------------
Then, I put a row to a HRegion by HTable interface, and make an RPC call of
my custom RPC server to scan the HRegion(the code lines above is executed
in a HRegionServer, a HRegion is scanned), and got nothing, total = 0. But
if I use client side scan like HTable's scan interface or HBase shell, I
can get the row I insert just now. I tried to flush the region and do a
major compaction on the HRegion using hbase shell, Nothing changed.
So, what's wrong with the code above? how to scan a HRegion in
HRegionServer instance?
Any responses is Appreciated!

--047d7b10ccb53487f704eca3b35e--