From user-return-2175-apmail-accumulo-user-archive=accumulo.apache.org@accumulo.apache.org Thu Apr 4 13:34:07 2013 Return-Path: X-Original-To: apmail-accumulo-user-archive@www.apache.org Delivered-To: apmail-accumulo-user-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 1A5F5F94F for ; Thu, 4 Apr 2013 13:34:07 +0000 (UTC) Received: (qmail 77638 invoked by uid 500); 4 Apr 2013 13:34:06 -0000 Delivered-To: apmail-accumulo-user-archive@accumulo.apache.org Received: (qmail 77270 invoked by uid 500); 4 Apr 2013 13:34:03 -0000 Mailing-List: contact user-help@accumulo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: user@accumulo.apache.org Delivered-To: mailing list user@accumulo.apache.org Received: (qmail 77252 invoked by uid 99); 4 Apr 2013 13:34:02 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Apr 2013 13:34:02 +0000 X-ASF-Spam-Status: No, hits=1.7 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,HTML_MESSAGE,RCVD_IN_DNSWL_LOW,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of aji1705@gmail.com designates 209.85.215.41 as permitted sender) Received: from [209.85.215.41] (HELO mail-la0-f41.google.com) (209.85.215.41) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 04 Apr 2013 13:33:56 +0000 Received: by mail-la0-f41.google.com with SMTP id fo12so2494068lab.28 for ; Thu, 04 Apr 2013 06:33:35 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=mime-version:x-received:in-reply-to:references:date:message-id :subject:from:to:content-type; bh=DE4dt6DVC95xUpuSZa3FaP6TBVV5+yM+xGtQxa3Zevk=; b=m0SJD5Bu++3YNsMPbctnua/YS2h6PgxGdvWKC3yYkzgIEfGmuXL+ih6Kqi/Q/OKZQn rbWe39550XJtKNOGaVFUNvpSHpm2DzPWhkUT0z+9/9DBwZ3HP+/eMhS9yzR7laFg+jJx ojFNXMMj3L72YGuqkHlDnnCVh8jCleHpQyupT329I/XqrYqCIZcj+H2dSNrRuBMF3sre 9V4WXcNSFjGBWGbcUbqPcpPTRC69KZhNI60YEARRD+qkJjR94bgrWRlIxgQHXe5AKLBF tzmKmmQrxtqllmt4WeStzyjGkg9V4Qvv+1TjNJs7nyIIX8kKt6W8CJsyx+od8YyJN3aN lLYw== MIME-Version: 1.0 X-Received: by 10.112.100.166 with SMTP id ez6mr3496234lbb.86.1365082415762; Thu, 04 Apr 2013 06:33:35 -0700 (PDT) Received: by 10.112.157.225 with HTTP; Thu, 4 Apr 2013 06:33:35 -0700 (PDT) In-Reply-To: References: Date: Thu, 4 Apr 2013 09:33:35 -0400 Message-ID: Subject: Re: importdirectory in accumulo From: Aji Janis To: user Content-Type: multipart/alternative; boundary=14dae9d7121e7b1b2204d98904d1 X-Virus-Checked: Checked by ClamAV on apache.org --14dae9d7121e7b1b2204d98904d1 Content-Type: text/plain; charset=ISO-8859-1 I am not sure its just a regular expression issue. Below is my console output. Not sure why this ClassDefFoundError occurs. Has anyone tried to do it successfully? Can you please tell me your env set up if you did. [user@mynode bulk]$ pwd /home/user/bulk [user@mynode bulk]$ ls BulkIngestExample.java GenerateTestData.java SetupTable.java test_1.txt VerifyIngest.java [user@mynode bulk]$ *[user@mynode bulk]$ /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-1.4.2.jar org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myinstance zookeepers user pswd tableName inputDir tmp/bulkWork* Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/accumulo/core/client/Instance at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.hadoop.util.RunJar.main(RunJar.java:149) Caused by: java.lang.ClassNotFoundException: org.apache.accumulo.core.client.Instance at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:423) at java.lang.ClassLoader.loadClass(ClassLoader.java:356) ... 3 more *[user@mynode bulk]$ /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^cs].jar org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myinstance zookeepers user pswd tableName inputDir tmp/bulkWork* Exception in thread "main" java.lang.NoClassDefFoundError: org/apache/accumulo/core/client/Instance at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.hadoop.util.RunJar.main(RunJar.java:149) Caused by: java.lang.ClassNotFoundException: org.apache.accumulo.core.client.Instance at java.net.URLClassLoader$1.run(URLClassLoader.java:366) at java.net.URLClassLoader$1.run(URLClassLoader.java:355) at java.security.AccessController.doPrivileged(Native Method) at java.net.URLClassLoader.findClass(URLClassLoader.java:354) at java.lang.ClassLoader.loadClass(ClassLoader.java:423) at java.lang.ClassLoader.loadClass(ClassLoader.java:356) ... 3 more *[user@mynode bulk]$ /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^c].jar org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myinstance zookeepers user pswd tableName inputDir tmp/bulkWork* Exception in thread "main" java.lang.ClassNotFoundException: /opt/accumulo/lib/examples-simple-1/4/2-sources/jar at java.lang.Class.forName0(Native Method) at java.lang.Class.forName(Class.java:264) at org.apache.hadoop.util.RunJar.main(RunJar.java:149) [user@mynode bulk]$ On Wed, Apr 3, 2013 at 4:57 PM, Billie Rinaldi wrote: > On Wed, Apr 3, 2013 at 1:16 PM, Christopher wrote: > >> Try with -libjars: >> > > tool.sh automatically adds libjars. > > The problem is the regular expression for the examples-simple jar. It's > trying to exclude the javadoc jar with ^c, but it isn't excluding the > sources jar. /opt/accumulo/lib/examples-simple-*[^cs].jar may work, or you > can just specify the jar exactly, > /opt/accumulo/lib/examples-simple-1.4.2.jar > > */opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^cs].jar > org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample > myinstance zookeepers user pswd tableName inputDir tmp/bulkWork* > > Billie > > > >> >> /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^c].jar >> -libjars /opt/accumulo/lib/examples-simple-*[^c].jar >> org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample >> myinstance zookeepers user pswd tableName inputDir tmp/bulkWork >> >> -- >> Christopher L Tubbs II >> http://gravatar.com/ctubbsii >> >> >> On Wed, Apr 3, 2013 at 4:11 PM, Aji Janis wrote: >> > I am trying to run the BulkIngest example (on 1.4.2 accumulo) and I am >> not >> > able to run the following steps. Here is the error I get: >> > >> > [user@mynode bulk]$ /opt/accumulo/bin/tool.sh >> > /opt/accumulo/lib/examples-simple-*[^c].jar >> > org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample >> > myinstance zookeepers user pswd tableName inputDir tmp/bulkWork >> > Exception in thread "main" java.lang.ClassNotFoundException: >> > /opt/accumulo/lib/examples-simple-1/4/2-sources/jar >> > at java.lang.Class.forName0(Native Method) >> > at java.lang.Class.forName(Class.java:264) >> > at org.apache.hadoop.util.RunJar.main(RunJar.java:149) >> > [user@mynode bulk]$ >> > [user@mynode bulk]$ >> > [user@mynode bulk]$ >> > [user@mynode bulk]$ ls /opt/accumulo/lib/ >> > accumulo-core-1.4.2.jar >> > accumulo-start-1.4.2.jar >> > commons-collections-3.2.jar >> > commons-logging-1.0.4.jar >> > jline-0.9.94.jar >> > accumulo-core-1.4.2-javadoc.jar >> > accumulo-start-1.4.2-javadoc.jar >> > commons-configuration-1.5.jar >> > commons-logging-api-1.0.4.jar >> > libthrift-0.6.1.jar >> > accumulo-core-1.4.2-sources.jar >> > accumulo-start-1.4.2-sources.jar >> > commons-io-1.4.jar >> > examples-simple-1.4.2.jar >> > log4j-1.2.16.jar >> > accumulo-server-1.4.2.jar >> > cloudtrace-1.4.2.jar >> > commons-jci-core-1.0.jar >> > examples-simple-1.4.2-javadoc.jar >> > native >> > accumulo-server-1.4.2-javadoc.jar >> > cloudtrace-1.4.2-javadoc.jar >> > commons-jci-fam-1.0.jar >> > examples-simple-1.4.2-sources.jar >> > wikisearch-ingest-1.4.2-javadoc.jar >> > accumulo-server-1.4.2-sources.jar >> > cloudtrace-1.4.2-sources.jar >> > commons-lang-2.4.jar >> > ext >> > wikisearch-query-1.4.2-javadoc.jar >> > >> > [user@mynode bulk]$ >> > >> > >> > Clearly, the libraries and source file exist so I am not sure whats >> going >> > on. I tried putting in >> /opt/accumulo/lib/examples-simple-1.4.2-sources.jar >> > instead then it complains BulkIngestExample ClassNotFound. >> > >> > Suggestions? >> > >> > >> > On Wed, Apr 3, 2013 at 2:36 PM, Eric Newton >> wrote: >> >> >> >> You will have to write your own InputFormat class which will parse your >> >> file and pass records to your reducer. >> >> >> >> -Eric >> >> >> >> >> >> On Wed, Apr 3, 2013 at 2:29 PM, Aji Janis wrote: >> >>> >> >>> Looking at the BulkIngestExample, it uses GenerateTestData and >> creates a >> >>> .txt file which contians Key: Value pair and correct me if I am wrong >> but >> >>> each new line is a new row right? >> >>> >> >>> I need to know how to have family and qualifiers also. In other words, >> >>> >> >>> 1) Do I set up a .txt file that can be converted into an Accumulo RF >> File >> >>> using AccumuloFileOutputFormat which can then be imported into my >> table? >> >>> >> >>> 2) if yes, what is the format of the .txt file. >> >>> >> >>> >> >>> >> >>> >> >>> On Wed, Apr 3, 2013 at 2:19 PM, Eric Newton >> >>> wrote: >> >>>> >> >>>> Your data needs to be in the RFile format, and more importantly it >> needs >> >>>> to be sorted. >> >>>> >> >>>> It's handy to use a Map/Reduce job to convert/sort your data. See >> the >> >>>> BulkIngestExample. >> >>>> >> >>>> -Eric >> >>>> >> >>>> >> >>>> On Wed, Apr 3, 2013 at 2:15 PM, Aji Janis wrote: >> >>>>> >> >>>>> I have some data in a text file in the following format. >> >>>>> >> >>>>> rowid1 columnFamily1 colQualifier1 value >> >>>>> rowid1 columnFamily1 colQualifier2 value >> >>>>> rowid1 columnFamily2 colQualifier1 value >> >>>>> rowid2 columnFamily1 colQualifier1 value >> >>>>> rowid3 columnFamily1 colQualifier1 value >> >>>>> >> >>>>> I want to import this data into a table in accumulo. My end goal is >> to >> >>>>> understand how to use the BulkImport feature in accumulo. I tried >> to login >> >>>>> to the accumulo shell as root and then run: >> >>>>> >> >>>>> #table mytable >> >>>>> #importdirectory /home/inputDir /home/failureDir true >> >>>>> >> >>>>> but it didn't work. My data file was saved as data.txt in >> >>>>> /home/inputDir. I tried to create the dir/file structure in hdfs >> and linux >> >>>>> but neither worked. When trying locally, it keeps complaining about >> >>>>> failureDir not existing. >> >>>>> ... >> >>>>> java.io.FileNotFoundException: File does not exist: failures >> >>>>> >> >>>>> When trying with files on hdfs, I get no error on the console but >> the >> >>>>> logger had the following messages: >> >>>>> ... >> >>>>> [tableOps.BulkImport] WARN : hdfs://node....//inputDir/data.txt does >> >>>>> not have a valid extension, ignoring >> >>>>> >> >>>>> or, >> >>>>> >> >>>>> [tableOps.BulkImport] WARN : hdfs://node....//inputDir/data.txt is >> not >> >>>>> a map file, ignoring >> >>>>> >> >>>>> >> >>>>> Suggestions? Am I not setting up the job right? Thank you for help >> in >> >>>>> advance. >> >>>>> >> >>>>> >> >>>>> On Wed, Apr 3, 2013 at 2:04 PM, Aji Janis >> wrote: >> >>>>>> >> >>>>>> I have some data in a text file in the following format: >> >>>>>> >> >>>>>> rowid1 columnFamily colQualifier value >> >>>>>> rowid1 columnFamily colQualifier value >> >>>>>> rowid1 columnFamily colQualifier value >> >>>>> >> >>>>> >> >>>> >> >>> >> >> >> > >> > > --14dae9d7121e7b1b2204d98904d1 Content-Type: text/html; charset=ISO-8859-1 Content-Transfer-Encoding: quoted-printable
I am not sure its just a regular e= xpression issue. Below is my console output. Not sure why this ClassDefFoun= dError occurs. Has anyone tried to do it successfully? Can you please tell = me your env set up if you did.


