feat: 移除拉数据limit

handle/pull_sample_data.py

@@ -133,8 +133,7 @@ def pull_by_max(size=100000):
     log.info("开始推送数据...")
 
     with odps_sdk.execute_sql(
-            'select * from out_winhc_data_analysis_pull_data where ds = ' + latest_ds + ' limit ' + str(
-                size)).open_reader(
+            'select * from out_winhc_data_analysis_pull_data where ds = ' + latest_ds + ' ').open_reader(
         tunnel=True) as reader:
         for record in reader:
             c = get_value(