test

eda/esmm/Model_pipline/dist_predict.py

@@ -209,7 +209,7 @@ if __name__ == "__main__":
     print(rdd_te_files.collect())
     print("-" * 100)
     indices = rdd_te_files.map(lambda x: main(x))
-    print(indices[0])
+    print(indices.collect())
 
     b = time.time()
     print("耗时(分钟)：")