[user@mynode bulk]$ pwd
/home/user/b= ulk
[user@mynode bulk]$ ls
BulkIngestExample.java =A0Ge= nerateTestData.java =A0SetupTable.java =A0test_1.txt =A0VerifyIngest.java
[user@mynode bulk]$
[user@mynode bulk]$ /opt/accumulo/bin= /tool.sh /opt/accumulo/lib/examples-simple-1.4.2.jar org.apache.accumulo.ex= amples.simple.mapreduce.bulk.BulkIngestExample myinstance zookeepers user p= swd tableName inputDir tmp/bulkWork
Exception in thread "main" java.lang.NoClassDefFoundError: o= rg/apache/accumulo/core/client/Instance
=A0 =A0 =A0 =A0 at java.l= ang.Class.forName0(Native Method)
=A0 =A0 =A0 =A0 at java.lang.Cl= ass.forName(Class.java:264)
=A0 =A0 =A0 =A0 at org.apache.hadoop.util.RunJar.main(RunJar.java:149)=
Caused by: java.lang.ClassNotFoundException: org.apache.accumulo= .core.client.Instance
=A0 =A0 =A0 =A0 at java.net.URLClassLoader$= 1.run(URLClassLoader.java:366)
=A0 =A0 =A0 =A0 at java.net.URLClassLoader$1.run(URLClassLoader.java:3= 55)
=A0 =A0 =A0 =A0 at java.security.AccessController.doPrivilege= d(Native Method)
=A0 =A0 =A0 =A0 at java.net.URLClassLoader.findC= lass(URLClassLoader.java:354)
=A0 =A0 =A0 =A0 at java.lang.ClassLoader.loadClass(ClassLoader.java:42= 3)
=A0 =A0 =A0 =A0 at java.lang.ClassLoader.loadClass(ClassLoader= .java:356)
=A0 =A0 =A0 =A0 ... 3 more
[user@mynode b= ulk]$ /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^cs].ja= r org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myin= stance zookeepers user pswd tableName inputDir tmp/bulkWork
Exception in thread "main" java.lang.NoClassDefFoundError: o= rg/apache/accumulo/core/client/Instance
=A0 =A0 =A0 =A0 at java.l= ang.Class.forName0(Native Method)
=A0 =A0 =A0 =A0 at java.lang.Cl= ass.forName(Class.java:264)
=A0 =A0 =A0 =A0 at org.apache.hadoop.util.RunJar.main(RunJar.java:149)=
Caused by: java.lang.ClassNotFoundException: org.apache.accumulo= .core.client.Instance
=A0 =A0 =A0 =A0 at java.net.URLClassLoader$= 1.run(URLClassLoader.java:366)
=A0 =A0 =A0 =A0 at java.net.URLClassLoader$1.run(URLClassLoader.java:3= 55)
=A0 =A0 =A0 =A0 at java.security.AccessController.doPrivilege= d(Native Method)
=A0 =A0 =A0 =A0 at java.net.URLClassLoader.findC= lass(URLClassLoader.java:354)
=A0 =A0 =A0 =A0 at java.lang.ClassLoader.loadClass(ClassLoader.java:42= 3)
=A0 =A0 =A0 =A0 at java.lang.ClassLoader.loadClass(ClassLoader= .java:356)
=A0 =A0 =A0 =A0 ... 3 more
[user@mynode b= ulk]$ /opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^c].jar= org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myins= tance zookeepers user pswd tableName inputDir tmp/bulkWork
Exception in thread "main" java.lang.ClassNotFoundException:= /opt/accumulo/lib/examples-simple-1/4/2-sources/jar
=A0 =A0 =A0 = =A0 at java.lang.Class.forName0(Native Method)
=A0 =A0 =A0 =A0 at= java.lang.Class.forName(Class.java:264)
=A0 =A0 =A0 =A0 at org.apache.hadoop.util.RunJar.main(RunJar.java:149)=
[user@mynode bulk]$



