您好,登录后才能下订单哦!
密码登录
登录注册
点击 登录注册 即表示同意《亿速云用户服务条款》
本篇文章为大家展示了reduce输出结果到sqlserver数据库异常,内容简明扼要并且容易理解,绝对能使你眼前一亮,通过这篇文章的详细介绍希望你能有所收获。
最近在做个hadoop统计的小项目,结果需要输出到sqlserver数据,其中遇到一些小问题
在map、reduce进行的比较顺利,因为数据比较规范,很快都搞定了
在运行时出现以下情况
遇到这种情况,第一时间想到是因为结点上驱动包的问题
对于缺少驱动的问题,有两种方案
1、在集群的每个结点${HADOOP_HOME}/lib下添加驱动包,并重启集群。这是最原始的方法,因为需要重启集群,不建议使用
2、先把驱动包上传到集群中
hadoop fs -put /lib/sqljdbc.jar
然后在新建Job之前添加到classpath环境中
Configuration conf = new Configuration(); FileSystem fs = FileSystem.get(conf); //添加到classpath DistributedCache.addFileToClassPath(new Path("/lib/sqljdbc.jar"), conf, fs); //必须在新建JOB之前执行,这样才能在初始化 加载数据库驱动、以及连接数据库 传入到conf中供JOB使用 DBConfiguration.configureDB(conf, "com.microsoft.sqlserver.jdbc.SQLServerDriver", "jdbc:sqlserver://192.168.240.1:1433;DatabaseName=dbname", "sa", "123456"); Job job = new Job(conf, "statistic"); job.setJarByClass(DbnameDownedStatistic.class); job.setMapperClass(StatisticMap.class); job.setReducerClass(StatisticReducer.class); job.setMapOutputKeyClass(Text.class); job.setMapOutputValueClass(IntWritable.class); job.setOutputKeyClass(StatisticDBWritable.class); job.setOutputValueClass(Text.class); job.setNumReduceTasks(4); job.setInputFormatClass(TextInputFormat.class); job.setOutputFormatClass(DBOutputFormat.class); FileInputFormat.addInputPath(job, new Path("hdfs://node1:9000/user/hadoop/statictic/")); String[] fileds = new String[] { "name","down", "count" }; DBOutputFormat.setOutput(job, "statistic", fileds); System.exit(job.waitForCompletion(true) ? 0 : 1);
这里需要注意的是
DBConfiguration.configureDB();
这个方法必须在new Job()之前执行,这样conf才能加载到驱动包,才能保证其他结点也能加载到驱动包。
上述内容就是reduce输出结果到sqlserver数据库异常,你们学到知识或技能了吗?如果还想学到更多技能或者丰富自己的知识储备,欢迎关注亿速云行业资讯频道。
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。