Sqoop导入mysql数据到HDFS

首先通过sqoop查看mysql数据库
命令:./sqoop list-databases --connect jdbc:mysql://***.*.:3306/?useSSL=false --username *** --password *******
请添加图片描述

然后在mysql中创建表

DROP TABLE IF EXISTS `mgmqtest`;
CREATE TABLE `mgmqtest` (
  `id` int(10) DEFAULT NULL,
  `uid` int(10) DEFAULT NULL,
  `title` varchar(100) DEFAULT NULL,
  `name` varchar(100) DEFAULT NULL,
  `status` int(10) DEFAULT NULL,
  `time` timestamp NULL DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=utf8;

在这里插入图片描述

发现我的用户没有插入权限

找一个有数据的表 直接开始抽数据
表名:amount_bk
在这里插入图片描述

sqoop运行命令: 期间要走mr的

./sqoop import --connect jdbc:mysql://***.***.**:3306/****?useSSL=false --username **** --password **** --table amount_bk -m 1

在这里插入图片描述

查看hdfs上文件:

 hdfs  dfs -cat /user/root/amount_bk/part-m-00000

在这里插入图片描述


版权声明:本文为cz124560原创文章,遵循CC 4.0 BY-SA版权协议,转载请附上原文出处链接和本声明。