Hey John,
Could you give an example of one of the ranges you are using which causes
this to happen?
On Fri, Aug 22, 2014 at 11:02 PM, John Yost <soozandjohny...@gmail.com>
wrote:
> Hey Everyone,
>
> The AccumuloMultiTableInputFormat is an awesome addition to the Accumulo
> API and I am really excited to start using it.
>
> My first attempt with the 1.6.0 release resulted in this
> IllegalStateException:
>
> java.lang.IllegalStateException: The table query configurations could not
> be deserialized from the given configuration
>
> at
> org.apache.accumulo.core.client.mapreduce.lib.impl.InputConfigurator.getInputTableConfigs(InputConfigurator.java:566)
>
> at
> org.apache.accumulo.core.client.mapreduce.lib.impl.InputConfigurator.validateOptions(InputConfigurator.java:628)
>
> at
> org.apache.accumulo.core.client.mapreduce.AbstractInputFormat.validateOptions(AbstractInputFormat.java:342)
>
> at
> org.apache.accumulo.core.client.mapreduce.AbstractInputFormat.getSplits(AbstractInputFormat.java:537)
>
> at
> org.apache.hadoop.mapreduce.JobSubmitter.writeSplits(JobSubmitter.java:508)
>
> at
> org.apache.hadoop.mapreduce.JobSubmitter.submitJobInternal(JobSubmitter.java:392)
>
> at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1268)
>
> at org.apache.hadoop.mapreduce.Job$10.run(Job.java:1265)
>
> at java.security.AccessController.doPrivileged(Native Method)
>
> at javax.security.auth.Subject.doAs(Subject.java:415)
>
> at
> org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1491)
>
> at org.apache.hadoop.mapreduce.Job.submit(Job.java:1265)
>
> at org.apache.hadoop.mapreduce.Job.waitForCompletion(Job.java:1286)
>
> at
> com.johnyostanalytics.mapreduce.client.TwitterJoin.run(TwitterJoin.java:104)
>
> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:70)
>
> at org.apache.hadoop.util.ToolRunner.run(ToolRunner.java:84)
>
> when I attempt to initialize the AccumuloMultiTableInputFormat:
>
> InputTableConfig baseConfig = new InputTableConfig();
> baseConfig.setRanges(ranges);
>
> InputTableConfig edgeConfig = new InputTableConfig();
> edgeConfig.setRanges(ranges);
> configs.put("base", baseConfig);
> configs.put("edges",edgeConfig);
>
> AccumuloMultiTableInputFormat.setInputTableConfigs(job, configs);
>
> Any ideas as to what may be going on? I know that the table names are
> valid and that the Range objects are valid because I tested all of that
> independently via Accumulo scans.
>
> Any guidance is greatly appreciated because, again,
> AcumuloMultiTableInputFormat is really cool and I am really looking forward
> to using it.
>
> Thanks
>
> --John
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
>
