update

ad_predict_user_data_process.py

@@ -38,7 +38,7 @@ def get_feature_data(project, table, dt, app_type):
         endpoint=odps_config['ENDPOINT'],
     )
     feature_data = []
-    sql = f"select * from {project}.{table} where dt={dt} and apptype={app_type}"
+    sql = f"select * from {project}.{table} where dt={dt} and apptype={app_type} limit 10000"
     with odps.execute_sql(sql).open_reader() as reader:
         for record in reader:
             # print(record)