Re: Parallel scanning of snapshots using hbase client api

gt; >> >>> > >> >>> > >>> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1671) >>> > >> >> at >>> org.apache.hadoop.ipc.Server$Handler.run(Server.java:2038) >>> > >> >> >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.util.ModifyRegionUtils.createRegions(ModifyRegionUtils.java:162) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.cloneHdfsRegions(RestoreSnapshotHelper.java:561) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:237) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:159) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.copySnapshotForScanner(RestoreSnapshotHelper.java:812) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.client.TableSnapshotScanner.init(TableSnapshotScanner.java:156) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:124) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:101) >>> > >> >> at >>> > >> >> >>> net.connexity.aro.data.AudienceScanner.join(AudienceScanner.scala:68) >>> > >> >> at >>> > >> >> net.connexity.aro.actor.ScanActor.joinAudience(ScanActor.scala:190) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> net.connexity.aro.actor.ScanActor$$anonfun$receive$1.applyOrElse(ScanActor.scala:90) >>> > >> >> at akka.actor.Actor$class.aroundReceive(Actor.scala:467) >>> > >> >> at >>> > >> >> net.connexity.aro.actor.ScanActor.aroundReceive(ScanActor.scala:36) >>> > >> >> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >>> > >> >> at akka.actor.ActorCell.invoke(ActorCell.scala:487) >>> > >> >> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) >>> > >> >> at akka.dispatch.Mailbox.run(Mailbox.scala:220) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) >>> > >> >> at >>> > >> >> >>> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >>> > >> >> at >>> > >> >> >>> > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >>> > >> >> at >>> > >> >> >>> > >> >> >>> > >> >>> > >>> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >>> > >> >> >>> > >> >> >>> > >> >> >>> > >> >> -- >>> > >> >> View this message in context: >>> > >> >> >>> > >> >>> > >>> http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html >>> > >> >> Sent from the HBase Developer mailing list archive at Nabble.com. >>> > >> >> >>> > >> >>> > >>>

Re: Parallel scanning of snapshots using hbase client api

> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.cloneHdfsRegions(RestoreSnapshotHelper.java:561) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:237) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:159) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.copySnapshotForScanner(RestoreSnapshotHelper.java:812) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.client.TableSnapshotScanner.init(TableSnapshotScanner.java:156) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:124) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:101) >> > >> >> at >> > >> >> >> net.connexity.aro.data.AudienceScanner.join(AudienceScanner.scala:68) >> > >> >> at >> > >> >> net.connexity.aro.actor.ScanActor.joinAudience(ScanActor.scala:190) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> net.connexity.aro.actor.ScanActor$$anonfun$receive$1.applyOrElse(ScanActor.scala:90) >> > >> >> at akka.actor.Actor$class.aroundReceive(Actor.scala:467) >> > >> >> at >> > >> >> net.connexity.aro.actor.ScanActor.aroundReceive(ScanActor.scala:36) >> > >> >> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >> > >> >> at akka.actor.ActorCell.invoke(ActorCell.scala:487) >> > >> >> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) >> > >> >> at akka.dispatch.Mailbox.run(Mailbox.scala:220) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) >> > >> >> at >> > >> >> >> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >> > >> >> at >> > >> >> >> > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >> > >> >> >> > >> >> >> > >> >> >> > >> >> -- >> > >> >> View this message in context: >> > >> >> >> > >> >> > >> http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html >> > >> >> Sent from the HBase Developer mailing list archive at Nabble.com. >> > >> >> >> > >> >> > >>

Re: Parallel scanning of snapshots using hbase client api

