You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@accumulo.apache.org by David Medinets <da...@gmail.com> on 2012/01/06 18:31:42 UTC

TApplicationException running example in README.shard

If someone confirms this is a bug, I'll make a JIRA ticket. I was
following the shard example, but when I used by own terms an exception
occured.

export ACCUMULO_HOME=/home/ubuntu/accumulo-1.5.0-incubating-SNAPSHOT
export AINSTANCE=development
export AZOOKEEPERS=localhost
export AUSER=root
export APASSWORD=password
export EXAMPLE_PACKAGE=org.apache.accumulo.examples

# create accumulo tables
bin/accumulo shell -u $AUSER -p $APASSWORD
> createtable shard
shard> createtable doc2term
doc2term> exit

# index some files
cd $ACCUMULO_HOME
export SHARD_TABLE=shard
export NUM_PARTITIONS=30
find src -name "*.java" | xargs bin/accumulo
$EXAMPLE_PACKAGE.shard.Index $AINSTANCE $AZOOKEEPERS $SHARD_TABLE
$AUSER $APASSWORD $NUM_PARTITIONS

export TERMS_TO_FIND="foo bar"
bin/accumulo $EXAMPLE_PACKAGE.shard.Query $AINSTANCE $AZOOKEEPERS
$SHARD_TABLE $AUSER $APASSWORD $TERMS_TO_FIND

#####
# Everything worked up to this point. But then I tried a different term.

$ bin/accumulo $EXAMPLE_PACKAGE.shard.Query $AINSTANCE $AZOOKEEPERS
$SHARD_TABLE $AUSER $APASSWORD RowDeleteTest

06 12:24:45,974 [impl.TabletServerBatchReaderIterator] WARN : Error on
server 127.0.0.1:9997
org.apache.accumulo.core.client.impl.AccumuloServerException: Error on
server 127.0.0.1:9997
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:579)
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:335)
	at cloudtrace.instrument.TraceRunnable.run(TraceRunnable.java:47)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
	at java.lang.Thread.run(Thread.java:722)
Caused by: org.apache.thrift.TApplicationException: Internal error
processing startMultiScan
	at org.apache.thrift.TApplicationException.read(TApplicationException.java:108)
	at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:298)
	at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:274)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:601)
	at cloudtrace.instrument.thrift.TraceWrap$2.invoke(TraceWrap.java:83)
	at $Proxy1.startMultiScan(Unknown Source)
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:539)
	... 5 more
Thread "org.apache.accumulo.examples.shard.Query" died null
java.lang.reflect.InvocationTargetException
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:601)
	at org.apache.accumulo.start.Main$1.run(Main.java:89)
	at java.lang.Thread.run(Thread.java:722)
Caused by: java.lang.RuntimeException:
org.apache.accumulo.core.client.impl.AccumuloServerException: Error on
server 127.0.0.1:9997
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.hasNext(TabletServerBatchReaderIterator.java:188)
	at org.apache.accumulo.examples.shard.Query.main(Query.java:69)
	... 6 more
Caused by: org.apache.accumulo.core.client.impl.AccumuloServerException:
Error on server 127.0.0.1:9997
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:579)
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:335)
	at cloudtrace.instrument.TraceRunnable.run(TraceRunnable.java:47)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
	... 1 more
Caused by: org.apache.thrift.TApplicationException: Internal error
processing startMultiScan
	at org.apache.thrift.TApplicationException.read(TApplicationException.java:108)
	at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:298)
	at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:274)
	at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
	at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
	at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
	at java.lang.reflect.Method.invoke(Method.java:601)
	at cloudtrace.instrument.thrift.TraceWrap$2.invoke(TraceWrap.java:83)
	at $Proxy1.startMultiScan(Unknown Source)
	at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:539)
	... 5 more

Did I do something wrong?

Re: TApplicationException running example in README.shard

Posted by Keith Turner <ke...@deenlo.com>.
I think the intersecting iterator expects at least two terms.
Unfortunately it is not complaining about this until the iterator
tries to execute on the server side.  This is definitely an issue.  I
think the IntersectingIterator static methods called by the client for
configuration should throw an exception, then it would fail much
faster/earlier and in an easier to debug way.

