fix

Pyspark_job/sqoop_import/dim_asin_profit_rate_info.py

@@ -37,7 +37,7 @@ if __name__ == '__main__':
         hive_table=hive_table,
         hdfs_path=hdfs_path,
         partitions=partition_dict,
-        check_count=False
+        check_count=True
     )
 
     print('success！')

Pyspark_job/sqoop_import/ods_keepa_asin_detail.py

@@ -41,7 +41,7 @@ if __name__ == '__main__':
         hive_table=hive_table,
         hdfs_path=hdfs_path,
         partitions=partition_dict,
-        check_count=False
+        check_count=True
     )
 
     pass