Re: Parallel scanning of snapshots using hbase client api

2016-03-03 Thread Deepti Bhogle
Information.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

2016-01-08 Thread Deepti Bhogle
; >> >> > >> org.apache.hadoop.hbase.util.ModifyRegionUtils.createRegions(ModifyRegionUtils.java:162) >> > >> >> at >> > >> >> >> > >> >> >> > >> >> > >> org.apache.hadoop.hbase.snaps

Re: Parallel scanning of snapshots using hbase client api

2016-01-08 Thread Matteo Bertozzi
hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSnapshotHelper.java:237) > > >> >> at > > >> >> > > >> >> > > >> > > > org.apache.hadoop.hbase.snapshot.RestoreSnapshotHelper.restoreHdfsRegions(RestoreSna

Re: Parallel scanning of snapshots using hbase client api

2016-01-08 Thread Enis Söztutar
; > >> > 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

2016-01-07 Thread Deepti Bhogle
ase.client.TableSnapshotScanner.(TableSnapshotScanner.java:124) >> >> at >> >> >> >> >> org.apache.hadoop.hbase.client.TableSnapshotScanner.(TableSnapshotScanner.java:101) >> >> at >> >> net.connexity.aro.data.Audie

Re: Parallel scanning of snapshots using hbase client api

2016-01-07 Thread Enis Söztutar
ask.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.runW

Re: Parallel scanning of snapshots using hbase client api

2016-01-07 Thread Deepti Bhogle
iveMessage(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

2016-01-07 Thread Ted Yu
ctor.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. > >> >

Parallel scanning of snapshots using hbase client api

2016-01-06 Thread dbhogle
) 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.