欢迎来到【codeblocks 源码】【大连网站源码】【神马电影pho源码】eclipse hbase 源码-皮皮网网站!!!

皮皮网

【codeblocks 源码】【大连网站源码】【神马电影pho源码】eclipse hbase 源码-皮皮网 扫描左侧二维码访问本站手机端

【codeblocks 源码】【大连网站源码】【神马电影pho源码】eclipse hbase 源码

2024-11-23 07:36:38 来源:{typename type="name"/} 分类:{typename type="name"/}

1.eclipse中Java程序实现对HBase操作报错:java.io.IOException: Attempt to start meta tracker failed.

eclipse hbase 源码

eclipse中Java程序实现对HBase操作报错:java.io.IOException: Attempt to start meta tracker failed.

       我hadoop和Hbase都是源码采用伪分布式的

       代码如下:

       public class HbaseTest {

       private static Configuration conf;

       static{

       conf = HBaseConfiguration.create();

       conf.set("hbase.rootdir", "hdfs://...2:/hbase");

       //使用eclipse时必须添加这个,否则无法定位

       conf.set("hbase.zookeeper.quorum",源码codeblocks 源码 "...2");

       conf.set("hbase.zookeeper.property.clientPort", "");

       }

       public static void createTable(String tableName){

       System.out.println("start create table ......");

       try {

       HBaseAdmin hbAdmin = new HBaseAdmin(conf);

       if(hbAdmin.tableExists(tableName)){

       hbAdmin.disableTable(tableName);

       hbAdmin.deleteTable(tableName);

       System.out.println(tableName + " is exist,detele ....");

       }

       // HTableDescriptor htd = new HTableDescriptor(tableName);

       HTableDescriptor htd = new HTableDescriptor(tableName);

       htd.addFamily(new HColumnDescriptor("cf1"));

       htd.addFamily(new HColumnDescriptor("cf2"));

       htd.addFamily(new HColumnDescriptor("cf3"));

       htd.addFamily(new HColumnDescriptor("cf4"));

       hbAdmin.createTable(htd);

       } catch (MasterNotRunningException e) {

       // TODO Auto-generated catch block

       e.printStackTrace();

       } catch (ZooKeeperConnectionException e) {

       // TODO Auto-generated catch block

       e.printStackTrace();

       } catch (IOException e) {

       // TODO Auto-generated catch block

       e.printStackTrace();

       }

       System.out.println("end create table ......");

       }

       public static void main(String[] args) {

       createTable("testTable");

       }

       更多0