test

eda/esmm/Model_pipline/dist_predict.py

@@ -213,7 +213,7 @@ if __name__ == "__main__":
     print("-"*100)
     print(rdd_te_files.collect())
     print("-" * 100)
-    indices = rdd_te_files.repartion(100).map(lambda x: main(x))
+    indices = rdd_te_files.repartition(100).map(lambda x: main(x))
     print(indices.collect())
 
     b = time.time()