如何保证sqoop数据同步后2边数据量一致

#1-sqoop导数

sqoop import --connect jdbc:mysql://node1:3306/库名 
--username root 
--password 123456 
--table dd_table 
--hive-table ods.table 
--fields-terminated-by 't' 
--hive-import 
--hive-overwrite 
--delete-target-dir 
-m 1

#2-查询MySQL的表的条数

mysql_log=`sqoop eval --connect jdbc:mysql://node1:3306/库名 
--username root 
--password 123456 
--query "select count(*) from table"`

mysql_cnt=`echo $mysql_log | awk -F '|' '{print $4}' | awk '{print $1}'`

#3-查询Hive表的条数

hive_log=`spark-sql -e "select count(1) from ods.table "`
hive_cnt=`echo $hive_log | awk '{print $2}'`

#4-比较2边的条数是否一致

if [ $mysql_cnt -eq $hive_cnt ] ; then
  echo "mysql表的条数是$mysql_cnt, Hive表的条数是$hive_cnt,2者一致"
else
  echo "mysql表的条数是$mysql_cnt, Hive表的条数是$hive_cnt,2者不一致"
fi