Home | About | Sematext search-lucene.com search-hadoop.com
 Search Hadoop and all its subprojects:

Switch to Threaded View
Accumulo >> mail # user >> MockInstance usage not working...?


Copy link to this message
-
MockInstance usage not working...?
Any idea why this doesn't work (see code and stack trace below)?  I am
using accumulo trunk.  This problem only occurs when I use a Scanner
or BatchScanner.  If I comment out the scanning section there are no
errors.

Thanks,

--Jason

Java code (https://gist.github.com/1927202)

package accumulo;

import java.util.Map.Entry;

import org.apache.accumulo.core.client.BatchWriter;
import org.apache.accumulo.core.client.Connector;
import org.apache.accumulo.core.client.Instance;
import org.apache.accumulo.core.client.Scanner;
import org.apache.accumulo.core.client.mock.MockInstance;
import org.apache.accumulo.core.data.Key;
import org.apache.accumulo.core.data.Mutation;
import org.apache.accumulo.core.data.Value;
import org.apache.accumulo.core.security.Authorizations;

public class Mock {

public static void main(String[] args) throws Exception {
String table = "data";
String user = "root";
Instance inst = new MockInstance("inst");
Connector conn = inst.getConnector(user, "secret");
conn.securityOperations().changeUserAuthorizations(user, new
Authorizations("auth"));
Authorizations auths = conn.securityOperations().getUserAuthorizations(user);
conn.tableOperations().create(table);

System.out.println("Ingesting data ...");
BatchWriter wr = conn.createBatchWriter(table, 10000000, 10000, 5);
for(int i = 0; i < 1000; ++i)
{
Mutation m = new Mutation("row_"+i);
m.put("cf_"+i, "cq_"+1, "val_"+1);
wr.addMutation(m);
}
wr.close();

System.out.println("Reading data ...");
Scanner s = conn.createScanner(table, auths);
for(Entry<Key, Value> e : s)
{
System.out.println(e);
}
System.out.println("Done");
}
}

stack trace (https://gist.github.com/1927225)

Ingesting data ...
Reading data ...
Exception in thread
"org.apache.accumulo.start.classloader.AccumuloFilesystemAlterationMonitor"
java.lang.NullPointerException
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$MonitorFileImpl.listFiles(FilesystemAlterationObserverImpl.java:64)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:119)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl.checkEntries(FilesystemAlterationObserverImpl.java:317)
at org.apache.commons.jci.monitor.FilesystemAlterationObserverImpl.checkAndNotify(FilesystemAlterationObserverImpl.java:331)
at org.apache.accumulo.start.classloader.AccumuloFilesystemAlterationMonitor.run(AccumuloFilesystemAlterationMonitor.java:121)
at java.lang.Thread.run(Thread.java:722)