Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
Received-SPF: pass (athena.apache.org: domain of asaf.mesika@gmail.com
 designates 74.125.82.169 as permitted sender)
Content-Type: text/plain; charset=iso-8859-1
Mime-Version: 1.0 (Apple Message framework v1283)
Subject: Re: Using HBaseAdmin.getAlterStatus
From: "Mesika, Asaf" <asaf.mesika@gmail.com>
In-Reply-To: 
 <CAOcnVr2YGBX0jnt9PyH+32BkVnArPDizLFZ0psm-7fg3umBcuA@mail.gmail.com>
Date: Sun, 9 Dec 2012 23:02:45 +0200
Content-Transfer-Encoding: quoted-printable
Message-Id: <9960F737-ADD5-451E-96D4-F42E7EC81556@gmail.com>
References: <19CED861-FE07-4231-AEB2-36A7C0D823D3@gmail.com>
 <CAOcnVr2YGBX0jnt9PyH+32BkVnArPDizLFZ0psm-7fg3umBcuA@mail.gmail.com>
To: user@hbase.apache.org

Yeah, I forgot to mention that important bit:
the pair returned is always 0 on the firstKey and never changes.

So if I understand you correctly, I need to use get AlterStatus between =
the modifyTable and enableTable ?

On Dec 9, 2012, at 10:53 PM, Harsh J wrote:

> Can you clarify on what "doesn't work" a bit more?
>=20
> Do you get an exception or are you not receiving some data that you
> are expecting?
>=20
> AFAICT, this API is helpful for a parallel monitoring of an issued
> schema update. In your code bits, which I will assume is serial, you
> already disable-update-enable table and complete the alter transaction
> before querying it (such that there isn't any pending operation to
> report). If the querying is done in a parallel process/monitor thread,
> then you may see in-flight results.
>=20
> On Mon, Dec 10, 2012 at 2:04 AM, Mesika, Asaf <asaf.mesika@gmail.com> =
wrote:
>> Hi,
>>=20
>> I've tried using HBaseAdmin.getAlterStatus to check on a =
HBaseAdmin.modifyTable command I've issued, but it doesn't work.
>>=20
>> Sample Code:
>>=20
>> Modifying Table
>>                tableDescriptor =3D =
admin.getTableDescriptor(tableNameBytes);
>>                if (tableDescriptor.hasCoprocessor(observerClassname)) =
{
>>                    logger.info("Coprocessor installed already. =
Removing to update jar location in any case");
>>                    =
tableDescriptor.removeCoprocessor(observerClassname);
>>                }
>>                tableDescriptor.addCoprocessor(observerClassname, =
hdfsJarPath, RegionObserver.PRIORITY_USER, null);
>>=20
>>                logger.info("Disabling table "+tableName);
>>                admin.disableTable(tableNameBytes);
>>                logger.info("Modifying table "+tableName);
>>                admin.modifyTable(Bytes.toBytes(tableName), =
tableDescriptor);
>>                logger.info("Enabling table "+tableName);
>>                admin.enableTable(tableNameBytes);
>>=20
>> Using alterStatus
>>                byte[] tableName =3D it.next();
>>                try {
>>                    Pair<Integer,Integer> alterStatus =3D =
admin.getAlterStatus(tableName);
>>                    if (alterStatus.getFirst() =3D=3D =
alterStatus.getSecond()) {
>>                        it.remove();
>>                        logger.info("Table =
"+Bytes.toString(tableName)+" was altered successfully. =
"+notLoadedTables.size()+" tables remaining...");
>>                    } else {
>>                        if (logger.isDebugEnabled()) {
>>                            logger.debug("Table =
"+Bytes.toString(tableName)+" was not yet altered. Alter Status: "+
>>                                    alterStatus.getFirst()+" regions =
altered, "+alterStatus.getSecond()+" total regions on table");
>>                        }
>>                    }
>>                } catch (IOException e) {
>>                    throw new RuntimeException("Failed getting alter =
status for table name: "+Bytes.toString(tableName));
>>                }
>>=20
>> Does anyone know how to use it?
>>=20
>> Asaf
>>=20
>=20
>=20
>=20
> --=20
> Harsh J