update

eda/smart_rank/pyspark_argsparse_test.py

@@ -81,6 +81,10 @@ if __name__ == '__main__':
     spark.sparkContext.addPyFile("/srv/apps/ffm-baseline_git/eda/smart_rank/tool.py")
     device_ids_lst_rdd = spark.sparkContext.parallelize(action_type)
     print("="*100)
+    print(action_type)
+    print(type(device_ids_lst_rdd))
+    print(device_ids_lst_rdd)
+    print("=" * 100)
     result = device_ids_lst_rdd.repartition(100).map(
         lambda x: args_test(x))
     result.foreach(print)