bug fix

eda/esmm/Model_pipline/dist_predict.py

@@ -7,7 +7,11 @@ import datetime
 import pandas as pd
 import time
 from pyspark import StorageLevel
+import os
 
+os.environ["PYSPARK_PYTHON"] = "/opt/anaconda3/envs/esmm/bin/python"
+os.environ["LD_LIBRARY_PATH"] = "/usr/lib/jvm/java-8-openjdk-amd64/jre/lib/amd64/server:/opt/hadoop/lib/native"
+# os.environ["PYSPARK_PYTHON"] = "/opt/anaconda3/envs/esmm/bin/python"
 
 def model_fn(features, labels, mode, params):
     """Bulid Model function f(x) for Estimator."""