10

我开始使用StumbleUpon 的asynchbase库，但在持续异步扫描时遇到了一些问题。根据我对库原理的理解，我编写了这段代码：

public class AsyncScanner
    implements Callback<Object, ArrayList<ArrayList<KeyValue>>> {
    private final Scanner scan;

    public AsyncScanner(Scanner scan) {
        this.scan = scan;
    }

    public void start() {
        scan.nextRows().addCallback(this);
    }

    @Override
    public Object call(ArrayList<ArrayList<KeyValue>> rows) throws Exception {
        if (rows == null) {
            return null;
        }
        // some useful things here
        scan.nextRows().addCallback(this);
        return null;
    }
}

但是在大扫描中使用此代码时，我得到了 StackOverflowError：

java.lang.StackOverflowError
    at java.util.concurrent.atomic.AtomicIntegerFieldUpdater$AtomicIntegerFieldUpdaterImpl.compareAndSet(AtomicIntegerFieldUpdater.java:279)
    at com.stumbleupon.async.Deferred.casState(Deferred.java:580)
    at com.stumbleupon.async.Deferred.access$100(Deferred.java:430)
    at com.stumbleupon.async.Deferred$Continue.call(Deferred.java:1342)
    at com.stumbleupon.async.Deferred.doCall(Deferred.java:1262)
    at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1241)
    at com.stumbleupon.async.Deferred.access$300(Deferred.java:430)
    at com.stumbleupon.async.Deferred$Continue.call(Deferred.java:1350)
    at com.stumbleupon.async.Deferred.doCall(Deferred.java:1262)
    at com.stumbleupon.async.Deferred.runCallbacks(Deferred.java:1241)
    at com.stumbleupon.async.Deferred.access$300(Deferred.java:430)
    at com.stumbleupon.async.Deferred$Continue.call(Deferred.java:1350)
    <--cut-->

我试图找到一些使用 asynchbase 继续扫描的工作示例。OpenTSDB 使用scanner.nextRows().joinUninterruptibly(). 来自HBase svn的这段代码，看起来像我的：

    @Override
    void testTimed() {
          scanner.nextRows()
            .addCallback(continueScan)
            .addCallbacks(callback, errback);
        }

此外，在异步文档中有这样的短语：

你不能建立一个相互依赖的延迟循环，因为这会导致无限递归（谢天谢地，它会很快失败并出现 StackOverflowError）

但我认为，这不是我的情况。

我打算跟踪 asynchbase 以找出我的代码有什么问题，但是如果有人可以向我展示持续扫描的工作示例，那将非常有帮助。

更新： 当您发布一段代码而没有错误时，这是​​一个尴尬的时刻。问题出在来电者身上。我需要进行一次扫描结束退出。我写：

   Scanner scanner = hclient.newScanner(TABLE);
   <!--cut some initialization--!>
   new AsyncScanner(scanner).start();
   hclient.shutdown().joinUninterruptibly();

而这shutdown()在扫描时才是真正的问题。如果shutdown()在扫描完成后删除或调用，一切正常。

很抱歉可能会浪费您的时间。

4

1 回答 1

0

更新副本：当您发布一段代码时没有错误的尴尬时刻。问题出在来电者身上。我需要进行一次扫描结束退出。我写：

Scanner scanner = hclient.newScanner(TABLE);
<!--cut some initialization--!>
new AsyncScanner(scanner).start();
hclient.shutdown().joinUninterruptibly();

扫描时的这个 shutdown() 是真正的问题。如果在扫描完成后删除或调用了 shutdown()，则一切正常。

很抱歉可能会浪费您的时间

于 2014-10-16T21:28:48.213 回答