sqoop导入可以处理一个表,但不能处理另一个表

oewdyzsn  于 2021-06-03  发布在  Sqoop
关注(0)|答案(1)|浏览(285)

我有两张table VB_B2B_INN_201611_201705_7 我导入到 adhoc_mn_client_inn_201611_201705 以及 EVKUZMIN_B2B_CHURN_BAN_SEGMENT 哪个应该去 evkuzmin_b2b_churn_ban_segment .
两种情况下的脚本都是

sqoop import \
-Dmapreduce.job.queuename=adhoc \
--connect jdbc:oracle:thin:secret/secret@//biistst1:1521/UATR15 \
--table table_name-m 1 \
--target-dir /apps/hive/warehouse/arstel.db/directory\
--delete-target-dir \
--fields-terminated-by '\t'

我来替换 table name 使用oracle表名和 directory 使用hdfs目录。我检查了oracle中的两个表,它们都有数据。不过,从 VB_B2B_INN_201611_201705_7 工作和来源 EVKUZMIN_B2B_CHURN_BAN_SEGMENT 不。
我没有发现第二张table有任何错误。只是

INFO mapreduce.ImportJobBase: Transferred 0 bytes in 38.2422 seconds (0 bytes/sec)
INFO mapreduce.ImportJobBase: Retrieved 0 records.

还有一个空文件 evkuzmin_b2b_churn_ban_segment 目录。

ujv3wf0j

ujv3wf0j1#

我不知道我要跑 commit; 在中插入数据后 EVKUZMIN_B2B_CHURN_BAN_SEGMENT 第一。在我做了所有的工作之后。

相关问题