fix: fixed python environ error

This commit is contained in:
fly6516 2025-04-22 05:42:16 +00:00
parent 73ae9b135b
commit 5c00db57ff

View File

@ -3,8 +3,8 @@ import os
# Set Java environment variable
os.environ['JAVA_HOME'] = '/opt/module/jdk1.8.0_171'
os.environ["PYSPARK_PYTHON"]="/usr/local/bin/python3.6"
os.environ["PYSPARK_DRIVER_PYTHON"]="/usr/local/bin/python3.6"
os.environ["PYSPARK_PYTHON"]="/usr/bin/python3"
os.environ["PYSPARK_DRIVER_PYTHON"]="/usr/bin/python3"
# Parse ratings data into (userID, movieID, rating)
def get_ratings_tuple(entry):