
如題,報這樣的錯,請問下這是問什么?
Configuration config = HBaseConfiguration.create();
/*// 配置hbase.zookeeper.quorum:后接zookeeper集群的機器串列
config.set("hbase.zookeeper.quorum", "zxl-Lenovo-G505");*//*
config.set("hbase.rootdir", "hdfs://localhost:9000/hbase");
// 配置hbase.zookeeper.property.clientPort:zookeeprr集群的服務埠
config.set("hbase.zookeeper.property.clientPort", "2181");*/
config.set("hbase.zookeeper.quorum", "localhost:2181");
config.set("hbase.rootdir", "hdfs://hadoop26:9000/hbase");
config.set(TableOutputFormat.OUTPUT_TABLE, args[1]);
Job job = Job.getInstance(config, Main.class.getSimpleName());
TableMapReduceUtil.addDependencyJars(job);
job.setJarByClass(Main.class);
job.setMapperClass(HdfsToBaseMapper.class);
job.setMapOutputKeyClass(Text.class);
job.setMapOutputValueClass(Text.class);
job.setReducerClass(HdfsToHbaseReducer.class);
FileInputFormat.addInputPath(job, new Path(args[0]));
job.setOutputFormatClass(TableOutputFormat.class);
job.waitForCompletion(true);
轉載請註明出處,本文鏈接:https://www.uj5u.com/qita/71163.html
標籤:服務器
