|
|
-
MockInstance usage not working...?Jason Trost 2012-02-27, 22:19
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) |