天天看点

从mysql增量导入数据到hive的sqoop语句

ERROR:org.springframework.transaction.CannotCreateTransactionException: Could not open JDBC Connection for transaction; nested exception is com.mysql.jdbc.exceptions.jdbc4.CommunicationsException: Communications link failure
sqoop job --create sojob -- import --connect jdbc:mysql://node02:3306/sales_source \
--driver com.mysql.jdbc.Driver \
--username root --password 123456 \
--table sales_order \
--m 1 \
--hive-import \
--hive-overwrite \
--hive-database sales_rds \
--hive-table sales_order \
--fields-terminated-by '\t' \
--check-column 'order_number' \
--last-value '0' \
--incremental append \
;
           
sqoop job --exec sojob
           
数据库连接池超时:连接的等待时间(wait_timeout)缺省为8小时。
从mysql增量导入数据到hive的sqoop语句
使用centos7命令重启mysql
systemctl restart mysql;
           
从mysql增量导入数据到hive的sqoop语句