os set

eda/esmm/Model_pipline/dist_predict.py

@@ -8,6 +8,8 @@ import datetime
 import pandas as pd
 import time
 from pyspark import StorageLevel
+import os
+os.environ["PYSPARK_PYTHON"] = "/srv/envs/esmm/bin/python"
 
 def model_fn(features, labels, mode, params):
     """Bulid Model function f(x) for Estimator."""