add printer

eda/smart_rank/dist_update_user_portrait_service.py

@@ -162,6 +162,7 @@ if __name__ == '__main__':
         device_ids_lst_rdd = spark.sparkContext.parallelize(device_ids_lst, numSlices=1000)
         result = device_ids_lst_rdd.repartition(100).map(lambda x: get_user_service_portrait(x, all_word_tags, all_tag_tag_type, all_3tag_2tag, all_tags_name))
         # result.foreach(print)
+        print("done")
         result.collect()
         spark.stop()
     except Exception as e: