Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
Received-SPF: unknown (athena.apache.org: error in processing during lookup of
 agsharma@ebay.com)
DomainKey-Signature: s=corp; d=ebay.com; c=nofws; q=dns;
  h=X-EBay-Corp:X-IronPort-AV:Received:Received:From:To:Date:
   Subject:Thread-Topic:Thread-Index:Message-ID:
   Accept-Language:Content-Language:X-MS-Has-Attach:
   X-MS-TNEF-Correlator:x-cr-puzzleid:x-cr-hashedpuzzle:
   acceptlanguage:x-ems-proccessed:x-ems-stamp:Content-Type:
   MIME-Version:X-CFilter;
  b=vbrx5jeEh0Ilh58s+scQx6NEG8NZAE81YNbD/36KQStnkv+laYnyGied
   fBLy35MgALL8cRFNKQVSyXRdFIpcU82pivtDcOc/DYfiZ6+gaPXFQ1LcR
   hWizjr3xRq3wkYa;
From: "Sharma, Avani" <agsharma@ebay.com>
To: "user@hbase.apache.org" <user@hbase.apache.org>
Date: Wed, 16 Jun 2010 19:05:56 -0700
Subject: MapReduce job runs fine, but nothing is written to HTable
Thread-Topic: MapReduce job runs fine, but nothing is written to HTable
Thread-Index: AcsNwZ+kMVIhgNgbQlOkukNBDtIxgw==
Message-ID: 
 <DE357E04199C8A4782DA2C8130FD64CAFF63FCBA@RHV-MEXMS-002.corp.ebay.com>
Accept-Language: en-US
Content-Language: en-US
acceptlanguage: en-US
Content-Type: multipart/alternative;
	boundary="_000_DE357E04199C8A4782DA2C8130FD64CAFF63FCBARHVMEXMS002corp_"
MIME-Version: 1.0

--_000_DE357E04199C8A4782DA2C8130FD64CAFF63FCBARHVMEXMS002corp_
Content-Type: text/plain; charset="us-ascii"
Content-Transfer-Encoding: quoted-printable

Hi,

I am running a job to write some data from a HDFS file to and Hbase table u=
sing the new API.
The job runs fine without any errors, but I do not see the rows added to th=
e hbase table.

This is what my code looks like -
I am running this as hadoop jar <jar_file_name> <class_name> <hdfs_file_nam=
e>

      private HTable table;
                protected void  map(ImmutableBytesWritable key, Text value,=
 Context context)
                throws IOException, InterruptedException
                        {
                           table =3D new HTable( new HBaseConfiguration(), =
"blogposts");

                             // Split input line on tab character
                            String [] splits =3D value.toString().split("\t=
");
                            String rowID =3D splits[0];
                            String cellValue =3D splits[1];
                          Put p =3D new Put(Bytes.toBytes(rowID));
                        p.add(Bytes.toBytes("post"), Bytes.toBytes("title")=
, Bytes.toBytes(splits[1]));
                        table.put(p);
                        table.flushCommits();
}
/*
       This commented code when run seprataely in a main program runs fine =
and does update to the table
        HTable table =3D new HTable(new HBaseConfiguration(), "blogposts");

        Put p =3D new Put(Bytes.toBytes("post3"));

        p.add(Bytes.toBytes("post"), Bytes.toBytes("title"), Bytes.toBytes(=
"abx"));
        p.add(Bytes.toBytes("post"), Bytes.toBytes("author"), Bytes.toBytes=
("hadings"));
        p.add(Bytes.toBytes("image"), Bytes.toBytes("body"), Bytes.toBytes(=
"123.jpg"));
        p.add(Bytes.toBytes("image"), Bytes.toBytes("header"), Bytes.toByte=
s("7657.jpg"));

        table.put(p);
*/

Run log
10/06/16 19:00:35 WARN mapred.JobClient: Use GenericOptionsParser for parsi=
ng the arguments. Applications should implement Tool for the same.
10/06/16 19:00:35 INFO input.FileInputFormat: Total input paths to process =
: 1
10/06/16 19:00:36 INFO mapred.JobClient: Running job: job_201003301510_0157
10/06/16 19:00:37 INFO mapred.JobClient:  map 0% reduce 0%
10/06/16 19:00:45 INFO mapred.JobClient:  map 100% reduce 0%
10/06/16 19:00:47 INFO mapred.JobClient: Job complete: job_201003301510_015=
7
10/06/16 19:00:47 INFO mapred.JobClient: Counters: 5
10/06/16 19:00:47 INFO mapred.JobClient:   Job Counters
10/06/16 19:00:47 INFO mapred.JobClient:     Rack-local map tasks=3D1
10/06/16 19:00:47 INFO mapred.JobClient:     Launched map tasks=3D1
10/06/16 19:00:47 INFO mapred.JobClient:   FileSystemCounters
10/06/16 19:00:47 INFO mapred.JobClient:     HDFS_BYTES_READ=3D31
10/06/16 19:00:47 INFO mapred.JobClient:   Map-Reduce Framework
10/06/16 19:00:47 INFO mapred.JobClient:     Map input records=3D2
10/06/16 19:00:47 INFO mapred.JobClient:     Spilled Records=3D0

Thanks,
Avani


--_000_DE357E04199C8A4782DA2C8130FD64CAFF63FCBARHVMEXMS002corp_--