Mailing-List: contact dev-help@phoenix.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@phoenix.apache.org
Content-Type: text/plain; charset=utf-8
Mime-Version: 1.0 (Mac OS X Mail 10.1 \(3251\))
Subject: Re: Sample phoenix upserts using threads
From: Shiva Krishna <shiva.krishnaah@gmail.com>
In-Reply-To: <5818C1B1.9020607@apache.org>
Date: Tue, 1 Nov 2016 21:59:27 +0530
Cc: "user@phoenix.apache.org" <user@phoenix.apache.org>
Content-Transfer-Encoding: quoted-printable
Message-Id: <FB74E70F-793B-4489-8A24-1A7DA792A1DC@gmail.com>
References: <D1CB194F-9D05-48D4-8D41-CECA3B4B438F@gmail.com>
 <5818C1B1.9020607@apache.org>
To: dev@phoenix.apache.org
archived-at: Tue, 01 Nov 2016 16:29:35 -0000

Hi Elser,
Thanks for the quick response.=20

Below is the exception that being logged in some region servers.
 In local it is working good when running in a distributed environment I =
am getting the below exception.
Caused by: java.lang.AssertionError: we should never remove a different
context
at org.apache.hadoop.hbase.regionserver.HRegion$RowLockContext.cleanUp(
HRegion.java:5227)
at org.apache.hadoop.hbase.regionserver.HRegion$
RowLockImpl.release(HRegion.java:5272)
at org.apache.phoenix.coprocessor.MetaDataEndpointImpl.doGetTable(
MetaDataEndpointImpl.java:2489)
at org.apache.phoenix.coprocessor.MetaDataEndpointImpl.doGetTable(
MetaDataEndpointImpl.java:2426)
at org.apache.phoenix.coprocessor.MetaDataEndpointImpl.getTable(
MetaDataEndpointImpl.java:451)
... 10 more

Phoenix : 4.7.0-HBase1.1 jar
HBase: 1.2.2

Cluster : 1 master 4 cores

OS : Amazon EMR 5.0.0

Thanks,
Krishna.

> On 01-Nov-2016, at 21:54, Josh Elser <elserj@apache.org> wrote:
>=20
> (cc: -dev +user, bcc: +dev)
>=20
> Hi Krishna,
>=20
> Might you be able to share the stacktrace that accompanied that =
Exception?
>=20
> Shiva Krishna wrote:
>> Hi All,
>> Can any one give me a small example of Phoenix upserts using Threads =
in Java.
>> I wrote a sample it is working fine in local environment but when =
running it cluster it is failing with below error.
>> java.lang.AssertionError: we should never remove a different context
>>=20
>> try(Connection conn =3D getConnection();
>>      PreparedStatement statement =3D conn.prepareStatement("upsert =
into \=E2=80=9Dtest\" values(?,?,?)");){
>> 	statement.setString(1,=E2=80=9Dtest1=E2=80=9D);
>> 	statement.setString(2,=E2=80=9Dtest2=E2=80=9D);
>> 	statement.setString(3,=E2=80=9Dtest3=E2=80=9D);
>> 	statement.execute();
>> 	conn.commit();
>> }catch(SqlException ex)
>> {
>> 	ex.printStackTrace();
>> }
>> Tried using both Threads and ForkJoins but getting the same exception =
some times we are not able to predict or generalise when this exception =
is occurring or how to resolve it.
>>=20
>> Thanks,
>> Krishna.