diff --git a/task/spark_test.py b/task/spark_test.py index 6fb5850dcca5a4c5ffe0ce3b21442baafe4c3acb..6d9e4fe1a322d6a36d8d126a8a98d458e925b1e2 100644 --- a/task/spark_test.py +++ b/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 online.ml_user_history_detail where date_joined >= {join_date} limit 20 ; +select * from online.ml_user_history_detail where date_joined >= {join_date} """.format(join_date="20200915") print(sql_search_ctr)