Re: Compile error in ProspectorExample

2017-10-23 Thread Puja Valiyil 
Hi Fan,
Would you mind making a jira ticket to track this?

On Mon, Oct 23, 2017 at 11:16 AM, Fan Yang  wrote:

> Hi,
>
> I tried to modified the codes of ProspectorExample.java under the package
> of rya.indexing.example to use a real accumulo instance instead of using a
> mock instance. After compiling the codes, I got the error message like this:
>
> Exception in thread "main" java.io.IOException: org.apache.accumulo.core.
> client.AccumuloSecurityException: Error TABLE_DOESNT_EXIST for user
> rya_spo - Unknown security exception
> at org.apache.accumulo.core.client.mapreduce.lib.impl.
> InputConfigurator.validateOptions(InputConfigurator.java:663)
> at org.apache.accumulo.core.client.mapreduce.AbstractInputFormat.
> validateOptions(AbstractInputFormat.java:343)
> at org.apache.accumulo.core.client.mapreduce.
> AbstractInputFormat.getSplits(AbstractInputFormat.java:538)
> at org.apache.hadoop.mapreduce.JobSubmitter.writeNewSplits(
> JobSubmitter.java:493)
> at org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(
> JobSubmitter.java:510)
> at org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(
> JobSubmitter.java:394)
> at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1285)
> at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1282)
> at java.security.AccessController.doPrivileged(Native Method)
> at javax.security.auth.Subject.doAs(Subject.java:422)
> at org.apache.hadoop.security.UserGroupInformation.doAs(
> UserGroupInformation.java:1614)
> at org.apache.hadoop.mapreduce.Job.submit(Job.java:1282)
> at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.
> java:1303)
> at org.apache.rya.prospector.mr.Prospector.run(Prospector.
> java:101)
> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84)
> at ProspectorExample.main(ProspectorExample.java:108)
> Caused by: org.apache.accumulo.core.client.AccumuloSecurityException:
> Error TABLE_DOESNT_EXIST for user rya_spo - Unknown security exception
> at org.apache.accumulo.core.client.mock.
> MockSecurityOperationsImpl.hasTablePermission(MockSecurityOperationsImpl.
> java:124)
> at org.apache.accumulo.core.client.mapreduce.lib.impl.
> InputConfigurator.validateOptions(InputConfigurator.java:646)
> ... 16 more
>
> When I looked up the list of accumulo tables, “rya_spo" did exist and the
> “rya_perspects" was also created but empty. What I did is to modify the
> configuration part of the codes. The modified Java file is attached via
> email. Thank you so much!
>
> Bests,
>
> Fan

Compile error in ProspectorExample

2017-10-23 Thread Fan Yang 
Hi,

I tried to modified the codes of ProspectorExample.java under the package of 
rya.indexing.example to use a real accumulo instance instead of using a mock 
instance. After compiling the codes, I got the error message like this:

Exception in thread "main" java.io.IOException: 
org.apache.accumulo.core.client.AccumuloSecurityException: Error 
TABLE_DOESNT_EXIST for user rya_spo - Unknown security exception
at 
org.apache.accumulo.core.client.mapreduce.lib.impl.InputConfigurator.validateOptions(InputConfigurator.java:663)
at 
org.apache.accumulo.core.client.mapreduce.AbstractInputFormat.validateOptions(AbstractInputFormat.java:343)
at 
org.apache.accumulo.core.client.mapreduce.AbstractInputFormat.getSplits(AbstractInputFormat.java:538)
at 
org.apache.hadoop.mapreduce.JobSubmitter.writeNewSplits(JobSubmitter.java:493)
at 
org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(JobSubmitter.java:510)
at 
org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(JobSubmitter.java:394)
at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1285)
at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1282)
at java.security.AccessController.doPrivileged(Native Method)
at javax.security.auth.Subject.doAs(Subject.java:422)
at 
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1614)
at org.apache.hadoop.mapreduce.Job.submit(Job.java:1282)
at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:1303)
at org.apache.rya.prospector.mr.Prospector.run(Prospector.java:101)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84)
at ProspectorExample.main(ProspectorExample.java:108)
Caused by: org.apache.accumulo.core.client.AccumuloSecurityException: Error 
TABLE_DOESNT_EXIST for user rya_spo - Unknown security exception
at 
org.apache.accumulo.core.client.mock.MockSecurityOperationsImpl.hasTablePermission(MockSecurityOperationsImpl.java:124)
at 
org.apache.accumulo.core.client.mapreduce.lib.impl.InputConfigurator.validateOptions(InputConfigurator.java:646)
... 16 more

When I looked up the list of accumulo tables, “rya_spo" did exist and the 
“rya_perspects" was also created but empty. What I did is to modify the 
configuration part of the codes. The modified Java file is attached via email. 
Thank you so much!

Bests,

Fan