gt; >> > > >> >> > > >> > > > org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:159) > > >> >> at > > >> >> > > >> >> > > >> > > > org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.copySnapshotForScanner(RestoreSnapshotHelper.java:812) > > >> >> at > > >> >> > > >> >> > > >> > > > org.apache.hadoop.hbase.client.TableSnapshotScanner.init(TableSnapshotScanner.java:156) > > >> >> at > > >> >> > > >> >> > > >> > > > org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:124) > > >> >> at > > >> >> > > >> >> > > >> > > > org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:101) > > >> >> at > > >> >> > net.connexity.aro.data.AudienceScanner.join(AudienceScanner.scala:68) > > >> >> at > > >> >> net.connexity.aro.actor.ScanActor.joinAudience(ScanActor.scala:190) > > >> >> at > > >> >> > > >> >> > > >> > > > net.connexity.aro.actor.ScanActor$$anonfun$receive$1.applyOrElse(ScanActor.scala:90) > > >> >> at akka.actor.Actor$class.aroundReceive(Actor.scala:467) > > >> >> at > > >> >> net.connexity.aro.actor.ScanActor.aroundReceive(ScanActor.scala:36) > > >> >> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) > > >> >> at akka.actor.ActorCell.invoke(ActorCell.scala:487) > > >> >> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) > > >> >> at akka.dispatch.Mailbox.run(Mailbox.scala:220) > > >> >> at > > >> >> > > >> >> > > >> > > > akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) > > >> >> at > > >> >> > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > > >> >> at > > >> >> > > >> >> > > >> > > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > > >> >> at > > >> >> > > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > > >> >> at > > >> >> > > >> >> > > >> > > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > >> >> > > >> >> > > >> >> > > >> >> -- > > >> >> View this message in context: > > >> >> > > >> > > > http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html > > >> >> Sent from the HBase Developer mailing list archive at Nabble.com. > > >> >> > > >> > > >

Re: Parallel scanning of snapshots using hbase client api

> org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.copySnapshotForScanner(RestoreSnapshotHelper.java:812) > >> >> at > >> >> > >> >> > >> > org.apache.hadoop.hbase.client.TableSnapshotScanner.init(TableSnapshotScanner.java:156) > >> >>

Re: Parallel scanning of snapshots using hbase client api

t; >> >> >> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:101) >> >> at >> >> net.connexity.aro.data.AudienceScanner.join(AudienceScanner.scala:68) >> >> at >> >> net.connexity.aro.actor.ScanActor.joinAudience(ScanActor.scala:190) >> >> at >> >> >> >> >> net.connexity.aro.actor.ScanActor$$anonfun$receive$1.applyOrElse(ScanActor.scala:90) >> >> at akka.actor.Actor$class.aroundReceive(Actor.scala:467) >> >> at >> >> net.connexity.aro.actor.ScanActor.aroundReceive(ScanActor.scala:36) >> >> at akka.actor.ActorCell.receiveMessage(ActorCell.scala:516) >> >> at akka.actor.ActorCell.invoke(ActorCell.scala:487) >> >> at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) >> >> at akka.dispatch.Mailbox.run(Mailbox.scala:220) >> >> at >> >> >> >> >> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) >> >> at >> >> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >> >> at >> >> >> >> >> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >> >> at >> >> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >> >> at >> >> >> >> >> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >> >> >> >> >> >> >> >> -- >> >> View this message in context: >> >> >> http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html >> >> Sent from the HBase Developer mailing list archive at Nabble.com. >> >> >>

Re: Parallel scanning of snapshots using hbase client api

scala:190) > >> at > >> > >> > net.connexity.aro.actor.ScanActor$$anonfun$receive$1.applyOrElse(ScanActor.scala:90) > >> at akka.actor.Actor$class.aroundReceive(Actor.scala:467) > >> at > >> net.connexity.aro.actor.ScanA

Re: Parallel scanning of snapshots using hbase client api

at akka.dispatch.Mailbox.processMailbox(Mailbox.scala:238) >> at akka.dispatch.Mailbox.run(Mailbox.scala:220) >> at >> >> akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397) >> at >> scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) >> at >> >> scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) >> at >> scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) >> at >> >> scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) >> >> >> >> -- >> View this message in context: >> http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html >> Sent from the HBase Developer mailing list archive at Nabble.com. >>

Re: Parallel scanning of snapshots using hbase client api

patcher.scala:397) > at > scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260) > at > > scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339) > at > scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979) > at > > scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) > > > > -- > View this message in context: > http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html > Sent from the HBase Developer mailing list archive at Nabble.com. >

Parallel scanning of snapshots using hbase client api

scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107) -- View this message in context: http://apache-hbase.679495.n3.nabble.com/Parallel-scanning-of-snapshots-using-hbase-client-api-tp4077014.html Sent from the HBase Developer mailing list archive at Nabble.com.