On Fri, Jan 6, 2012 at 12:31 PM, David Medinets
<da...@gmail.com> wrote:
> If someone confirms this is a bug, I'll make a JIRA ticket. I was
> following the shard example, but when I used by own terms an exception
> occured.
>
> export ACCUMULO_HOME=/home/ubuntu/accumulo-1.5.0-incubating-SNAPSHOT
> export AINSTANCE=development
> export AZOOKEEPERS=localhost
> export AUSER=root
> export APASSWORD=password
> export EXAMPLE_PACKAGE=org.apache.accumulo.examples
>
> # create accumulo tables
> bin/accumulo shell -u $AUSER -p $APASSWORD
>> createtable shard
> shard> createtable doc2term
> doc2term> exit
>
> # index some files
> cd $ACCUMULO_HOME
> export SHARD_TABLE=shard
> export NUM_PARTITIONS=30
> find src -name "*.java" | xargs bin/accumulo
> $EXAMPLE_PACKAGE.shard.Index $AINSTANCE $AZOOKEEPERS $SHARD_TABLE
> $AUSER $APASSWORD $NUM_PARTITIONS
>
> export TERMS_TO_FIND="foo bar"
> bin/accumulo $EXAMPLE_PACKAGE.shard.Query $AINSTANCE $AZOOKEEPERS
> $SHARD_TABLE $AUSER $APASSWORD $TERMS_TO_FIND
>
> #####
> # Everything worked up to this point. But then I tried a different term.
>
> $ bin/accumulo $EXAMPLE_PACKAGE.shard.Query $AINSTANCE $AZOOKEEPERS
> $SHARD_TABLE $AUSER $APASSWORD RowDeleteTest
>
> 06 12:24:45,974 [impl.TabletServerBatchReaderIterator] WARN : Error on
> server 127.0.0.1:9997
> org.apache.accumulo.core.client.impl.AccumuloServerException: Error on
> server 127.0.0.1:9997
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:579)
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:335)
>        at cloudtrace.instrument.TraceRunnable.run(TraceRunnable.java:47)
>        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>        at java.lang.Thread.run(Thread.java:722)
> Caused by: org.apache.thrift.TApplicationException: Internal error
> processing startMultiScan
>        at org.apache.thrift.TApplicationException.read(TApplicationException.java:108)
>        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:298)
>        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:274)
>        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>        at java.lang.reflect.Method.invoke(Method.java:601)
>        at cloudtrace.instrument.thrift.TraceWrap$2.invoke(TraceWrap.java:83)
>        at $Proxy1.startMultiScan(Unknown Source)
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:539)
>        ... 5 more
> Thread "org.apache.accumulo.examples.shard.Query" died null
> java.lang.reflect.InvocationTargetException
>        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>        at java.lang.reflect.Method.invoke(Method.java:601)
>        at org.apache.accumulo.start.Main$1.run(Main.java:89)
>        at java.lang.Thread.run(Thread.java:722)
> Caused by: java.lang.RuntimeException:
> org.apache.accumulo.core.client.impl.AccumuloServerException: Error on
> server 127.0.0.1:9997
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.hasNext(TabletServerBatchReaderIterator.java:188)
>        at org.apache.accumulo.examples.shard.Query.main(Query.java:69)
>        ... 6 more
> Caused by: org.apache.accumulo.core.client.impl.AccumuloServerException:
> Error on server 127.0.0.1:9997
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:579)
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator$QueryTask.run(TabletServerBatchReaderIterator.java:335)
>        at cloudtrace.instrument.TraceRunnable.run(TraceRunnable.java:47)
>        at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1110)
>        at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:603)
>        ... 1 more
> Caused by: org.apache.thrift.TApplicationException: Internal error
> processing startMultiScan
>        at org.apache.thrift.TApplicationException.read(TApplicationException.java:108)
>        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.recv_startMultiScan(TabletClientService.java:298)
>        at org.apache.accumulo.core.tabletserver.thrift.TabletClientService$Client.startMultiScan(TabletClientService.java:274)
>        at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
>        at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57)
>        at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
>        at java.lang.reflect.Method.invoke(Method.java:601)
>        at cloudtrace.instrument.thrift.TraceWrap$2.invoke(TraceWrap.java:83)
>        at $Proxy1.startMultiScan(Unknown Source)
>        at org.apache.accumulo.core.client.impl.TabletServerBatchReaderIterator.doLookup(TabletServerBatchReaderIterator.java:539)
>        ... 5 more
>
> Did I do something wrong?