test

eda/esmm/Model_pipline/dist_predict.py

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