Return-Path: X-Original-To: apmail-incubator-accumulo-user-archive@minotaur.apache.org Delivered-To: apmail-incubator-accumulo-user-archive@minotaur.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id AFDBD9E38 for ; Tue, 28 Feb 2012 01:50:26 +0000 (UTC) Received: (qmail 94593 invoked by uid 500); 28 Feb 2012 01:50:26 -0000 Delivered-To: apmail-incubator-accumulo-user-archive@incubator.apache.org Received: (qmail 94572 invoked by uid 500); 28 Feb 2012 01:50:26 -0000 Mailing-List: contact accumulo-user-help@incubator.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: accumulo-user@incubator.apache.org Delivered-To: mailing list accumulo-user@incubator.apache.org Received: (qmail 94564 invoked by uid 99); 28 Feb 2012 01:50:26 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Feb 2012 01:50:26 +0000 X-ASF-Spam-Status: No, hits=1.5 required=5.0 tests=HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: local policy) Received: from [206.112.75.239] (HELO iron-u-b-out.osis.gov) (206.112.75.239) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 28 Feb 2012 01:50:21 +0000 X-IronPort-Anti-Spam-Filtered: true X-IronPort-Anti-Spam-Result: Am0FAPAxTE+sEAbx/2dsb2JhbABDs3yBD4FzAQEBAwESAmoLCws7IQETBR0ZCBqHX6JLCpVwBIkPhABTGYRnHhMDMgcaDQuDLQSIT4xuixeHdQ X-IronPort-AV: E=Sophos;i="4.73,494,1325480400"; d="scan'208";a="8640660" Received: from ghost-a.center.osis.gov (HELO mail-pw0-f47.google.com) ([172.16.6.241]) by iron-u-b-in.osis.gov with ESMTP/TLS/RC4-SHA; 27 Feb 2012 20:48:41 -0500 Received: by pbbrp12 with SMTP id rp12so3350401pbb.6 for ; Mon, 27 Feb 2012 17:49:55 -0800 (PST) Received-SPF: pass (google.com: domain of john.w.vines@ugov.gov designates 10.68.223.199 as permitted sender) client-ip=10.68.223.199; Authentication-Results: mr.google.com; spf=pass (google.com: domain of john.w.vines@ugov.gov designates 10.68.223.199 as permitted sender) smtp.mail=john.w.vines@ugov.gov Received: from mr.google.com ([10.68.223.199]) by 10.68.223.199 with SMTP id qw7mr17221934pbc.79.1330393795352 (num_hops = 1); Mon, 27 Feb 2012 17:49:55 -0800 (PST) MIME-Version: 1.0 Received: by 10.68.223.199 with SMTP id qw7mr14396789pbc.79.1330393795338; Mon, 27 Feb 2012 17:49:55 -0800 (PST) Received: by 10.68.141.14 with HTTP; Mon, 27 Feb 2012 17:49:55 -0800 (PST) Received: by 10.68.141.14 with HTTP; Mon, 27 Feb 2012 17:49:55 -0800 (PST) In-Reply-To: <1391871014.100057.1330381226709.JavaMail.root@linzimmb04o.imo.intelink.gov> References: <1391871014.100057.1330381226709.JavaMail.root@linzimmb04o.imo.intelink.gov> Date: Mon, 27 Feb 2012 20:49:55 -0500 Message-ID: Subject: Re: MockInstance usage not working...? From: John Vines To: accumulo-user@incubator.apache.org Content-Type: multipart/alternative; boundary=047d7b16334d951fd204b9fc7149 X-Virus-Checked: Checked by ClamAV on apache.org --047d7b16334d951fd204b9fc7149 Content-Type: text/plain; charset=ISO-8859-1 I'm not near a computer so I cannot verify, but it looks like you are missing libraries? Make sure you build the project once so maven pulls in the dependencies. John Sent from my phone, so pardon the typos and brevity. On Feb 27, 2012 5:20 PM, "Jason Trost" wrote: > 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 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) > --047d7b16334d951fd204b9fc7149 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable

I'm not near a computer so I cannot verify, but it looks like you ar= e missing libraries? Make sure you build the project once so maven pulls in= the dependencies.

John

Sent from my phone, so pardon the typos and brevity.

On Feb 27, 2012 5:20 PM, "Jason Trost"= <jason.trost@gmail.com>= wrote:
Any idea why this doesn't work (see code and stack trace below)? =A0I a= m
using accumulo trunk. =A0This problem only occurs when I use a Scanner
or BatchScanner. =A0If I comment out the scanning section there are no
errors.

Thanks,

--Jason

Java code (ht= tps://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 {

=A0 =A0 =A0 =A0public static void main(String[] args) throws Exception { =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0String table =3D "data";
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0String user =3D "root";
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Instance inst =3D new MockInstance("in= st");
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Connector conn =3D inst.getConnector(user, = "secret");
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0conn.securityOperations().changeUserAuthori= zations(user, new
Authorizations("auth"));
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Authorizations auths =3D conn.securityOpera= tions().getUserAuthorizations(user);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0conn.tableOperations().create(table);

=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0System.out.println("Ingesting data ...= ");
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0BatchWriter wr =3D conn.createBatchWriter(t= able, 10000000, 10000, 5);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0for(int i =3D 0; i < 1000; ++i)
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0{
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Mutation m =3D new Mutation= ("row_"+i);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0m.put("cf_"+i, &q= uot;cq_"+1, "val_"+1);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0wr.addMutation(m);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0wr.close();

=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0System.out.println("Reading data ...&q= uot;);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0Scanner s =3D conn.createScanner(table, aut= hs);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0for(Entry<Key, Value> e : s)
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0{
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0System.out.println(e);
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
=A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0System.out.println("Done");
=A0 =A0 =A0 =A0}
}

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

Ingesting data ...
Reading data ...
Exception in thread
"org.apache.accumulo.start.classloader.AccumuloFilesystemAlterationMon= itor"
java.lang.NullPointerException
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$MonitorFileImpl.listFiles(FilesystemAlterationObserverImpl.java:64)=
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:119)
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203) =A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203) =A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203) =A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.compareChilds(FilesystemAlterationObserverImpl.java:137)
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl$Entry.needsToBeDeleted(FilesystemAlterationObserverImpl.java:203) =A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl.checkEntries(FilesystemAlterationObserverImpl.java:317)
=A0 =A0 =A0 =A0at org.apache.commons.jci.monitor.FilesystemAlterationObser= verImpl.checkAndNotify(FilesystemAlterationObserverImpl.java:331)
=A0 =A0 =A0 =A0at org.apache.accumulo.start.classloader.AccumuloFilesystem= AlterationMonitor.run(AccumuloFilesystemAlterationMonitor.java:121)
=A0 =A0 =A0 =A0at java.lang.Thread.run(Thread.java:722)
--047d7b16334d951fd204b9fc7149--