diff --git a/task/spark_test.py b/task/spark_test.py
index f5ad2290dba1c3adaae3ab282b7f924f1f6aacdd..f88f2e19a4571e9cf2e6329d7502c3e4f2ee407a 100644
--- a/task/spark_test.py
+++ b/task/spark_test.py
@@ -187,7 +187,7 @@ WHERE spam_pv.device_id IS NULL
         # print(count, res)
         portratit_res = get_user_portrait_tag3_from_redis(res.device_id)
         sql = """select cl_id, projects from kafka_tag3_log
-  where cl_id = '%s' and event_cn = 'kyc' """
+  where cl_id = '%s' and event_cn = 'kyc' """ % res.device_id
         # print(count_user_count, res, portratit_res)
         sql_res_list = con_sql(sql)
         kyc_str_list= []
@@ -239,8 +239,7 @@ WHERE spam_pv.device_id IS NULL
         db.commit()
         print(res)
 
-    cursor.executemany()
-    db.close()
+