On Wed, Apr 3, 2013= at 4:57 PM, Billie Rinaldi <billie@apache.org> wrote:
On Wed, A= pr 3, 2013 at 1:16 PM, Christopher <ctubbsii@apache.org> w= rote:
Try with -libjars:

tool.sh automatically adds libjars.

The problem is the regular expression for the examples-simple jar.=A0 = It's trying to exclude the javadoc jar with ^c, but it isn't exclud= ing the sources jar. /opt/accumulo/lib/examples-simple-*[^cs].jar may work,= or you can just specify the jar exactly, /opt/accumulo/lib/examples-simple= -1.4.2.jar

/opt/accumulo/bin/tool.sh /opt/accumulo/lib/= examples-simple-*[^cs].jar org.apache.accumulo.examples.simple.mapreduce.bu= lk.BulkIngestExample myinstance zookeepers user pswd tableName inputDir tmp= /bulkWork

Billie

=A0

/opt/accumulo/bin/tool.sh /opt/accumulo/lib/examples-simple-*[^c].jar
-libjars =A0/opt/accumulo/lib/examples-simple-*[^c].jar
org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample myinstance zookeepers user pswd tableName inputDir tmp/bulkWork

--
Christopher L Tubbs II
http://gravatar.= com/ctubbsii


On Wed, Apr 3, 2013 at 4:11 PM, Aji Janis <aji1705@gmail.com> wrote:
> I am trying to run the BulkIngest example (on 1.4.2 accumulo) and I am= not
> able to run the following steps. Here is the error I get:
>
> [user@mynode bulk]$ /opt/accumulo/bin/tool.sh
> /opt/accumulo/lib/examples-simple-*[^c].jar
> org.apache.accumulo.examples.simple.mapreduce.bulk.BulkIngestExample > myinstance zookeepers user pswd tableName inputDir tmp/bulkWork
> Exception in thread "main" java.lang.ClassNotFoundException:=
> /opt/accumulo/lib/examples-simple-1/4/2-sources/jar
> =A0 =A0 =A0 =A0 at java.lang.Class.forName0(Native Method)
> =A0 =A0 =A0 =A0 at java.lang.Class.forName(Class.java:264)
> =A0 =A0 =A0 =A0 at org.apache.hadoop.util.RunJar.main(RunJar.java:149)=
> [user@mynode bulk]$
> [user@mynode bulk]$
> [user@mynode bulk]$
> [user@mynode bulk]$ ls /opt/accumulo/lib/
> accumulo-core-1.4.2.jar
> accumulo-start-1.4.2.jar
> commons-collections-3.2.jar
> commons-logging-1.0.4.jar
> jline-0.9.94.jar
> accumulo-core-1.4.2-javadoc.jar
> accumulo-start-1.4.2-javadoc.jar
> commons-configuration-1.5.jar
> commons-logging-api-1.0.4.jar
> libthrift-0.6.1.jar
> accumulo-core-1.4.2-sources.jar
> accumulo-start-1.4.2-sources.jar
> commons-io-1.4.jar
> examples-simple-1.4.2.jar
> log4j-1.2.16.jar
> accumulo-server-1.4.2.jar
> cloudtrace-1.4.2.jar
> commons-jci-core-1.0.jar
> examples-simple-1.4.2-javadoc.jar
> native
> accumulo-server-1.4.2-javadoc.jar
> cloudtrace-1.4.2-javadoc.jar
> commons-jci-fam-1.0.jar
> examples-simple-1.4.2-sources.jar
> wikisearch-ingest-1.4.2-javadoc.jar
> accumulo-server-1.4.2-sources.jar
> cloudtrace-1.4.2-sources.jar
> commons-lang-2.4.jar
> =A0ext
> wikisearch-query-1.4.2-javadoc.jar
>
> [user@mynode bulk]$
>
>
> Clearly, the libraries and source file exist so I am not sure whats go= ing
> on. I tried putting in /opt/accumulo/lib/examples-simple-1.4.2-sources= .jar
> instead then it complains BulkIngestExample ClassNotFound.
>
> Suggestions?
>
>
> On Wed, Apr 3, 2013 at 2:36 PM, Eric Newton <eric.newton@gmail.com> wrote: >>
>> You will have to write your own InputFormat class which will parse= your
>> file and pass records to your reducer.
>>
>> -Eric
>>
>>
>> On Wed, Apr 3, 2013 at 2:29 PM, Aji Janis <aji1705@gmail.com> wrote:
>>>
>>> Looking at the BulkIngestExample, it uses GenerateTestData and= creates a
>>> .txt file which contians Key: Value pair and correct me if I a= m wrong but
>>> each new line is a new row right?
>>>
>>> I need to know how to have family and qualifiers also. In othe= r words,
>>>
>>> 1) Do I set up a .txt file that can be converted into an Accum= ulo RF File
>>> using AccumuloFileOutputFormat =A0which can then be imported i= nto my table?
>>>
>>> 2) if yes, what is the format of the .txt file.
>>>
>>>
>>>
>>>
>>> On Wed, Apr 3, 2013 at 2:19 PM, Eric Newton <eric.newton@gmail.com><= br> >>> wrote:
>>>>
>>>> Your data needs to be in the RFile format, and more import= antly it needs
>>>> to be sorted.
>>>>
>>>> It's handy to use a Map/Reduce job to convert/sort you= r data. =A0See the
>>>> BulkIngestExample.
>>>>
>>>> -Eric
>>>>
>>>>
>>>> On Wed, Apr 3, 2013 at 2:15 PM, Aji Janis <aji1705@gmail.com> wrote:=
>>>>>
>>>>> I have some data in a text file in the following forma= t.
>>>>>
>>>>> rowid1 columnFamily1 colQualifier1 value
>>>>> rowid1 columnFamily1 colQualifier2 value
>>>>> rowid1 columnFamily2 colQualifier1 value
>>>>> rowid2 columnFamily1 colQualifier1 value
>>>>> rowid3 columnFamily1 colQualifier1 value
>>>>>
>>>>> I want to import this data into a table in accumulo. M= y end goal is to
>>>>> understand how to use the BulkImport feature in accumu= lo. I tried to login
>>>>> to the accumulo shell as root and then run:
>>>>>
>>>>> #table mytable
>>>>> #importdirectory /home/inputDir /home/failureDir true<= br> >>>>>
>>>>> but it didn't work. My data file was saved as data= .txt in
>>>>> /home/inputDir. I tried to create the dir/file structu= re in hdfs and linux
>>>>> but neither worked. When trying locally, it keeps comp= laining about
>>>>> failureDir not existing.
>>>>> ...
>>>>> java.io.FileNotFoundException: File does not exist: fa= ilures
>>>>>
>>>>> When trying with files on hdfs, I get no error on the = console but the
>>>>> logger had the following messages:
>>>>> ...
>>>>> [tableOps.BulkImport] WARN : hdfs://node....//inputDir= /data.txt does
>>>>> not have a valid extension, ignoring
>>>>>
>>>>> or,
>>>>>
>>>>> [tableOps.BulkImport] WARN : hdfs://node....//inputDir= /data.txt is not
>>>>> a map file, ignoring
>>>>>
>>>>>
>>>>> Suggestions? Am I not setting up the job right? Thank = you for help in
>>>>> advance.
>>>>>
>>>>>
>>>>> On Wed, Apr 3, 2013 at 2:04 PM, Aji Janis <aji1705@gmail.com> w= rote:
>>>>>>
>>>>>> I have some data in a text file in the following f= ormat:
>>>>>>
>>>>>> rowid1 columnFamily colQualifier value
>>>>>> rowid1 columnFamily colQualifier value
>>>>>> rowid1 columnFamily colQualifier value
>>>>>
>>>>>
>>>>
>>>
>>
>


--14dae9d7121e7b1b2204d98904d1--