Mailing-List: contact user-help@hbase.apache.org; run by ezmlm
Precedence: bulk
Reply-To: user@hbase.apache.org
From: "Ma, Sheng-Chen (Aven)" <shengchen.ma@esgyn.cn>
To: "user@hbase.apache.org" <user@hbase.apache.org>
Subject: how to Dynamic load of Coprocessors
Thread-Topic: how to Dynamic load of Coprocessors
Thread-Index: AdHj71SQcgnH+05bTjucvliq2QJjUQ==
Date: Fri, 22 Jul 2016 08:12:48 +0000
Message-ID: <SHAPR01MB1594E76DCE247927C2773AFEA0A0@SHAPR01MB159.CHNPR01.prod.partner.outlook.cn>
Accept-Language: zh-CN, en-US
Content-Language: zh-CN
received-spf: None (protection.outlook.com: esgyn.cn does not designate
 permitted sender hosts)
Content-Type: multipart/alternative;
	boundary="_000_SHAPR01MB1594E76DCE247927C2773AFEA0A0SHAPR01MB159CHNPR0_"
MIME-Version: 1.0
X-MS-Exchange-CrossTenant-originalarrivaltime: 22 Jul 2016 08:12:48.4004
 (UTC)
X-MS-Exchange-CrossTenant-fromentityheader: Hosted
X-MS-Exchange-CrossTenant-id: 8bf80453-2b55-4b23-a365-dc866d5806aa
X-MS-Exchange-Transport-CrossTenantHeadersStamped: SHAPR01MB157
archived-at: Fri, 22 Jul 2016 08:17:29 -0000

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

Hi all:
I want to dynamic add coprocessor in order to not restart hbase.

Following is my code:
        Path path =3D new Path("/coprocessor_jars");
        FileSystem fs =3D FileSystem.get(conf);
        FileStatus[] status =3D fs.listStatus(path);
        Path[] listedPaths =3D FileUtil.stat2Paths(status);
        for (Path p : listedPaths) {
            if(p.getName().contains("test.jar")){
                hdfsPath =3D p;
            }
        }
        HBaseAdmin hadmin =3D new HBaseAdmin(conf);
        HTableDescriptor tableDesc =3D hadmin.getTableDescriptor("testTbl".=
getBytes());
        tableDesc.addCoprocessor("org.apache.hadoop.hbase.coprocessor.trans=
actional.TestRegionEndpoint", hdfsPath,
                Coprocessor.PRIORITY_USER, null);
        // tableDesc.removeCoprocessor("org.apache.hadoop.hbase.coprocessor=
.transactional.TrxRegionEndpoint");
        for (Entry<ImmutableBytesWritable, ImmutableBytesWritable> entry : =
tableDesc.getValues().entrySet()) {
            System.out.println(Bytes.toString(entry.getKey().get()) + " =3D=
 " + Bytes.toString(entry.getValue().get()));
        }
        hadmin.disableTable("testTbl".getBytes());
        hadmin.modifyTable("testTbl", tableDesc);
        hadmin.enableTable("testTbl");

the syso print : coprocessor$1 =3D hdfs://192.168.0.17:17400/coprocessor_ja=
rs/test.jar|org.apache.hadoop.hbase.coprocessor.transactional.TestRegionEnd=
point|1073741823|

and the remote side return Exception:
org.apache.hadoop.hbase.DoNotRetryIOException: org.apache.hadoop.hbase.DoNo=
tRetryIOException: Class org.apache.hadoop.hbase.coprocessor.transactional.=
TestRegionEndpoint cannot be loaded Set hbase.table.sanity.checks to false =
at conf or table descriptor if you want to bypass sanity checks

I use hbase 1.2 and the test.jar is not under hbase/lib, I just put the tes=
t.jar in hdfs.

If I add test.jar to hbase/lib but not restart hbase, the upon code still t=
hrow same exception.
If I add test.jar to hbase/lib and restart hbase, the upon code will exec s=
uccessful.

But my requirement is not restart hbase.

Is there someone can give me a favor.

Thanks


--_000_SHAPR01MB1594E76DCE247927C2773AFEA0A0SHAPR01MB159CHNPR0_--