update

task/spark_test.py

@@ -80,7 +80,7 @@ spark.sql("CREATE TEMPORARY FUNCTION arrayMerge AS 'com.gmei.hive.common.udf.UDF
 
 
 sql_search_ctr = r"""
-select * from ml_user_history_detail where partition_date = '20200915' and  unix_timestamp(date_joined) >=  1600012800 ;
+select * from online.bl_hdfs_maidian_updates where partition_date = ${partition_date} and cl_id is not null order by time_stamp asc;
 """
 
 print(sql_search_ctr)