提交Google Dataproc Hadoop作业时找不到Hadoop流jar？

$HADOOP_HOME/share/hadoop/tools/lib/hadoop-streaming-*.jar

gcloud dataproc jobs submit hadoop \
    --cluster=my-cluster \
    --region=us-central1 \
    --jar=/path/to/hadoop-streaming-*.jar \
    -- \
    -input /user/input \
    -output /user/output \
    -mapper my_mapper.py \
    -reducer my_reducer.py

export HADOOP_HOME=/path/to/hadoop
export PATH=$PATH:$HADOOP_HOME/bin

import os

# 设置Hadoop路径
os.environ['HADOOP_HOME'] = '/usr/lib/hadoop'
os.environ['PATH'] += os.pathsep + os.path.join(os.environ['HADOOP_HOME'], 'bin')

# 提交作业的命令
submit_command = """
gcloud dataproc jobs submit hadoop \
    --cluster=my-cluster \
    --region=us-central1 \
    --jar=/usr/lib/hadoop/share/hadoop/tools/lib/hadoop-streaming-*.jar \
    -- \
    -input gs://my-bucket/input \
    -output gs://my-bucket/output \
    -mapper my_mapper.py \
    -reducer my_reducer.py
"""

# 执行命令
os.system(submit_command)