Sqoop将MySQL数据导入到hive中成功但没有数据

可能是由于以下原因导致的：

1. 检查表结构和数据类型

在使用Sqoop导入数据之前，请确保源数据库表的结构和数据类型与目标Hive表的结构和数据类型匹配。如果不匹配，可能会出现导入成功但没有数据的情况。

2. 检查导入的数据是否存在

在导入数据之前，请检查源数据库表中是否存在数据。如果没有数据，那么导入到目标Hive表中也不会有任何数据。

3. 检查导入的数据是否满足条件

在使用Sqoop导入数据之前，请确保你已经正确配置了导入的条件。例如，如果你只想导入源数据库表中的特定行或特定列，那么你需要正确配置Sqoop命令。

4. 检查日志信息

在Sqoop导入数据时，Sqoop会产生日志信息。通过检查日志信息，你可以了解导入数据的过程，并查找导入失败的原因。

如果以上措施都没有解决问题，你可以尝试重新运行Sqoop命令，或者尝试使用其他方法将数据从源数据库导入到目标Hive表中。

相关问题

（7）使用数据迁移工具Sqoop将MySQL数据导入到Hive； （8）使用数据迁移工具Sqoop将Hive数据导入到MySQL；

（7）使用Sqoop将MySQL数据导入到Hive的步骤：

1. 确保Sqoop已经正确安装和配置，并且Hive的元数据存储在MySQL中。

2. 在Hive中创建一个与MySQL表对应的Hive表。可以使用以下命令：

CREATE TABLE mydb.news (
  id INT,
  title STRING,
  content STRING,
  publish_time TIMESTAMP
)
STORED AS PARQUET;

这将在Hive中创建一个新的Parquet格式的表，用于存储MySQL表中的数据。

3. 使用Sqoop将MySQL中的数据导入到Hive中。可以使用以下命令：

sqoop import \
  --connect jdbc:mysql://mysql_host/mydb \
  --username mysql_user \
  --password mysql_password \
  --table news \
  --hive-import \
  --hive-table mydb.news \
  --incremental append \
  --check-column id \
  --last-value 0 \
  --split-by id \
  --target-dir /tmp/news

其中，`--connect`参数指定MySQL数据库的连接信息，`--username`和`--password`指定MySQL数据库的用户名和密码，`--table`参数指定要导入的MySQL表名，`--hive-import`参数表示将数据导入到Hive中，`--hive-table`参数指定要导入到的Hive表名，`--incremental`参数表示增量导入数据，`--check-column`参数指定用于增量导入的列名，`--last-value`参数指定增量导入的起始值，`--split-by`参数指定用于拆分任务的列名，`--target-dir`参数指定导入数据的目录。

4. 最后，使用以下命令在Hive中查看导入的数据：

SELECT * FROM mydb.news;

这将显示导入到Hive表中的数据。

（8）使用Sqoop将Hive数据导入到MySQL的步骤：

1. 确保Sqoop已经正确安装和配置，并且Hive的元数据存储在MySQL中。

2. 在Hive中创建一个与MySQL表对应的Hive表。可以使用以下命令：

CREATE TABLE mydb.news (
  id INT,
  title STRING,
  content STRING,
  publish_time TIMESTAMP
)
STORED AS PARQUET;

这将在Hive中创建一个新的Parquet格式的表，用于存储MySQL表中的数据。

3. 使用Sqoop将Hive中的数据导出到MySQL中。可以使用以下命令：

sqoop export \
  --connect jdbc:mysql://mysql_host/mydb \
  --username mysql_user \
  --password mysql_password \
  --table news \
  --export-dir /user/hive/warehouse/mydb.db/news \
  --input-fields-terminated-by ',' \
  --update-key id \
  --update-mode allowinsert \
  --input-null-string '\\N' \
  --input-null-non-string '\\N'

其中，`--connect`参数指定MySQL数据库的连接信息，`--username`和`--password`指定MySQL数据库的用户名和密码，`--table`参数指定要导出到的MySQL表名，`--export-dir`参数指定要导出的Hive表的目录，`--input-fields-terminated-by`参数指定Hive表中的字段分隔符，`--update-key`参数指定用于更新的列名，`--update-mode`参数指定更新模式，`--input-null-string`和`--input-null-non-string`参数指定Hive表中的空值。

4. 最后，使用以下命令在MySQL中查看导入的数据：

SELECT * FROM mydb.news;

这将显示导入到MySQL表中的数据。

（7）使用数据迁移工具Sqoop将MySQL数据导入到Hive；需要在hive中创建相同数据库和表吗

在使用 Sqoop 将 MySQL 数据导入到 Hive 之前，你需要在 Hive 中创建相同的数据库和表。这是因为 Sqoop 将数据导入到 Hive 表中，如果表不存在，Sqoop 将无法导入数据。

你可以使用以下命令在 Hive 中创建一个数据库：

CREATE DATABASE IF NOT EXISTS my_db;

这个命令将创建一个名为 `my_db` 的数据库，如果这个数据库已经存在，将不会重新创建。

接下来，你需要在 Hive 中创建一个表来存储从 MySQL 导入的数据。表结构应该与 MySQL 中的表结构相同，否则 Sqoop 将无法正常导入数据。你可以使用以下命令在 Hive 中创建一个表：

CREATE EXTERNAL TABLE IF NOT EXISTS my_table (
  column1_name column1_type,
  column2_name column2_type,
  ...
)
ROW FORMAT DELIMITED
FIELDS TERMINATED BY ','
STORED AS TEXTFILE
LOCATION '/user/hive/warehouse/my_db.db/my_table';

请注意以下几点：

- `my_table` 应该与 MySQL 表的名称相同。
- 列名和数据类型应该与 MySQL 中的表结构相同。
- `ROW FORMAT DELIMITED` 和 `FIELDS TERMINATED BY` 用于指定表中字段的分隔符，这里使用逗号作为分隔符。
- `STORED AS TEXTFILE` 用于指定表中数据的存储格式。
- `LOCATION` 用于指定表中数据的存储位置。

在创建表之后，你可以使用 Sqoop 将 MySQL 中的数据导入到 Hive 中的表中。以下是一个示例 Sqoop 命令：

sqoop import \
--connect jdbc:mysql://mysql_host/my_db \
--username root \
--password root_password \
--table my_table \
--hive-import \
--hive-table my_table \
--create-hive-table \
--target-dir /user/hive/warehouse/my_db.db/my_table;

这个命令将从 MySQL 数据库中的 `my_table` 表中导入数据，并将其存储到 Hive 中的 `my_table` 表中。`--hive-import` 参数用于指定将数据导入到 Hive 中，`--hive-table` 参数用于指定 Hive 表的名称，`--create-hive-table` 参数用于在导入数据之前自动创建 Hive 表，`--target-dir` 参数用于指定存储数据的目录。

请注意，你需要替换示例命令中的数据库名称、用户名、密码以及存储位置等参数，以确保正确导入数据。