tbase在数据库建了一张分区表,按数据时间每天一张分区表,之前只是建了20200301-20200415每天的日表,现在增加分区的时候,执行半天没反应
表数据量4亿条数据
执行增加分区语句
create table xxx20200416 partition of xxx for values from ('2020-04-16') to ('2020-04-17');
我在mysql中有表测试,如下所示:
id name address
1 Km sky
2 hd heaven
3 Ab null
4 en null
现在我做了一个sqoop导入,如下所示
sqoop import--connect jdbc:mysql://XXXXXX/testing --username XXXX --password XXXX --query "select * from testing.test where \$CONDITIONS" --null-string '' --null-non-string '
我正在从mysql向hive导入一个表。该表包含2115584行。在导入期间,我看到
13/03/20 18:34:31 INFO mapreduce.ImportJobBase: Retrieved 2115584 records.
但是,当我在导入的表上执行count(*)时,我看到它有49262250行。怎么一回事?
更新:指定--direct时,导入可以正常工作。