update

task/search_strategy_d.py

@@ -136,8 +136,8 @@ for t in range(0, task_days):
     dev_df.cache()
     dev_df.show(1)
     sql_res = dev_df.collect()
-    for res in sql_res:
-        print(res)
+    # for res in sql_res:
+    #     print(res)
 
     print("-------------------------------")
 
@@ -154,8 +154,8 @@ for t in range(0, task_days):
     spam_pv_df.show(1)
     sql_res = spam_pv_df.collect()
     spam_pv_df.cache()
-    for res in sql_res:
-        print(res)
+    # for res in sql_res:
+    #     print(res)
 
     print("-------------------------------")
     sql = r"""
@@ -374,8 +374,8 @@ for t in range(0, task_days):
     device_df = spark.sql(sql)
     device_df.show(1, False)
     sql_res = device_df.collect()
-    for res in sql_res:
-        print(res)
+    # for res in sql_res:
+    #     print(res)
     device_df.createOrReplaceTempView("data_table")
     #
     # sql = r"""